InputStream in.read() 的行为与预期不同

Question

我正在尝试使用 TCP 将文本文件传输到另一台服务器，但它的行为与预期不同。发送数据的代码是：

        System.out.println("sending file name...");
        String outputFileNameWithDelimiter = outputFileName + "\r\n"; //These 4 lines send the fileName with the delimiter
        byte[] fileNameData = outputFileNameWithDelimiter.getBytes("US-ASCII");
        outToCompression.write(fileNameData, 0, fileNameData.length);
        outToCompression.flush();

        System.out.println("sending content...");
        System.out.println(new String(buffer, dataBegin, dataEnd-dataBegin));
        outToCompression.write(buffer, dataBegin, dataEnd-dataBegin); //send the content
        outToCompression.flush();

        System.out.println("sending magic String...");
        byte[] magicStringData = "--------MagicStringCSE283Miami".getBytes("US-ASCII"); //sends the magic string to tell Compression server the data being sent is done
        outToCompression.write(magicStringData, 0, magicStringData.length);
        outToCompression.flush();

因为这是 TCP 并且您不能像在 UDP 中那样发送离散的数据包，所以我希望所有数据都在输入流中，我可以使用分隔符来分隔文件名、内容和结束字符串，然后每个 in.read() 只会给我下一个后续的数据量。

相反，这是我每次读取时获得的数据：

On the first in.read() byteBuffer appears to only have "fileName\r\n". 
On the second in.read() byteBuffer still has the same information. 
On the third in.read() byteBuffer now holds the content I sent. 
On the fourth in.read() byteBuffer holds the content I sent minus a few letters.
On the fifth in.read() I get the magicString + part of  the message.

我在每次从 Web 服务器发送时都会刷新，但输入流似乎无法实现可刷新。

谁能解释为什么会这样？

编辑： 这就是我读取内容的方式。基本上这是循环然后写入文件。

 in.read(byteBuffer, 0, BUFSIZE);

Answer 1

当您从 InputStream 读取数据时，您将为其提供一个字节数组以写入（以及可选的偏移量和最大读取量）。 InputStream 不保证数组将被新数据填充。返回值是实际读入的字节数。

您的示例中发生的情况是这样的：

• 第一个 TCP 数据包带有"fileName\r\n"，被写入缓冲区，到目前为止一切正常。
• 您再次调用read()，但下一个数据包尚未到达。 read() 将返回0，因为它不想在数据到达之前阻塞。所以缓冲区仍然包含"fileName\r\n"。编辑：正如所指出的，read() 总是阻塞，直到它读取至少一个字节。真的不知道为什么缓冲区没有改变。
• 三读时，内容已到。
• 内容的第一位被消息的第二部分覆盖，最后一位仍然包含旧消息的一部分（我认为这就是您的意思）。
• 等等，你懂的

您需要检查返回值，等待数据到达，并且只使用最后一个read() 写入的缓冲区。

Answer 2

如果您的期望是读取将填满缓冲区，或者接收对等方由单个 write() 发送的确切内容，那么您的期望是这里的错误，而不是 read(). 它没有指定为一次传输超过一个字节，并且无法保证保留写边界。

如果不将read() 的结果存储到变量中，就不可能编写正确的代码。