nio框架中的多个Selector结构

核心提示：随着并发数量的提高，传统nio框架采用一个Selector来支撑大量连接事件的管理和触发已经遇到瓶颈，nio框架中的多个Selector结构，因此现在各种nio框架的新版本都采用多个 Selector并存的结构，由多个Selector均衡地去管理大量连接，Selector的管理是由org.apache.mina.tra

随着并发数量的提高，传统nio框架采用一个Selector来支撑大量连接事件的管理和触发已经遇到瓶颈，因此现在各种nio框架的新版本都采用多个 Selector并存的结构，由多个Selector均衡地去管理大量连接。这里以Mina和Grizzly的实现为例。

在Mina 2.0中，Selector的管理是由org.apache.mina.transport.socket.nio.NioProcessor来处理，每个NioProcessor对象保存一个Selector，负责具体的select、wakeup、channel的注册和取消、读写事件的注册和判断、实际的IO读写操作等等，核心代码如下：

　　　public　NioProcessor(Executor　executor)　{
　　　　　　　　super(executor);
　　　　　　　　try　{
　　　　　　　　　　　　//　Open　a　new　selector
　　　　　　　　　　　　selector　=　Selector.open();
　　　　　　　　}　catch　(IOException　e)　{
　　　　　　　　　　　　throw　new　RuntimeIoException("Failed　to　open　a　selector.",　e);
　　　　　　　　}
　　　　}

　　　　protected　int　select(long　timeout)　throws　Exception　{
　　　　　　　　return　selector.select(timeout);
　　　　}
　　
　　　　protected　boolean　isInterestedInRead(NioSession　session)　{
　　　　　　　　SelectionKey　key　=　session.getSelectionKey();
　　　　　　　　return　key.isValid()　&&　(key.interestOps()　&　SelectionKey.OP_READ)　!=　0;
　　　　}

　　　　protected　boolean　isInterestedInWrite(NioSession　session)　{
　　　　　　　　SelectionKey　key　=　session.getSelectionKey();
　　　　　　　　return　key.isValid()　&&　(key.interestOps()　&　SelectionKey.OP_WRITE)　!=　0;
　　　　}
　　　　protected　int　read(NioSession　session,　IoBuffer　buf)　throws　Exception　{
　　　　　　　　return　session.getChannel().read(buf.buf());
　　　　}

　　　　protected　int　write(NioSession　session,　IoBuffer　buf,　int　length)　throws　Exception　{
　　　　　　　　if　(buf.remaining()　<=　length)　{
　　　　　　　　　　　　return　session.getChannel().write(buf.buf());
　　　　　　　　}　else　{
　　　　　　　　　　　　int　oldLimit　=　buf.limit();
　　　　　　　　　　　　buf.limit(buf.position()　+　length);
　　　　　　　　　　　　try　{
　　　　　　　　　　　　　　　　return　session.getChannel().write(buf.buf());
　　　　　　　　　　　　}　finally　{
　　　　　　　　　　　　　　　　buf.limit(oldLimit);
　　　　　　　　　　　　}
　　　　　　　　}
　　　　}