2010-06-10 55 views
1

我试图创建一个小的HTTP代理,可以根据需要重新编写请求/标头以适应我的要求。如果已经存在,请将它指向我。否则...Java/Groovy Socket - 检测以非阻塞方式关闭的套接字

我写了一些东西,几乎工作。它可以做代理功能,但不能重写(还)。问题是,我无法检测到远程套接字何时未被阻塞读取而关闭。对于这个东西的功能来说它是关键的,它能够检测到没有阻塞的插座被关闭。我已经清理了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) 

    } 

关闭套接字的测试永远不会指出套接字已关闭。而且,正如我所提到的,我无法找到任何有关如何在不进行阻止读取的情况下检测到流中“END OF FILE”条件的示例。

还有一种方法。这里有人知道它是什么吗?

回答

2

我假设你正在为你的I/O使用java.net.Socket。为了在Java中执行非阻塞I/O,您必须使用NIO软件包。

尤其是,您需要使用java.nio.channels.SocketChannel进行通信。在通道上调用configureBlocking(false),则read()将返回读取的数据量,关闭时为-1,如果没有可用数据,则返回零。在某些错误情况下也会引发异常。

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

0

不,这没有帮助。你甚至可以知道如果连接在另一端关闭,你应该读取它,而java nio选择器在这种情况发生时不会将通道置于就绪状态?

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

+1

同意!我现在正面临着这个问题 - 如果另一方死亡,我不会收到读取事件,甚至写入套接字也不会报错。多么痛苦...... – trojanfoe 2011-02-08 11:15:39