在 readline() 调用之后，Java 的 BufferedReader 是否在其内部缓冲区中留下字节？

Question

我在我的服务器中遇到了一个问题，在我发送一个包含 X 字节的文件后，我发送一个字符串，表示该文件已结束，另一个文件即将到来，就像

FILE: a SIZE: Y\r\n
send Y bytes
FILE a FINISHED\r\n
FILE b SIZE: Z\r\n
send Z byes
FILE b FINISHED\r\n
FILES FINISHED\r\n

在我的客户端中它无法正确接收一样。 从套接字读取 Y 或 Z 字节后，我使用 readline() 获取命令行。 对于一个文件，它工作得很好，对于多个文件，它很少工作（是的，我不知道它是如何工作一次或两次）

以下是我用来传输二进制文件的一些代码

public static void readInputStreamToFile(InputStream is, FileOutputStream fout,
        long size, int bufferSize) throws Exception
{
    byte[] buffer = new byte[bufferSize];
    long curRead = 0;
    long totalRead = 0;
    long sizeToRead = size;
    while(totalRead < sizeToRead)
    {
        if(totalRead + buffer.length <= sizeToRead)
        {
            curRead = is.read(buffer);
        }
        else
        {
            curRead = is.read(buffer, 0, (int)(sizeToRead - totalRead));
        }
        totalRead = totalRead + curRead;
        fout.write(buffer, 0, (int) curRead);
    }
}





public static void writeFileInputStreamToOutputStream(FileInputStream in, OutputStream out, int bufferSize) throws Exception
{
    byte[] buffer = new byte[bufferSize];
    int count = 0;
    while((count = in.read(buffer)) != -1)
    {
        out.write(buffer, 0, count);
    }
}

，只是为了说明我可以解决将 readline 替换为此代码的问题：

    ByteArrayOutputStream ba = new ByteArrayOutputStream();
    int ch;
    while(true)
    {
        ch = is.read();
        if(ch == -1)
            throw new IOException("Conecção finalizada");
        if(ch == 13)
        {
            ch = is.read();
            if(ch == 10)
                return new String(ba.toByteArray(), "ISO-8859-1");
            else
                ba.write(13);
        }
        ba.write(ch);
    }

PS：“ is" 是我来自套接字的输入流：socket.getInputStream();

我仍然不知道这是否是最好的实现，我正在尝试弄清楚

Answer 1

这里的代码中没有 readLine() 调用，而是回答您的问题；是的，调用 BufferedReader.readLine() 很可能会在其内部缓冲区中留下一些东西。它正在缓冲输入。

如果您将其中一个 InputStream 包装在 BufferedReader 中，那么如果您先从 BufferedReader 读取数据，然后再读取数据，则无法真正获得理智的行为从 InputStream 读取。

您可以从 InputStream 读取字节，并通过查找一对 \r\n字节。当您看到一行显示 "FILE: a SIZE: Y\r\n" 时，您将像往常一样继续，只是用于解析行的缓冲区可能包含文件的前几个字节，因此首先将这些字节写出。

或者，您使用 FTP 的思想，使用一个 TCP 流用于命令，使用一个 TCP 流用于实际传输，使用 BufferedReader.readLine() 从命令流中读取数据，并像之前一样读取数据使用InputStream。

Answer 2

是的，BufferedReader 的主要目的是缓冲数据。它以更大的块从其底层 Reader 读取输入，以避免多次小读取。

它有一个 readLine() 方法，这只是一个很好的好处，通过缓冲可以轻松实现。

如果您确实必须通过同一连接混合文本和二进制数据，您可能需要使用 DataInputStream（位于 BufferedInputStream 之上）及其 readLine() 方法 - 从同一 DataInputStream 读取数据。 （但要注意这里的编码。）

Answer 3

在写入要确定已发送的数据后，在 OutputStream 上调用 flush()。所以本质上是在每个文件的末尾调用flush()。

Answer 4

我想您必须刷新输出流，以确保任何缓冲的字节都正确发送到流中。关闭流同样会运行该进程。

刷新的 Javadocs 说：

刷新此输出流并强制
任何缓冲的输出字节
写出来了。总承包合同
冲洗是调用它是一个
表明，如果有任何字节
之前写入的内容已被缓冲
通过执行输出
流，这样的字节应该立即
写成他们想要的
目的地。