一、组件详解

在Tomcat处理客户端请求的过程中，这里面有三个组件概念，他们都是线程，分别负责不同的职责。
（必须记清楚这三个线程组件）

Acceptor

一个普通线程任务，用于接收新连接，并将新连接封装，选择一个 Poller 将新连接添加到 Poller 的事件队列中。
Poller

一个线程任务，用于监听 Socket 事件，当有任务来临时，将 Socket 封装，添加到 worker 线程池的任务队列中。
Worker

他是创建一组线程的，每个线程任务都是一个阻塞队列，用于对请求进行处理（例如我们中间件参数中的最大线程数就是指最多创建多少个Worker线程）。每个Worker线程任务包括分析解析请求报文、创建 Request 对象、调用容器的管道pipeline 执行阀门value、执行servlet的具体逻辑。

二、请求处理流程

1.总体流程图

在这里插入图片描述

2.Worker线程任务流程

在这里插入图片描述

三、源码跟踪

1.Tomcat启动线程组件

Tomcat启动时，如果默认使用NIO模式，先是执行了AbstractEndpoint.initServerSocket，通过 ServerSocketChannel.open() 打开一个 ServerSocket通道，默认绑定到 8080 端口，用于监听请求。

说明：在Java语言的NIO中，类ServerSocketChannel就是用来处理TPC连接的客户端，他的open方法就是用例建立一个TPC连接。

在这里插入图片描述

然后Tomcat会创建Worker 线程池、Acceptor线程、Poller线程：

AbstractEndpoint.createExecutor，用于创建 Worker 线程池，这个线程池是用来处理实际的请求的，把配置文件中的初始线程数10、最大线程数200等信息传进去，创建一个线程池executor

在这里插入图片描述

AbstractEndpoint.createExecutor.startAcceptorThread，他创建一个线程任务Acceptor，作为一个接收者，线程用来无限循环接受客户端发送过来的连接请求

在这里插入图片描述

NioEndpoint.startInternal，创建一个线程任务Poller，用于检测Acceptor接兽并处理成已就绪的 Socket。

在这里插入图片描述

2.Acceptor

Tomcat启动完成后，客户端发起一个请求

Acceptor的run方法，无限循环在这里接受连接请求
（假如启动后客户端发起一个请求，这里就是第一时间捕获到）

在这里插入图片描述
点进去NioEndpoint.serverSocketAccept（因为使用NIO模式），可以看到我们熟悉的nio的accept方法，这是一个阻塞的方法，会一直等待接收请求。

在这里插入图片描述

当Acceptor接收到客户端的请求时，调用addEvent() 方法会将 Socket 添加到该 Poller 的 PollerEvent 队列中。并调用了NIO中selector.wakeup方法，唤醒了Poller。到此，这一次请求中 Acceptor 的任务就完成了。

在这里插入图片描述

3.Poller

接着到Poller 线程了，Poller 线程1秒阻塞一次，等待有请求过来被唤醒后，每次请求先过AbstractEndpoint.processSocket

从处理器缓存中获取当前要被执行的任务，放进任务进程，然后获取Worker线程组，将这个任务放进去。到此 Poller 的任务就完成了。

在这里插入图片描述

4.Worker

然后就是到Worker线程组了，这次请求的后续的所有操作都在这个线程中完成。Worker线程是一个阻塞队列，它继承自AbstractQueuedSynchronizer。worker 线程被创建以后就执行 ThreadPoolExecutor 的 runWorker() 方法，试图从 workQueue 中取待处理任务，但是一开始 workQueue 是空的，所以 worker 线程会阻塞在 workQueue.take() 方法。

在这里插入图片描述
当新任务添加到 workQueue后，workQueue.take() 阻塞就会结束，会返回一个 Runnable，通常是 SocketWrapperBase,然后 worker 线程调用 SocketWrapperBase的 run() 方法对 Socket 进行处理。