上一偏文章写tomcat的启动初始化，包含tomcat的init，load，start的三个核心部分，讲了tomcat的配置文件解析，工作线程创建，还有最最重要的一部分就是tomcat接受客户端请求的NIO网络模型
Tomcat nio网络模型的初始化配置，主要完成nio socket的参数配置
以及nio selector线程的创建等，初始化如下也是在tomcat的init模块完成的。
代码主要是StandardService的initInternal()方法是入口，
synchronized (connectorsLock) {
for (Connector connector : connectors) {
connector.init();
}
}
tomat server.xml里面每个<Connector > 对应一个connector，
connector.init 方法主要是
try {
protocolHandler.init();
} catch (Exception e) {
throw new LifecycleException(
sm.getString("coyoteConnector.protocolHandlerInitializationFailed"), e);
}
protocolHandler默认是http/1.1对应实现类org.apache.coyote.http11.Http11NioProtocol，protocolHandler是通过
Http11NioProtocol的构造函数创建的，代码如下：
public Http11NioProtocol() {
super(new NioEndpoint());
}
Http11NioProtocol 有个endpoint，这个endpoint是创建nio的核心，我们等下就会分析，先看下tomcat的一下tcp层面的默认参数
Http11NioProtocol继承AbstractProtocol，他的构造函数如下：
public AbstractProtocol(AbstractEndpoint<S,?> endpoint) {
this.endpoint = endpoint
setConnectionLinger(Constants.DEFAULT_CONNECTION_LINGER);
setTcpNoDelay(Constants.DEFAULT_TCP_NO_DELAY);
}
这里我们看到两个tcp层面的参数，分别是Linger和tcpNoDelay，Linger默认是：
public static final int DEFAULT_CONNECTION_LINGER = -1;
public void setConnectionLinger(int connectionLinger) {
socketProperties.setSoLingerTime(connectionLinger);
socketProperties.setSoLingerOn(connectionLinger>=0);
}
LINGER设置为-1时，LingerOn是false，即0，这等于内核缺省情况，close调用会立即返回给调用者，如果可能将会传输任何未发送的数据；
TcpNoDelay 的默认值是：
public static final boolean DEFAULT_TCP_NO_DELAY = true;
即关掉tcp禁止小包发送的算法，可以发送小包
看完了tomcat的再创建Http11NioProtocol时设置的网络层默认的参数后，我们下面就看怎么创建nio 的，即上面的protocolHandler.init()实现。
protocolHandler.init()的主要是执行上面说的endPoint的init方法，大戏就是从NioEndpoint的init方法开始的。
public final void init() throws Exception {
if (bindOnInit) {
bindWithCleanup();
bindState = BindState.BOUND_ON_INIT;
}
if (this.domain != null) {
// Register endpoint (as ThreadPool - historical name)
oname = new ObjectName(domain + ":type=ThreadPool,name=\"" + getName() + "\"");
Registry.getRegistry(null, null).registerComponent(this, oname, null);
ObjectName socketPropertiesOname = new ObjectName(domain +
":type=ThreadPool,name=\"" + getName() + "\",subType=SocketProperties");
socketProperties.setObjectName(socketPropertiesOname);
Registry.getRegistry(null, null).registerComponent(socketProperties, socketPropertiesOname, null);
for (SSLHostConfig sslHostConfig : findSslHostConfigs()) {
registerJmx(sslHostConfig);
}
}
}
bindWithCleanup 主要是执行bind方法
public void bind() throws Exception {
//创建server socket，即bind操作，同时设定了backlog，并标记为阻塞模式，这个阻塞是对accept操作的。
initServerSocket();
setStopLatch(new CountDownLatch(1));
// Initialize SSL if needed
initialiseSsl();
//创建selector，但这里的selector不是接受请求的selector
selectorPool.open(getName());
}
NioEndpoint的init方法就完了，tomcat在start阶段时，会执行connector.start()方法，start最终也是执行NioEndpoint的startInternal方法
public void startInternal() throws Exception {
if (!running) {
running = true;
paused = false;
//tomcat对频繁用的对象做了缓存重用，缓存大小默认时128
if (socketProperties.getProcessorCache() != 0) {
//processorCache 是tomcat的puller线程会为每个请求创建一个SocketProcessor，缓存里有就不用创建新的
processorCache = new SynchronizedStack<>(SynchronizedStack.DEFAULT_SIZE,
socketProperties.getProcessorCache());
}
if (socketProperties.getEventCache() != 0) {
//一个新的请求进来都会一个PollerEvent，通过这个event来注册到poller的selector线程上，eventCache用来缓存PollerEvent
eventCache = new SynchronizedStack<>(SynchronizedStack.DEFAULT_SIZE,
socketProperties.getEventCache());
}
if (socketProperties.getBufferPool() != 0) {
////一个新的请求进来，都会从nioChannels里看又没有可以复用的NioChannel，没有就新创建一个NioChannel。
nioChannels = new SynchronizedStack<>(SynchronizedStack.DEFAULT_SIZE,
socketProperties.getBufferPool());
}
// Create worker collection
//这里是重新检查下，已经在init阶段初始化完成了。
if (getExecutor() == null) {
createExecutor();
}
//tomcat对最大链接数有个限制，默认是10000，超过了就不接受，由maxConnections参数指定，-1是没有限制
initializeConnectionLatch();
// Start poller thread
poller = new Poller();
Thread pollerThread = new Thread(poller, getName() + "-ClientPoller");
pollerThread.setPriority(threadPriority);
pollerThread.setDaemon(true);
pollerThread.start();
//创建acceptor线程，负责接收链接
startAcceptorThread();
}
}
Puller 线程
Poller是对jdk nioselector的一个封装，核心是selector，
public Poller() throws IOException {
this.selector = Selector.open();
}
tomcat10对poller线程做了修改，之前是两个，现在是一个poller线程，主要是干两件事情：
- 负责把新来的请求注册到selector上。
- 处理链接上的读写事件，通过创建一个SocketProcessor，交给tomcat work线程去处理，poller线程本身并不做io操作
这也是tomcat只留了一个poller线程来处理读写事件，但是大量链接的场景，就不能利用多core
上面我们看到tomcat用了三个对象池技术，因为这三个是频繁使用的，而且都是puller线程用的，进一步优化来puller线程的性能。
Acceptor 线程
Acceptor 线程是阻塞的，代码如下：
try {
//if we have reached max connections, wait
//检查是否达到了链接数限制，达到了则要等其他链接释放
endpoint.countUpOrAwaitConnection();
//去accept已经建立链接的请求
}
countUpOrAwaitConnection 代码如下：
protected void countUpOrAwaitConnection() throws InterruptedException {
if (maxConnections==-1) return;
LimitLatch latch = connectionLimitLatch;
if (latch!=null) latch.countUpOrAwait();
}
如果是maxConnections是-1，则不会等其他链接释放，如果不是，则看链接数是否达到了限制，如果达到则要阻塞在这里。
tomcat的初始化nio 线程就算是写完了，想要知道nio是怎么把请求交给catalina work线程的，请看我的 [NIO 线程模型分析的文章]https://www.jianshu.com/p/4e239e217ada
网友评论