java - BufferedOutputStream 连接两个连续的flush() 调用

Question

我想使用 BufferedOutputStream 发送单独的消息。所以我做 bos.write(msg1); bos.flush(); bos.write(msg2); bos.flush()。另一方面，我有一个 BufferedReader，它依赖于这些消息的分离:

BufferedReader br = new BufferedReader(new InputStreamReader(server.getInputStream()));
InputStream is = server.getInputStream();
while (true) {
    if (br.ready()) {
        byte[] bytes = new byte[is.available()];
        is.read(bytes);
    }
}

但是我得到的是这样的:“向客户端发送 30 个字节；向客户端发送 30 个字节”，另一端:“已接收 60 个字节”。

Answer 1

您提到的行为来自 TCP，而不是来自 BufferedOutputStream ，原因是 TCP 中不存在消息这样的东西，因此不能保证写入大小和读取大小之间的任何对应关系。它是一种字节流协议(protocol)。如果您想要消息边界，您必须自己提供它们。

您不应该使用ready()和available()也可以这样。只需使用固定大小的缓冲区，然后阻塞即可。