我之前问过:https://stackoverflow.com/questions/35344535/dcom-alternative-for-java-sending-audio-streaming-in-the-same-machine

我想使用一台服务器从我的麦克风中捕获音频并发送给客户端(0 或 4)...

PD:我正在检查这个问题:Sending audio stream over TCP, UnsupportedAudioFileException但面向 One server with One Client 解决方案。 其他问题:Java - Broadcast voice over Java sockets Streaming audio from microphone with Java

我正在考虑使用 TCP(服务器/客户端模型)，但服务器和 4 个客户端将接收数据(音频流)，我不知道是否可以实现此替代方案(我担心港口管理)...

这里是我的初步(它仍然没有用，因为我有疑问，我在想如何解决我的顾虑)

变量:

static boolean bThreadCapture = false;
static boolean bThreadServer = false;
static ByteArrayOutputStream myByteArrayOutStream;
ExecutorService myServerPool = Executors.newFixedThreadPool(4);
static Thread myThreadServer = null;

现在我头疼

  final int iServerPort = 2370;
  final AudioFormat myAudioFormat = new AudioFormat(8000,8,1,false, true);
  final DataLine.Info myDataLineInfo = new DataLine.Info(TargetDataLine.class, myAudioFormat);
  if (!AudioSystem.isLineSupported(myDataLineInfo)) {
    System.out.println("Line not supported");
    System.exit(0);
  }
  try {
    final TargetDataLine myTargetDataLine = (TargetDataLine) AudioSystem.getLine(myDataLineInfo);
    myTargetDataLine.open(myAudioFormat);
    myByteArrayOutStream = null;

    //BEGIN definition Thread for CAPTURING AUDIO FROM MIC
    Runnable runnAudioCapture = new Runnable() {
      int bufferSize = (int) myAudioFormat.getSampleRate()* myAudioFormat.getFrameSize();
      byte buffer[] = new byte[bufferSize];
      public void run() {
        myByteArrayOutStream = new ByteArrayOutputStream();
        bThreadCapture = true;
        while (bThreadCapture) {
          try {
            int count = myTargetDataLine.read(buffer, 0, buffer.length);
            if (count > 0) {
              myByteArrayOutStream.write(buffer, 0, count);
              //  HERE: I need to send the bytes of Sound to all active Threads Client (from 1 until 4)
              //  But, How to know what (how much and which) are active threads client?
              //  How to access to each Executor?
            }
          } catch (IllegalArgumentException | ArrayIndexOutOfBoundsException e) {
            System.err.println("TargetDataLine problems: " + e);
          }
        }
        try {
          if (myByteArrayOutStream != null) myByteArrayOutStream.close();
        } catch (IOException e) {  }
      }
    };
    //END definition Thread for CAPTURING AUDIO FROM MIC


    //BEGIN definition Thread for ATTENDANT SERVER CLIENT (Still not defined) 
    myThreadServer = new Thread() {
      @Override
      public void run() {
        try {
          SrvrSocketProducer = new ServerSocket(iServerPort);
          System.out.println("Server Listening on port number: "+iServerPort);
        } catch (IOException e) {
          System.out.println("Could not listen on port: "+iServerPort);
        }
        new Thread(runnAudioCapture).start();  //BEGIN AUDIO CAPTURE
        while(bThreadServer) {
          Socket clientSocket = null;
          try {
            clientSocket = SrvrSocketProducer.accept(); 
          } catch (IOException e) {
            if(!bThreadServer) {
              System.out.println("Server Stopped.") ;
              break;
            }
            throw new RuntimeException("Error accepting client connection", e);
          }
          myServerPool.execute(new runnWorkerListener(clientSocket,myAudioFormat));
        }
        myServerPool.shutdown();
        bThreadCapture = false;  //STOP AUDIO CAPTURE
      }
    };
    //END definition Thread for ATTENDANT SERVER CLIENT (Still not defined) 
    myThreadServer.start();
  } catch (LineUnavailableException ex) {
    System.out.println(ex.toString());
  }

问题:

(合并到runnAudioCapture代码中定位帮助)

1. HERE: I need to send the bytes of Sound to all ACTIVE Threads Client (from 1 until 4)
2. But, How to know what (how much and which) are active threads client?
3. How to access to each Executor?

现在工作线程--

  class runnWorkerListener implements Runnable {
    Socket innerClientSocket = null;
    AudioFormat innerAdfmt = null;
    public runnWorkerListener(Socket clientSocket, AudioFormat audioFormat) {
      innerClientSocket = clientSocket;
      innerAdfmt = audioFormat;
    }
    public void run() {
      try {
        InputStream input  = innerClientSocket.getInputStream();
        OutputStream output = innerClientSocket.getOutputStream();
        // Now How Can I to Comunicate with runnAudioCapture?
        while (RunningClientAttender /*This variable still is not defined*/) {
          // I need to send (thread client here Not defined) EACH bytes from runnAudioCapture
        }
        output.close();
        input.close();
        System.out.println("Request processed: ");
      } catch (IOException e) {
        //report exception somewhere.
        e.printStackTrace();
      }
    }
  }

问题:

(合并到runnWorkerListener代码中定位帮助)

1. Now How Can I to Comunicate with runnAudioCapture?
2. I need to send (thread client here Not defined) EACH bytes from runnAudioCapture

我的疑问与: 一个专用于音频捕获的线程 一个线程专用于使用 Pool 接收客户端(1、2、3 或 4)并创建线程 worker (一个线程 worker 与“远程”客户端通信)

我不知道 Capturer 线程 Capturer 与每个 Worker 线程的句柄同步...

谢谢...

最佳答案

不幸的是，在 Java 中，流一次只能由一个人使用。您有一个流 myByteArrayOutStream，并且您希望在 4 个 TCP 连接之间共享它。

我建议您将音频数据写入文件。每次客户端连接时，您都会将文件的所有内容流式传输到该客户端(您可以打开文件，跳到最后，如果需要，只流式传输新内容)。为此，您需要为每个客户创建一个新线程。

如果您希望在 Java 中构建类似 Skype 音频的东西，那么这比仅使用 TCP 稍微复杂一些。 TCP 是一种从 A 到 B 获取数据的方法，可靠。对于音频，您通常希望它实时从 A 传输到 B。如果您在此过程中丢失了一个数据包，您不想返回并重新传输它，因为那样会给调用引入延迟。 TCP 的替代方案(可能更适合您的情况)是 UDP。它发送单个数据包，并且不保证它们会按顺序到达，甚至根本不保证。但它不会停下来等待丢失的数据包。

关于JAVA(发送音频流 一服务器四客户端同机)，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35491848/