文章詳情頁

Tomcat處理請求的流程

瀏覽：229日期：2023-09-08 20:45:27

目錄一、組件詳解二、請求處理流程1.總體流程圖2.Worker線程任務流程三、源碼跟蹤1.Tomcat啟動線程組件2.Acceptor3.Poller4.Worker總結一、組件詳解

在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() 方法。