很多東西在時序圖中體現(xiàn)的已經(jīng)非常清楚了，沒有必要再一步一步的作介紹，本文以圖為主，然后對部分內(nèi)容加以簡單解釋。

創(chuàng)新互聯(lián)堅持“要么做到，要么別承諾”的工作理念，服務領域包括：成都網(wǎng)站建設、成都網(wǎng)站制作、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣等服務，滿足客戶于互聯(lián)網(wǎng)時代的三原網(wǎng)站設計、移動媒體設計的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡建設合作伙伴！

• 繪制圖形使用的工具是 PlantUML + Visual Studio Code + PlantUML Extension

本文對 Tomcat 的介紹以 Tomcat-9.0.0.M22 為標準。

Tomcat-9.0.0.M22 是 Tomcat 目前最新的版本，但尚未發(fā)布，它實現(xiàn)了 Servlet4.0 及 JSP2.3 并提供了很多新特性，需要 1.8 及以上的 JDK 支持等等，詳情請查閱 Tomcat-9.0-doc

• Overview

• Connector Init and Start

• Requtst Process

• Acceptor

• Poller

• Worker

• Container

• At last

Overview

1. Connector 啟動以后會啟動一組線程用于不同階段的請求處理過程。

2. Acceptor 線程組。用于接受新連接，并將新連接封裝一下，選擇一個 Poller 將新連接添加到 Poller 的事件隊列中。

3. Poller 線程組。用于監(jiān)聽 Socket 事件，當 Socket 可讀或可寫等等時，將 Socket 封裝一下添加到 worker 線程池的任務隊列中。

4. worker 線程組。用于對請求進行處理，包括分析請求報文并創(chuàng)建 Request 對象，調(diào)用容器的 pipeline 進行處理。

• Acceptor、 Poller、 worker 所在的 ThreadPoolExecutor 都維護在 NioEndpoint 中。

Connector Init and Start

1. initServerSocket()，通過 ServerSocketChannel.open() 打開一個 ServerSocket，默認綁定到 8080 端口，默認的連接等待隊列長度是 100， 當超過 100 個時會拒絕服務。我們可以通過配置 conf/server.xml 中 Connector 的 acceptCount 屬性對其進行定制。

2. createExecutor() 用于創(chuàng)建 Worker 線程池。默認會啟動 10 個 Worker 線程，Tomcat 處理請求過程中，Woker 最多不超過 200 個。我們可以通過配置 conf/server.xml 中 Connector 的 minSpareThreads 和 maxThreads 對這兩個屬性進行定制。

3. Pollor 用于檢測已就緒的 Socket。 默認最多不超過 2 個， Math.min(2,Runtime.getRuntime().availableProcessors());。我們可以通過配置 pollerThreadCount 來定制。

4. Acceptor 用于接受新連接。默認是 1 個。我們可以通過配置 acceptorThreadCount 對其進行定制。

Requtst Process

Acceptor

1. Acceptor 在啟動后會阻塞在 ServerSocketChannel.accept(); 方法處，當有新連接到達時，該方法返回一個 SocketChannel。

2. 配置完 Socket 以后將 Socket 封裝到 NioChannel 中，并注冊到 Poller, 值的一提的是，我們一開始就啟動了多個 Poller 線程，注冊的時候，連接是公平的分配到每個 Poller 的。 NioEndpoint 維護了一個 Poller 數(shù)組，當一個連接分配給 pollers[index] 時，下一個連接就會分配給 pollers[(index+1)%pollers.length].

3. addEvent() 方法會將 Socket 添加到該 Poller 的 PollerEvent 隊列中。到此 Acceptor 的任務就完成了。

Poller

1. selector.select(1000)。當 Poller 啟動后因為 selector 中并沒有已注冊的 Channel，所以當執(zhí)行到該方法時只能阻塞。所有的 Poller 共用一個 Selector，其實現(xiàn)類是 sun.nio.ch.EPollSelectorImpl

2. events() 方法會將通過 addEvent() 方法添加到事件隊列中的 Socket 注冊到 EPollSelectorImpl，當 Socket 可讀時， Poller 才對其進行處理

3. createSocketProcessor() 方法將 Socket 封裝到 SocketProcessor 中， SocketProcessor 實現(xiàn)了 Runnable 接口。 worker 線程通過調(diào)用其 run() 方法來對 Socket 進行處理。

4. execute(SocketProcessor) 方法將 SocketProcessor 提交到線程池，放入線程池的 workQueue 中。 workQueue 是 BlockingQueue 的實例。到此 Poller 的任務就完成了。

Worker

1. worker 線程被創(chuàng)建以后就執(zhí)行 ThreadPoolExecutor 的 runWorker() 方法，試圖從 workQueue 中取待處理任務，但是一開始 workQueue 是空的，所以 worker 線程會阻塞在 workQueue.take() 方法。

2. 當新任務添加到 workQueue后， workQueue.take() 方法會返回一個 Runnable，通常是 SocketProcessor, 然后 worker 線程調(diào)用 SocketProcessor 的 run() 方法對 Socket 進行處理。

3. createProcessor() 會創(chuàng)建一個 Http11Processor, 它用來解析 Socket，將 Socket 中的內(nèi)容封裝到 Request 中。注意這個 Request 是臨時使用的一個類，它的全類名是 org.apache.coyote.Request，

4. postParseRequest() 方法封裝一下 Request，并處理一下映射關(guān)系 (從 URL 映射到相應的 Host、 Context、 Wrapper)。

5. CoyoteAdapter 將 Rquest 提交給 Container 處理之前，并將 org.apache.coyote.Request 封裝到 org.apache.catalina.connector.Request，傳遞給 Container 處理的 Request 是 org.apache.catalina.connector.Request。

6. connector.getService().getMapper().map()，用來在 Mapper 中查詢 URL 的映射關(guān)系。映射關(guān)系會保留到 org.apache.catalina.connector.Request 中， Container 處理階段 request.getHost() 是使用的就是這個階段查詢到的映射主機，以此類推 request.getContext()、 request.getWrapper() 都是。

7. connector.getService().getContainer().getPipeline().getFirst().invoke() 會將請求傳遞到 Container 處理，當然了 Container 處理也是在 Worker 線程中執(zhí)行的，但是這是一個相對獨立的模塊，所以單獨分出來一節(jié)。

Container

1. 需要注意的是，基本上每一個容器的 StandardPipeline 上都會有多個已注冊的 Valve，我們只關(guān)注每個容器的 Basic Valve。其他 Valve 都是在 Basic Valve 前執(zhí)行。

2. request.getHost().getPipeline().getFirst().invoke() 先獲取對應的 StandardHost，并執(zhí)行其 pipeline。

3. request.getContext().getPipeline().getFirst().invoke() 先獲取對應的 StandardContext, 并執(zhí)行其 pipeline。

4. request.getWrapper().getPipeline().getFirst().invoke() 先獲取對應的 StandardWrapper，并執(zhí)行其 pipeline。

5. 最值得說的就是 StandardWrapper 的 Basic Valve， StandardWrapperValve

6. allocate() 用來加載并初始化 Servlet，值的一提的是 Servlet 并不都是單例的，當 Servlet 實現(xiàn)了 SingleThreadModel 接口后， StandardWrapper 會維護一組 Servlet 實例，這是享元模式。當然了 SingleThreadModel 在 Servlet 2.4 以后就棄用了。

7. createFilterChain() 方法會從 StandardContext 中獲取到所有的過濾器，然后將匹配 Request URL 的所有過濾器挑選出來添加到 filterChain 中。

8. doFilter() 執(zhí)行過濾鏈, 當所有的過濾器都執(zhí)行完畢后調(diào)用 Servlet 的 service() 方法

9. 歡迎工作一到五年的Java工程師朋友們加入我的個人粉絲群（Java填坑之路：789337293）群內(nèi)提供免費的Java架構(gòu)學習資料（里面有高可用、高并發(fā)、高性能及分布式、Jvm性能調(diào)優(yōu)、Spring源碼，MyBatis，Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多個知識點的架構(gòu)資料）

10. 合理利用自己每一分每一秒的時間來學習提升自己，不要再用"沒有時間“來掩飾自己思想上的懶惰！趁年輕，使勁拼，給未來的自己一個交代！

創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(yè)提供香港、美國云服務器，動態(tài)BGP最優(yōu)骨干路由自動選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡助力業(yè)務部署。公司持有工信部辦法的idc、isp許可證， 機房獨有T級流量清洗系統(tǒng)配攻擊溯源，準確進行流量調(diào)度，確保服務器高可用性。佳節(jié)活動現(xiàn)已開啟，新人活動云服務器買多久送多久。

分享名稱：6張時序圖，談談Tomcat請求處理流程-創(chuàng)新互聯(lián)
本文路徑：http://weahome.cn/article/ddjdjd.html