Tomcat的Http11NioProtocol协议使用Java NIO技术实现高性能Web服务器。本文通过分析Http11NioProtocol源码来学习Java NIO的使用。从中可以了解到阻塞IO和非阻塞IO的配合，NIO的读写操作以及Selector.wakeup的使用。
1. 初始化阶段
Java NIO服务器端实现的第一步是开启一个新的ServerSocketChannel对象。Http11NioProtocol的实现也不例外, 在NioEndPoint类的init方法可以看到这段代码。
代码1：NioEndPoint.init()方法
public void init()
throws Exception {
if (initialized )
return;
//开启一个新的ServerSocketChannel
serverSock = ServerSocketChannel.open();
//设置socket的性能偏好
serverSock.socket().setPerformancePreferences(socketProperties .getPerformanceConnectionTime(),
socketProperties.getPerformanceLatency(),
socketProperties.getPerformanceBandwidth());
InetSocketAddress addr = ( address!=null ?new InetSocketAddress(address ,port ):new InetSocketAddress(port));
//绑定端口号，并设置backlog
serverSock.socket().bind(addr,backlog );
//将serverSock设置成阻塞IO
serverSock.configureBlocking(true); //mimic APR behavior
//初始化acceptor线程数
if (acceptorThreadCount == 0) {
// FIXME: Doesn't seem to work that well with multiple accept threads
acceptorThreadCount = 1;
}
//初始化poller线程数
if (pollerThreadCount <= 0) {
//minimum one poller thread
pollerThreadCount = 1;
}
// 根据需要，初始化SSL
// 因为主要关注Java NIO, 所以这一块代码就省略掉了
if (isSSLEnabled()) {
......
}
//OutOfMemoryError策略
if (oomParachute >0) reclaimParachute(true);
//开启NioSelectorPool
selectorPool.open();
initialized = true ;
}
在NioEndPoint.init方法中，可以看到ServerSocketChannel被设置成阻塞IO，并且没有注册任何就绪事件。这样可以和阻塞ServerSocket一样方便地使用阻塞accept方法来接收客户端新来的连接。但不同的是当NioEndPoint.Accept线程通过accept方法获得一个新的SocketChannel后会构建一个OP_REGISTER类型的PollerEvent事件并放到Poller.events队列中。而我们使用ServerSocket实现服务器的时候，在接收到新连接后，一般是从线程池中取出一个线程来处理这个连接。
在NioEndPoint.Accept的setSocketOptions方法中可以看到获得SocketChannel后的处理过程。步骤如下：
1）将SocketChannel设置成非阻塞；
2）构建OP_REGISTER类型的PollerEvent对象，并放入到Poller.events队列中。
代码2：NioEndPoint.Accept类的setSocketOptions方法
protected boolean setSocketOptions(SocketChannel socket) {
try {
//将客户端Socket设置为非阻塞， APR风格
socket.configureBlocking( false);
Socket sock = socket.socket();
socketProperties.setProperties(sock);
//从缓存中取NioChannel对象，如果取不到直接构建一个
NioChannel channel = nioChannels.poll();
if ( channel == null ) {
// 如果sslContext不等于null, 需要启动ssl
if (sslContext != null) {
....
}
//正常tcp启动
else {
//构建NioBufferHandler对象
NioBufferHandler bufhandler = new NioBufferHandler(socketProperties .getAppReadBufSize(),
socketProperties.getAppWriteBufSize(),
socketProperties.getDirectBuffer());
//构建NioChannel对象
channel = new NioChannel(socket, bufhandler);
}
} else {
//从缓存中取的NioChannel对象，将客户端socket设置进去
channel.setIOChannel(socket);
if ( channel instanceof SecureNioChannel ) {
SSLEngine engine = createSSLEngine();
((SecureNioChannel)channel).reset(engine);
} else {
channel.reset();
}
}
//注册NioChannel对象
getPoller0().register(channel);
} catch (Throwable t) {
try {
log.error("" ,t);
} catch ( Throwable tt){}
// Tell to close the socket
return false ;
}
return true ;
}