我应该如何从缓冲阅读器中读取内容？

Question

我有以下从缓冲读取器读取的示例：

while ((inputLine = input.readLine()) != null) {
   System.out.println("I got a message from a client: " + inputLine);
}

只要缓冲读取器中出现某些内容（在本例中为 input），循环 println 中的代码就会被执行。就我而言，如果客户端应用程序向套接字写入某些内容，则循环（在服务器应用程序中）中的代码将被执行。

但我不明白它是如何工作的。 inputLine = input.readLine() 等待直到缓冲读取器中出现某些内容，当其中出现某些内容时，它返回 true 并执行循环中的代码。但是当null时可以返回。

还有一个问题。上面的代码取自一个抛出异常的方法，我在线程的 run 方法中使用了这段代码。当我尝试在运行之前放置抛出异常时，编译器会抱怨：重写的方法不会抛出异常。如果没有抛出异常，我还会收到编译器的另一个抱怨：​​未报告的异常。那么，我能做什么呢？

Answer 1

当另一端的套接字关闭时，读取器应返回空字符串。这就是您正在寻找的条件。要处理异常，请将读取循环包装在 try/catch 块中。

 try {
   while ((inputLine = input.readLine()) != null) {
     System.out.println("I got a message from a client: " + inputLine);
   }
 }
 catch (IOException e) {
   System.err.println("Error: " + e);
 }

您可能会发现这个关于读取/写入的教程到 Java 中的套接字，很有帮助。

Answer 2

对于你的第一个问题：

但我不明白它是如何工作的。 inputLine = input.readLine() 等待直到缓冲读取器中出现某些内容，当某些内容出现在那里时，它返回 true 并执行循环中的代码。但是什么时候可以返回null。

BufferedReader.readLine () 成功时不会返回 true。它返回一个包含已读取行的字符串。如果到达流末尾，则返回null。

您的第二个问题：

上面的代码取自一个抛出异常的方法，我在线程的 run 方法中使用了这段代码。当我尝试在运行之前抛出异常时，编译器会抱怨：重写的方法不会抛出异常。如果没有抛出异常，我还会收到编译器的另一个抱怨：​​未报告的异常。那么，我能做什么呢？

您应该将代码包装在 try/catch 块中。如果您不想处理捕获的异常，只需将该部分留空即可（不推荐）

try {
    while ((inputLine = input.readLine()) != null) {
        System.out.println("I got a message from a client: " + inputLine);
    }
} catch (Exception e) {
    //handle exception
}

Answer 3

当读取器读取到某些内容时，读取器的 readLine() 将返回一个字符串值；当还没有读取任何内容时，将返回一个空字符串；当连接关闭时，将返回 null。

我建议使用 IO 函数在代码块周围包装一个 try/catch 并适当地处理错误。

Answer 4

input reader 连接到套接字，它是一个侦听器，即不断侦听传入的消息。

关于你的第二个问题，你应该在方法中放置一个 try/catch 块，捕获异常并处理它。不要重新扔掉它。

Answer 5

但我不明白它是如何工作的。 ....等待直到有东西出现在
缓冲阅读器，当有东西时
出现在那里它返回 true

否，它返回表达式 (inputLine = input.readLine()) 的值，即 inputLine 本身。 inputLine 与 null 进行比较。

Answer 6

当到达“EOF（文件结束）”时，返回 null。由于这是从网络套接字读取，因此当套接字断开连接（由服务器或客户端）时创建文件结尾，但在实际看到 EOF 之前您可能会收到异常。

Answer 7

如果这不是为了家庭作业，您可能需要查看 Apache Commons IOUtils。

假设您不创建 BufferedReader，只是停在 InputStream 处：

String results = IOUtils.toString(inputStream);
System.out.println(results);

Answer 8

while ((inputLine = input.readLine()) != null) {

查看表达式的每个部分：

input.readLine()

如果已到达流末尾，则返回一个 String，该 String 将为 null（或在错误时抛出异常）。

inputLine = input.readLine()

将此字符串分配给 inputLine

((inputLine = input.readLine()) != null)

检查分配的字符串是否不为 null（流末尾）。

Answer 9

您已经收到了一些很好的答案。只需捕获异常并在本地处理即可。如果您需要将此传递给其他代码，但由于 run() 方法不允许任何检查异常而无法传递，则可以将该异常包装在某种 RuntimeException 中。如果 run 方法直接在线程上执行（因为它可能是 Runnable），那么您应该小心重新抛出包装的异常。

至于readLine()的结果，当没有更多内容可读取时，它将返回null。对于套接字，这是指另一方干净地关闭套接字（任何突然终止或不干净的关闭通常都会导致代码中出现异常，因为操作系统将发送不同类型的套接字关闭通知）。

由于您将套接字包装在 java.io.BufferedReader 中，因此我确实有一句话要小心。在任何类型的生产代码中使用它时都应该非常小心。

危险在于 BufferedReader 不能很好地处理读取过程中的异常。如果您在套接字上启用了超时，则这尤其是一个问题，因此代码将自动从操作系统接收定期异常。当读取器内的缓冲区正在填充时，可能会出现超时（或其他异常）。如果您尝试在异常发生后重用该对象，它将忽略缓冲区中任何先前的内容。先前收到的数据包会默默丢失，并且无法检索这些字节。

请注意，还有其他类型的套接字异常并不意味着套接字已丢失。例如，查看 java.io.InterruptedIOException 的定义。它有一个公共变量，用于报告最近 I/O（读或写）请求中成功传输的字节数。这意味着可以再次执行 IO 操作以检索或发送数据包的剩余字节。

如果出现任何异常，您的设计是立即关闭读取器和套接字，则该方法将正常工作。

从套接字读取数据的正确方法是直接使用套接字流，使用 NIO（ByteBuffer 等），或者使用编写良好的网络库，对这些较低级别的类进行良好的抽象（有几个可用的开源库）。