Tomcat源码之NioEndpoint

q6542125

NIO，非堵塞IO，通常适用于I/O读写等方面，一般来讲，系统运行的性能瓶颈通常在I/O读写，包括对端口和文件的操作上，过去，在打开一个I/O通道后，read()将一直等待在端口一边读取字节内容，如果没有内容进来，read()就会一直等下去，这会影响程序继续做其他事情，那么改进做法就是开设线程，让线程去等待，但是这样做也是相当耗费资源的。
NIO非堵塞技术实际是采取Reactor模式，或者说是Observer模式为我们监察I/O端口，如果有内容进来，会自动通知我们，这样，我们就不必开启多个线程死等，从外界看，实现了流畅的I/O读写，不堵塞了。

NioEndpoint就是使用Java中的NIO技术，来实行对Socket的处理。它主要包含两个部业务处理部分：Poller线程组和Acceptor线程组。

Acceptor
实现Runnable接口，在ServerSocketChannel侦听事件，将NioChannel交给Poller去处理。

protected ServerSocketChannel serverSock = null;
.....
                        socket = serverSock.accept();
.....
getPoller0().register(channel);

Poller
实现Runnable接口，不断的轮询selector，最近将socket交给handler处理。

初始化和启动
在bind()中完成对socket/SSL(如果要支持的话)等资源的初始化。
        serverSock = ServerSocketChannel.open();
        socketProperties.setProperties(serverSock.socket());
        InetSocketAddress addr = (getAddress()!=null?new InetSocketAddress(getAddress(),getPort()):new InetSocketAddress(getPort()));
        serverSock.socket().bind(addr,getBacklog());
        serverSock.configureBlocking(true); //mimic APR behavior
        serverSock.socket().setSoTimeout(getSocketProperties().getSoTimeout());
......
if (isSSLEnabled()) {
..........
        }

在startInternal(),启动Poller线程组, Comet Poller线程组(两个都是Poller类),Sendfile线程组,Acceptor线程组和1个运行AsyncTimeout接口的线程组.
// Start poller threads
     pollers = new Poller[getPollerThreadCount()];
     for (int i=0; i<pollers.length; i++) {
           pollers = new Poller();
           Thread pollerThread = new Thread(pollers, getName() + "-ClientPoller-"+i);
           pollerThread.setPriority(threadPriority);
           pollerThread.setDaemon(true);
           pollerThread.start();
     }
// Start acceptor threads
      for (int i = 0; i < acceptorThreadCount; i++) {
           Thread acceptorThread = new Thread(new Acceptor(), getName() + "-Acceptor-" + i);
           acceptorThread.setPriority(threadPriority);
           acceptorThread.setDaemon(getDaemon());
           acceptorThread.start();
      }