Java：BufferedReader 读取的内容超过一行？

Question

我正在用 Java 编写一个带有套接字的程序。我可以向客户端发送命令，也可以从客户端向服务器发送命令。为了读取命令，我使用了 BufferedReader。要编写它们，需要一个PrintWriter，但现在我想通过那个套接字传输文件（不仅仅是创建第二个连接）。
首先，我向输出流写入文件包含的字节数。例如 40000 字节。因此，我通过套接字写入数字 40000，但连接的另一端读取 78。

所以我在想：BufferedReader 读取的不仅仅是行（通过调用readLine()），这样我就丢失了一些字节文件数据。因为它们位于 BufferedReader 的缓冲区中。
所以数字78是我要传输的文件的一个字节。

这种思维方式对还是不对。如果是这样，如何解决这个问题。
我希望我已经解释得很好了。

---

这是我的代码，但我的默认语言是荷兰语。所以有些变量名听起来很奇怪。

public void flushStreamToStream(InputStream is, OutputStream os, boolean closeIn, boolean closeOut) throws IOException {
    byte[] buffer = new byte[BUFFERSIZE];
    int bytesRead;
    if ((!closeOut) && closeIn) { // To Socket from File
        action = "Upload";
        os.write(is.available()); // Here I write 400000
        max = is.available();
        System.out.println("Bytes to send: " + max);
        while ((bytesRead = is.read(buffer)) != -1) {
            startTiming(); // Two lines to compute the speed
            os.write(buffer, 0, bytesRead);
            stopTiming(); // Speed compution
            process += bytesRead;
        }
        os.flush();
        is.close();
        return;
    }
    if ((!closeIn) && closeOut) { // To File from Socket
        action = "Download";
        int bytesToRead = -1;
        bytesToRead = is.read(); // Here he reads 78.
        System.out.println("Bytes to read: " + bytesToRead);
        max = bytesToRead;
        int nextBufferSize;
        while ((nextBufferSize = Math.min(BUFFERSIZE, bytesToRead)) > 0) {
            startTiming();
            bytesRead = is.read(buffer, 0, nextBufferSize);
            bytesToRead -= bytesRead;
            process += nextBufferSize;
            os.write(buffer, 0, bytesRead);
            stopTiming();
        }
        os.flush();
        os.close();
        return;
    }
    throw new IllegalArgumentException("The only two boolean combinations are: closeOut == false && closeIn == true AND closeOut == true && closeIn == false");
}

---

解决方案如下：
感谢詹姆斯的建议
我认为 laginimaineb anwser 是解决方案的一部分。

阅读命令。

DataInputStream in = new DataInputStream(is); // Originally a BufferedReader
// Read the request line
String str;
while ((str = in.readLine()) != null) {
    if (str.trim().equals("")) {
       continue;
    }
    handleSocketInput(str);
}

现在是flushStreamToStream：

public void flushStreamToStream(InputStream is, OutputStream os, boolean closeIn, boolean closeOut) throws IOException {
    byte[] buffer = new byte[BUFFERSIZE];
    int bytesRead;
    if ((!closeOut) && closeIn) { // To Socket from File
        action = "Upload";
        DataOutputStream dos = new DataOutputStream(os);
        dos.writeInt(is.available());

        max = is.available();
        System.out.println("Bytes to send: " + max);
        while ((bytesRead = is.read(buffer)) != -1) {
            startTiming();
            dos.write(buffer, 0, bytesRead);
            stopTiming();
            process += bytesRead;
        }
        os.flush();
        is.close();
        return;
    }
    if ((!closeIn) && closeOut) { // To File from Socket
        action = "Download";
        DataInputStream dis = new DataInputStream(is);
        int bytesToRead = dis.readInt();
        System.out.println("Bytes to read: " + bytesToRead);
        max = bytesToRead;
        int nextBufferSize;
        while ((nextBufferSize = Math.min(BUFFERSIZE, bytesToRead)) > 0) {
            startTiming();
            bytesRead = is.read(buffer, 0, nextBufferSize);
            bytesToRead -= bytesRead;
            process += nextBufferSize;
            os.write(buffer, 0, bytesRead);
            stopTiming();
        }
        os.flush();
        os.close();
        return;
    }
    throw new IllegalArgumentException("The only two boolean combinations are: closeOut == false && closeIn == true AND closeOut == true && closeIn == false");
}

Martijn。

Answer 1

我不确定我是否听从了你的解释。

但是，是的 - 您无法真正控制 BufferedReader 实际读取的量。这种读取器的要点在于，它会根据需要乐观地读取底层资源块以补充其缓冲区。因此，当您第一次调用readLine时，它会发现其内部缓冲区没有足够的空间来满足您的请求，并且会继续读取它认为需要的字节数< /strong> 来自底层源，这通常会比您当时要求的要多得多。一旦缓冲区被填充，它就会从缓冲的内容中返回您的行。

因此，一旦将输入流包装在 BufferedReader 中，您应该确保仅通过同一个缓冲读取器读取该流。如果不这样做，您最终将丢失数据（因为一些字节将被消耗并且现在位于 BufferedReader 的缓存中等待服务）。

Answer 2

DataInputStream 很可能是您想要使用的。另外，不要使用 available() 方法，因为它通常是无用的。

Answer 3

BufferedReader 假定它是从底层输入流中唯一读取的内容。

其目的是最大限度地减少从底层流读取的次数（这是昂贵的，因为它们可以委托得相当深）。为此，它保留一个缓冲区，通过在对底层流的单次调用中读取尽可能多的字节来填充该缓冲区。

所以是的，你的诊断是准确的。

Answer 4

这里只是一个疯狂的尝试 - 40000 是二进制的 1001110001000000。现在，这里的前 7 位是 1001110，即 78。这意味着，您正在写入 2 个字节的信息，但读取 7 位。