Аудиовизуальное воспроизведение на основе клиентского сервера в Java с использованием Socket

Question

Данный код предназначен для потоковой передачи потокового аудио между клиентом и сервером с помощью java-сокета, но проблема в том, что при запуске этого проекта клиент начинает запись звука и отправляет его на стороне приемника (сервера). Затем сервер буферизует полученный звук, но не воспроизводит его одновременно. Но когда клиент закрыт, сервер начинает воспроизводить звук. Пожалуйста, помогите мне. Мне нужен тот сервер, который должен воспроизводить полученный звук одновременно.

\ клиент

import java.io.*; 
import java.net.*; 
import java.sound.sampled.*; 
import org.apache.commons.io.IOUtils; 
public class ClientStream{ 
public ClientStream() throws IOException{ 
    isl.runListener(); 
} 

private IncomingSoundListener isl = new IncomingSoundListener();  
AudioFormat format = getAudioFormat(); 
InputStream is; 
Socket client; 
String serverName = "192.168.2.8"; 
int port=3000; 
boolean inVoice = true; 


private AudioFormat getAudioFormat(){ 
    float sampleRate = 16000.0F; 
    int sampleSizeBits = 16; 
    int channels = 1; 
    boolean signed = true; 
    boolean bigEndian = false; 

    return new AudioFormat(sampleRate, sampleSizeBits, channels, signed, bigEndian); 
} 
class IncomingSoundListener { 
    public void runListener(){ 
     try{ 
      System.out.println("Connecting to server:"+serverName+" Port:"+port); 
      client = new Socket(serverName,port); 
      System.out.println("Connected to: "+client.getRemoteSocketAddress()); 
      System.out.println("Listening for incoming audio."); 
      DataLine.Info speakerInfo = new DataLine.Info(SourceDataLine.class,format); 
      SourceDataLine speaker = (SourceDataLine) AudioSystem.getLine(speakerInfo); 
      speaker.open(format); 
      speaker.start(); 
      while(inVoice){ 
       is = client.getInputStream(); 
       byte[] data = IOUtils.toByteArray(is); 
       ByteArrayInputStream bais = new ByteArrayInputStream(data); 
       AudioInputStream ais = new AudioInputStream(bais,format,data.length); 
       int bytesRead = 0; 
       if((bytesRead = ais.read(data)) != -1){ 
        System.out.println("Writing to audio output."); 
        speaker.write(data,0,bytesRead); 

    //     bais.reset(); 
       } 
       ais.close(); 
       bais.close(); 

      } 
      speaker.drain(); 
      speaker.close(); 
      System.out.println("Stopped listening to incoming audio."); 
     }catch(Exception e){ 
      e.printStackTrace(); 
     } 
    } 
} 
public static void main(String [] args) throws IOException{ 
     new ClientStream(); 
    } 

}

\ сервер

import java.io.*; 
import java.net.*; 
import java.sound.sampled.*; 
public class ServerStream { 
private OutgoingSoudnListener osl = new OutgoingSoudnListener(); 
boolean outVoice = true; 
AudioFormat format = getAudioFormat(); 

private ServerSocket serverSocket; 
Socket server; 
private AudioFormat getAudioFormat() { 
    float sampleRate = 16000.0F; 
    int sampleSizeBits = 16; 
    int channels = 1; 
    boolean signed = true; 
    boolean bigEndian = false; 

    return new AudioFormat(sampleRate, sampleSizeBits, channels, signed, bigEndian); 
} 
public ServerStream() throws IOException{ 
    try{ 
     System.out.println("Creating Socket..."); 
     serverSocket = new ServerSocket(3000); 
     osl.runSender(); 
    }catch(Exception e){ 
     e.printStackTrace(); 
    } 
} 
class OutgoingSoudnListener{ 
    public void runSender(){ 
     try{ 
      server = serverSocket.accept(); 
      System.out.println("Listening from mic."); 
      DataOutputStream out = new DataOutputStream(server.getOutputStream()); 
      DataLine.Info micInfo = new DataLine.Info(TargetDataLine.class,format); 
      TargetDataLine mic = (TargetDataLine) AudioSystem.getLine(micInfo); 
      mic.open(format); 
      System.out.println("Mic open."); 
      byte tmpBuff[] = new byte[mic.getBufferSize()/5]; 
      mic.start(); 
      while(outVoice) { 
       System.out.println("Reading from mic."); 
       int count = mic.read(tmpBuff,0,tmpBuff.length); 
       if (count > 0){ 
        System.out.println("Writing buffer to server."); 
        out.write(tmpBuff, 0, count); 
       }    
       } 
      mic.drain(); 
      mic.close(); 
      System.out.println("Stopped listening from mic."); 
     }catch(Exception e){ 
      e.printStackTrace(); 
     } 
    } 

} 
public static void main (String args[]) throws IOException{ 
    new ServerStream(); 

} 

}

Answer 1

соединение клиент-сервер, а затем Socket основан на модели протокола TCP. Как вы можете подтвердить в своих документах.

То, что вы ищете, это DatagramSocket, основанный на UDP, вы можете пострадать от потери пакетов, но это так, как все работает. Вот как работает потоковое видео, вы получаете некоторые, вы теряете некоторые.

Теперь у вас возникает вопрос, одна из проблем, возникающих при реализации с TCP-протоколом, заключается в том, что TCP основан на подтверждениях, чтобы синхронизировать связь, если ваш сервер или клиент не смог подтвердить, из-за этого испытывают поток, чтобы застрять.