DataOutputStream 未刷新

Question

我有一个 Java 客户端，它将 UTF-8 字符串发送到 C# TCP 服务器，我使用 DataOutputStream 发送字符串。代码如下所示：

public void sendUTF8String(String ar) {
    if (socket.isConnected()) {
        try {
            dataOutputStream.write(ar.getBytes(Charset.forName("UTF-8")));
            dataOutputStream.flush();
        } catch (IOException e) {
            handleException(e);
        }
    }
}

问题是刷新似乎无法正常工作。如果我发送两个彼此靠近的字符串，服务器只会收到一条包含这两个字符串的消息。如果我在调用之间执行 Thread.sleep(1000) ，整个事情就会起作用，这显然不是一个解决方案。 我缺少什么？

Answer 1

flush() 不保证数据包被发送出去。您的 TCP/IP 堆栈可以自由地捆绑您的数据，以实现最大效率。更糟糕的是，您和目的地之间可能存在许多其他 TCP/IP 堆栈，并且它们可以随意执行相同的操作。

我认为你不应该依赖数据包捆绑。在数据中插入逻辑终止符/分隔符，这样您就安全了。

Answer 2

您不必担心数据如何分解为数据包。

您应该在消息中包含字符串的长度，然后在接收端首先读取该长度。因此，例如发送给你会做

byte[] arbytes = ar.getBytes(Charset.forName("UTF-8"));
output.writeInt(arbytes.length)
output.write(arbytes)

，然后在你的阅读器中你做

byte[] arbytes = new byte[input.readInt()];
for(int i = 0; i < len; i++){
     arbytes[i] = input.read();
}
//convert bytes back to string.

你不能只调用 input.read(arbytes) 因为读取函数不一定读取数组的整个长度。您可以执行一个循环，一次读取一个块，但其代码有点复杂。

无论如何，你明白了。

---

另外，如果您真的想要控制数据包中的内容，您可以使用数据报套接字，但如果您这样做，则无法保证数据包的传送。

Answer 3

套接字发送数据流，而不是消息。
您不应依赖收到的数据包与发送的数据包大小相同。
正如您所看到的，数据包可以组合在一起，但也可以分解。
使用 @Chad Okere 关于如何确保您获得的块与发送的块相同的建议。

但是，就您而言，您可以使用

dataOutputStream.writeUTF(ar); // sends a string as UTF-8

和

String text = dataInputStream.readUTF(); // reads a string as UTF-8