替换没有阻塞功能的java中的Inputstream

Question

当我尝试使用多个并行请求调用inputstream 的.read 方法时，响应时间会增加。我认为它在读取前一个响应之前会被阻止。

InputStream 的替代方案是什么？

我正在使用 UNIX 域套接字，我正在尝试从输入流中读取数据，这里的代码我正在使用----------

-

UnixDomainSocketClient socket = new UnixDomainSocketClient(sockFileName, JUDS.SOCK_STREAM);
InputStream in = socket.getInputStream();
OutputStream out = socket.getOutputStream();
out.write(inputStreamData.getBytes());
String modelResponse = "";
while (true) {
            try {
                modelResponse += (char) in.read();
            } catch (Exception e) {
                break;

            }
        }
        out.flush();
        socket.close();
        in.close();
        out.close();
}

Answer 1

当我尝试使用多个并行请求调用输入流的 .read 方法时，响应时间会增加。我认为它在读取前一个响应之前会被阻止。

没有。在数据到达此套接字之前，它会被阻塞。它与其他套接字无关，除了机器上的整体负载。读取不会在不同的输入流之间进行排序。

InputStream 的替代方案是什么？

通过 NIO 包的非阻塞 I/O 或异步 I/O，但您没有正确识别您的问题。您的应用程序中可能有一些不适当的同步。或者你的诊断不正确。