Java套接字通信问题

Question

我正在使用 Java 进行套接字通信。服务器正在从客户端读取字节，如下所示：

InputStream inputStream;
final int BUFFER_SIZE = 65536;
byte[] buffer = new byte[BUFFER_SIZE];
String msg="";

while (msg.indexOf(0)==-1 && (read = inputStream.read(buffer)) != -1)
{
    msg += new String(buffer, 0, read);
}
handleMessage(msg)

当客户端一次发送多条消息时出现问题，服务器混合消息，例如

MSG1: <MyMessage><Hello/>nul
MSG2: </MyMessage><MyMessage><Hello again /></MyMessage>nul

所以消息 1 的尾部是消息 2 的一部分。 null 代表 java nul 符号。

为什么输入流混合消息？

提前致谢！

Answer 1

您进行了错误的比较。您检查字符串中是否有 \0，然后相信它是一条消息。错误的。事实上，在第二个例子中，\0 出现了两次。

你应该做不同的事情。逐字符读取流中的字符（使用包装的 BufferedInputStream，否则性能会很糟糕），并在达到 \0 时跳过。现在消息已完成，您可以处理它了。

InputStream bin = new BufferedInputStream(inputStream);
InputStreamReader reader = new InputStreamReader(bin);
StringBuilder msgBuilder = new StringBuilder();
char c;
while ( (c=reader.read()) != -1 ) 
{
    msgBuilder .append(c);
}
handleMessage(msgBuilder.toString())

更好的是使用换行符进行行分隔。在这种情况下，您可以只使用 BufferedReader 的 readline() 功能。

Answer 2

Sockets 和 InputStream 只是字节流，而不是消息。 如果您想根据\0 之类的字符拆分流，您需要自己执行此操作。

但是，在您的情况下，您的发送端似乎存在错误，因为 \0 不是正确的位置，并且极不可能成为客户端的错误。

顺便说一句：使用 String += 非常低效。

Answer 3

您从InputStream 读取的数据将进入，因为它可以从操作系统获得，并且无法保证将如何拆分。如果您希望在新行上拆分，您可能需要考虑这样的事情：

BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));

然后使用reader.readLine() 将每一行作为String 这是您的消息。

Answer 4

我认为你的问题在于你的方法：

客户端一次发送多条消息时出现问题

套接字通常只获取字节块，诀窍在于如何发送它们，如何标记消息的开始/结束以及如何检查错误（快速哈希可以做很多好事）所以在我看来，这种行为很好，如果你真的需要一次发送多条消息，你只需要处理你的消息。

套接字将控制您的消息是否在物理方面是完整的，但消息中的内容是您关心的。