Socket 上的 BufferedReader.readLine() 是阻塞操作吗？

Question

我正在尝试运行一个示例类，该类使用Observer 接口和Observable 子类来检查来自套接字的输入流何时不同于空字符串。这是代码（Observable 类）：

@Override
public void run() {
    String input;
    while (true) {
        try {
            input = reader.readLine();
            if (input != null) {
                setChanged();
                notifyObservers(input);
            } else
                System.out.println("Nothing read from the stream");
        } catch (IOException e) {
        }
    }
}

因此，当条件input != null 为真时，调用update() 方法并将从套接字读取的内容输出到stdout。服务器每秒发送一个字符串，观察者以最大速度检查它（没有任何sleep() 调用）。那么，BufferedReader.readLine() 在从套接字拥有的流中读取时真正做了什么？因为else 块永远不会被执行。

Answer 1

正如BufferedReader.readLine() 状态

包含行内容的字符串，不包括任何行终止字符，如果已到达流的末尾，则为 null

只有在另一端关闭连接时，你才会得到null。

如果你想实现一个繁忙的等待策略，你可以使用非阻塞 NIO，但要注意这将使用 100% 的 CPU。

Answer 2

您不能在套接字周围创建BufferedReader，因为BufferedReader 只是包装了另一个Reader。 Readers 根本不支持非阻塞 I/O。

在您可以创建BufferedReader 之前，您必须先创建一个Reader：

Channels.newReader(…):

...如果要读取字节时通道处于非阻塞模式，则将抛出IllegalBlockingModeException。

如果你尝试the detour via an InputStream, e.g. acquired by Socket.getInputStream()会发生类似的事情：

如果通道处于非阻塞模式，则输入流的读取操作将抛出IllegalBlockingModeException。

所以你只能在套接字处于阻塞模式时使用BufferedReader.readLine()，这意味着它将等待至少一个字符可以被读取，这与流结束的条件不同。因此，作为Peter Lawrey pointed out，它将继续读取，直到行完成或流到达其末尾，这意味着在阻塞套接字中流已关闭。