将输入流连接到输出流

java inputstream outputstream

2022-08-31 12:41:02

在java9中更新：https://docs.oracle.com/javase/9/docs/api/java/io/InputStream.html#transferTo-java.io.OutputStream-

我看到了一些类似的，但并不完全是我需要的线程。

我有一个服务器，它基本上会从客户端A获取输入，并将其逐个字节地转发到另一个客户端，客户端B。

我想将客户端 A 的输入流与客户端 B 的输出流连接起来。这可能吗？有什么方法可以做到这一点？

此外，这些客户端正在相互发送消息，这些消息对时间有些敏感，因此缓冲不起作用。我不想要一个500的缓冲区，客户端发送499字节，然后我的服务器推迟转发500字节，因为它没有收到最后一个字节来填充缓冲区。

现在，我正在解析每条消息以查找其长度，然后读取长度字节，然后转发它们。我认为（并测试）这比读取一个字节并一遍又一遍地转发一个字节要好，因为那会非常慢。我也不想使用缓冲区或计时器，因为我在上一段话中说过 - 我不希望消息仅仅因为缓冲区没有满而等待很长时间才能通过。

什么是做到这一点的好方法？

答案 1

仅仅因为您使用缓冲区并不意味着流必须填充该缓冲区。换句话说，这应该没问题：

public static void copyStream(InputStream input, OutputStream output)
    throws IOException
{
    byte[] buffer = new byte[1024]; // Adjust if you want
    int bytesRead;
    while ((bytesRead = input.read(buffer)) != -1)
    {
        output.write(buffer, 0, bytesRead);
    }
}

这应该可以正常工作 - 基本上调用将阻塞，直到有一些数据可用，但它不会等到它全部可用来填充缓冲区。（我想它可以，我相信通常会填充缓冲区，但是附加到套接字的流更有可能立即为您提供数据。readFileInputStream

我认为至少值得先尝试这个简单的解决方案。

答案 2

如何使用

void feedInputToOutput(InputStream in, OutputStream out) {
   IOUtils.copy(in, out);
}

并完成它？

来自jakarta apache commons i/o库，它已经被大量的项目使用，所以你可能已经在你的类路径中有了jar。