Java/Groovy Socket - 以非阻塞方式检测正在关闭的套接字

Question

我正在尝试创建一个小型 HTTP 代理，它可以根据需要重写请求/ header 以满足我的要求。如果已经存在，请指出它。否则...

我已经写了一些几乎可以工作的东西。它可以执行代理功能，但还不能执行重写。问题是，如果不进行阻塞读取，我无法检测远程套接字何时关闭。对于这个东西的功能来说至关重要的是它能够检测到套接字正在关闭而不会阻塞。我已经浏览了 Java API 文档，但我找不到任何迹象表明这是可能的。这是我所拥有的:

    while ( this.inbound.isConnected() && this.outbound.isConnected() ) { 

      try {
        while ( ( available = readFromClient.available() ) != 0 ) { 
          if ( available > 1024 ) available = 1024
          bytesRead = readFromClient.read( buffer, 0, available )
          writeToServer.write( buffer, 0, bytesRead )
        }   

        while ( ( available = readFromServer.available() ) != 0 ) { 
          if ( available > 1024 ) available = 1024
          bytesRead = readFromServer.read( buffer, 0, available )
          writeToClient.write( buffer, 0, bytesRead )
        }                                                                                       
      } catch (e) { 
        print e
      }   

      println "Connected:      " + this.inbound.isConnected() 
      println "Bound:          " + this.inbound.isBound() 
      println "InputShutdown:  " + this.inbound.isInputShutdown() 
      println "OutputShutdown: " + this.inbound.isOutputShutdown() 
      print "\n";

      Thread.sleep( 10 )

    }   

对正在关闭的套接字的测试从未表明套接字已关闭。而且，正如我所提到的，我找不到任何有关如何在不执行阻塞读取的情况下检测流上的“文件结束”条件的示例。

一定有办法。这里有人知道这是什么吗？

Answer 1

我假设您正在使用 java.net.Socket 进行 I/O。为了在 Java 中进行非阻塞 I/O，您必须使用 NIO 包。

特别是，您需要使用 java.nio.channels.SocketChannel 进行通信。在 channel 上调用 configureBlocking(false)，然后 read() 将返回读取的数据量，-1 表示关闭，如果没有可用数据则返回 0。在某些错误情况下也可能引发异常。

这是一个example使用 SocketChannel 显示非阻塞 I/O。