您可以同时写入套接字的输入和输出流吗？

Question

我有一个Java应用程序，即Voip。我正在使用一个套接字通过线程同时发送和接收信息。代码如下所示。

Socket clientSocket = sockList.accept();
OutputStream outSock = clientSocket.getOutputStream();
InputStream inSock = clientSocket.getInputStream();
new Thread( new Capture(outSock)).start();
new Thread( new PlayAudio(inSock)).start();
outSock.close();
clientSocket.close();

我发现的问题是，当我写入输出流时，它在第一次写入时阻塞。我发送的字节数不多。贝娄是我的写代码。

private class Capture implements Runnable{

    private OutputStream out;
    public Capture(OutputStream out){
        this.out = out;
    }
    @Override
    public void run() {
        try{
            int numBytesRead;
            TargetDataLine outLine = getMic();
            outLine.open();
            outLine.start();

            byte[] data = new byte[outLine.getBufferSize() / 5];
            byte[] test = {0x1,0x1,0x1};

            while(true) {       
                //numBytesRead =  outLine.read(data, 0, data.length);
                //System.out.println(numBytesRead);
                out.write(test, 0, test.length);
                out.flush();
                /*if(numBytesRead > 0){
                    out.write(data, 0, data.length);
                    System.out.println("C");
                }*/
            }
        }catch(Exception ex){}
    }
}

读取声音代码的另一个线程是…

private class PlayAudio implements Runnable{

    private InputStream in;
    public PlayAudio(InputStream in){
        this.in = in;
    }
    @Override
    public void run() {
        int write;
        try{
        SourceDataLine inLine = getSpeaker();
        inLine.open();
        inLine.start();
        byte[] data = new byte[inLine.getBufferSize()];
        byte[] test = new byte[3];
        while(true){
            System.out.println(1);
            //write = in.read(data, 0, data.length);
            in.read(test, 0 , test.length);
            System.out.println(2);
            /*if(write > 0){
                inLine.write(data, 0, write);
                System.out.println(3);
                System.out.println(write);
            }*/
        }
        } catch(Exception ex){}
    }

}

我已经在实际代码中注释了很大一部分，因为我只是想使其正常工作。我的写函数在第一次写时无限期阻塞。这可能是我的线程有问题吗？我唯一的想法是输出和输入流共享我的套接字对象，这可能会导致死锁或其他原因。请让我知道最新情况。

Answer 1

是的，您可以同时写入套接字的输入和输出流。

从do-java-sockets-support-full-
duplex

由于输入流和输出流是Socket中的单独对象，因此您可能要担心的唯一问题是，如果有两个线程试图同时读取或写入（两个线程，相同的输入/输出流），该怎么办？时间？InputStream
/ OutputStream类的读/写方法不同步。但是，如果使用的是InputStream /
OutputStream的子类，则可能会同步正在调用的读取/写入方法。您可以检查javadoc中是否有要调用的类/方法，并很快找到它。