자바 소켓 사이에서 오디오를 전달하는 방법

Question

메신저는 소켓간에 오디오를 전달하려고 시도하지만 클라이언트에서 멈추는 것보다 클라이언트에서 한 번 전달됩니다. 내가 길 메신저 쓰기를 생각하고 잘못 될 수있다 보내는 다음이 코드 에 대한 좀 도와주세요 나의 서버 코드 :

public void run(){ 
    try{ 
      SetInitialSettings(); 
      int bufferSize = (int) format.getSampleRate() * (int) format.getFrameSize(); 
      System.out.println("length :" +bufferSize); 
      out = new ByteArrayOutputStream(); 
      readagain=true; 
      while(record){ 
      int count=0; 

      for(int i=0;i<1000;i++) 
      { 

         if(buffer==null){ 
         buffer = new byte[bufferSize]; 
         } 
         count = line.read(buffer, 0, buffer.length); 
         if (count > 0) { 
         //out.write(buffer, 0, count); 
         //readagain=false; 
          for (int j=0;i<ser.clientReceiver.audioSender.size();j++){ 
          ser.clientReceiver.audioSender.get(i).cliOut.write("Audio".getBytes()); 
          ser.clientReceiver.audioSender.get(i).cliOut.write('\n'); 
          ser.clientReceiver.audioSender.get(i).cliOut.flush(); 
          ser.clientReceiver.audioSender.get(i).cliOut.write(buffer,0,count); 
          ser.clientReceiver.audioSender.get(i).cliOut.flush(); 
          Thread.sleep(2000); 

           } 
         } 

      }    




    } 
    } 
    catch(Exception ex) 
    { 
     System.out.println(ex.getMessage()); 

    } 




    } 

및 다음 내 클라이언트 코드 :

공공 무효 실행() {

try{ 
     //audioReceiver = new TAudioReceiver(cli); 
     //audioReceiver.start(); 
     while(true){ 

      //Thread.sleep(1000);  
      System.out.println("reading token"); 
      cmd= cli.BufferedReader().readLine(); 
      System.out.println("token :" +cmd); 
      switch (cmd) { 
       case "Msg": 
        message = cli.BufferedReader().readLine(); 
        cmd="None"; 
        break; 
      case "File": 
       GetFile(); 
       break; 
      case "Audio": 
       PlayAudio(); 
       break; 


     } 


     } 

     //reading msgs here 
    } 
    catch(Exception ex) 
    { 
     //throw new InterruptedException(ex.getMessage()); 
    } 
} 

이 은 "오디오"MSG는 서버에서 클라이언트로 받았을 때 실행할 수있는 기능이 필요하다

public void PlayAudio()throws Exception{ 

    try{ 

        cli.ServerInputStream().read(buffer); 


        audio = buffer; 
        audioIn = new ByteArrayInputStream(audio); 
        AudioFormat f = new AudioFormat(8000, 8, 1,true, true); 
        ain= new AudioInputStream(audioIn,f, audio.length/f.getFrameSize()); 
        DataLine.Info info = new DataLine.Info(SourceDataLine.class, f); 
        try (SourceDataLine line = (SourceDataLine)AudioSystem.getLine(info)) { 
         int bufferSize = (int) f.getSampleRate()* f.getFrameSize(); 
         buffer= new byte[bufferSize]; 
         int count; 
         while ((count = ain.read(buffer, 0, buffer.length)) != -1) { 
         if (count > 0) { 
          line.write(buffer, 0, count); 
         } 
         } 
         line.drain(); 
        } 

    } 
    catch(Exception ex) 
    { 
     System.out.println("file" + ex.getMessage()); 
    } 


} 

Answer 1

원본 코드가 더 좋았습니다. 쓰기 (버퍼, 0, 카운트), 쓰기 (버퍼)하지 않아야합니다. 그렇지 않으면 마지막으로 읽을 때 읽지 않은 각 버퍼의 끝에 쓰레기를 쓰게됩니다. 두 번째 코드는 read()의 결과를 무시합니다.