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

Question

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

我已经写了一些几乎有效的东西。它可以执行代理功能，但还不能执行重写。问题是，如果不进行阻塞读取，我无法检测远程套接字何时关闭。对于这个东西的功能来说至关重要的是它能够检测到套接字正在关闭而不会阻塞。我已经浏览了 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 进行通信。在通道上调用 configureBlocking(false)，然后 read() 将返回读取的数据量，-1 表示关闭，如果没有可用数据则返回 0。在某些错误情况下也可能引发异常。

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

Answer 2

不，这没有帮助。如果连接在另一端关闭，并且 java nio 选择器在发生这种情况时没有将通道放入就绪集中，您怎么知道您应该读取呢？

据我所知，它只是被设计破坏了，而且没有办法做到这一点。如果我错了，请有人纠正我...