在编写一些测试代码时,我发现Selector.select()可以返回而不包含要处理的任何键的Selector.selectedKeys().当我注册一个accept()ed频道时,会发生这种情况
SelectionKey.OP_READ | SelectionKey.OP_CONNECT
作为感兴趣的业务.
根据文档,select()应该在以下时间返回:
1)有可以采取行动的渠道.
2)您明确调用Selector.wakeup() - 未选择任何键.
3)显式Thread.interrupt()执行select()的线程 - 没有选择键.
如果我在select()之后没有键,我必须在case(2)和(3)中.但是,我的代码不是调用wakeup()或interrupt()来启动这些返回.
关于是什么导致这种行为的任何想法?
简短回答:OP_CONNECT
从您感兴趣的操作列表中删除已接受的连接 - 已连接已接受的连接.
我设法重现了这个问题,这可能正是你发生的事情:
import java.net.*; import java.nio.channels.*; public class MyNioServer { public static void main(String[] params) throws Exception { final ServerSocketChannel serverChannel = ServerSocketChannel.open(); serverChannel.configureBlocking(true); serverChannel.socket().bind(new InetSocketAddress("localhost", 12345)); System.out.println("Listening for incoming connections"); final SocketChannel clientChannel = serverChannel.accept(); System.out.println("Accepted connection: " + clientChannel); final Selector selector = Selector.open(); clientChannel.configureBlocking(false); final SelectionKey clientKey = clientChannel.register(selector, SelectionKey.OP_READ | SelectionKey.OP_CONNECT); System.out.println("Selecting..."); System.out.println(selector.select()); System.out.println(selector.selectedKeys().size()); System.out.println(clientKey.readyOps()); } }
在上述服务器收到连接之后,连接select()
上的第一个服务器在没有阻塞的情况下退出,并且没有准备好操作的密钥.我不知道为什么Java会以这种方式表现,但似乎很多人都被这种行为所困扰.
Windows XP上Sun的JVM 1.5.0_06以及Linux 2.6上的Sun的JVM 1.5.0_05和1.4.2_04的结果是相同的.
原因是,OP_CONNECT
并且OP_WRITE
在引擎盖下是相同的东西,所以你永远不应该同时注册(同上OP_ACCEPT
和OP_READ
),并且OP_CONNECT
当频道已经连接时你根本不应该注册,因为在这种情况下,被接受了.
并且OP_WRITE
几乎总是准备就绪,除非e内核中的套接字发送缓冲区已满,所以你只应在获得零长度写入后注册它.因此,通过注册已连接的通道,OP_CONNECT,
您实际上正在注册OP_WRITE,
已准备就绪,因此select()
被触发.