Bootstrap.main()->Bootstrap.init()

bootstrap.init() 方法中設(shè)置catalinaDaemon

創(chuàng)建 Connector 對象

Bootstrap.main()->Bootstrap.start()->Catalina.start()->Catalina.load()->Catalina.createStartDigester()

createStartDigester() 方法

1. 創(chuàng)建connector對象，并判斷server.xml 中是否配置線程池，如果配置線程池則創(chuàng)建線程池

為connector對象設(shè)置除executor外的其它屬性信息

把當(dāng)前connector添加到StandardService.connectors 數(shù)組中。

Connector

構(gòu)造

通過protocol協(xié)議來判斷使用那個protocolHandler。

setProtocol 方法

tomcat 默認配置 是以BIO的模式啟動的，默認會調(diào)用org.apache.coyote.http11.Http11Protocol。
下面我們以Http11Protocol來分析Connector。

startInternal() 方法

1. 設(shè)置tomcat狀態(tài)為，正在啟動
2. 啟動 connector。

Http11Protocol

在構(gòu)造方法中創(chuàng)建JIoEndpoint和Http11ConnectionHandler對象

設(shè)置 socket 參數(shù)

AbstractEndpoint.start() 方法

public class JIoEndpoint extends AbstractEndpoint

JIoEndpoint 繼承 AbstractEndpoint

JIoEndpoint .bind() 方法

在這創(chuàng)建connector的socket服務(wù)，使用serverSocket監(jiān)聽入站連接。

JIoEndpoint.startInternal() 方法

1. 判斷線程池是否為空，如果為空則創(chuàng)建默認的線程池。（server.xml的connector中配置的線程池）
2. 根據(jù)server.xml中的connector中的acceptorThreadCount屬性來確定創(chuàng)建幾個接受請求處理的線程。
Acceptor類，負責(zé)處理接受客戶端請求的處理。

server.xml 中配置如下：

acceptorThreadCount 個數(shù)建議和CPU的個數(shù)一致。

createExecutor() 方法

默認創(chuàng)建的線程池，最小線程數(shù)為10，最大線程數(shù)為200，空閑時間為60秒，隊列為LinkedBlockingQueue，隊列大小默認為Ineteger.MAX_VALUE。

這里需要注意的是，如果隊列中的元素沒有存滿，那么線程的數(shù)量一直會是10，而不會自動擴大到200。所以建議大家自己設(shè)置一個線程池，而不要用默認的

Acceptor 類

Acceptor.run() 方法

獲取之前創(chuàng)建的serverSocket。
2.設(shè)置socket的參數(shù)

調(diào)用processSocket 處理請求的socket

processSocket() 方法

把socket封裝成SocketWrapper對象 傳給SocketProcessor對象，并提交給線程池處理。

SocketProcessor

負責(zé)解析http協(xié)議信息。
SOcketProcessor重要屬性

inputBuffer：包裝socket的inputStream，并解析http協(xié)議信息。
outputBuffer：包裝socket的outputStream，負責(zé)響應(yīng)用戶的數(shù)據(jù)。

run() 方法

在process方法中處理解析http協(xié)議信息。

Http11Processor.process() 方法

Http11Protocol.process()->Http11Processor.process() 代碼如下：

獲取socket的輸入流和輸出流

Http11Processor構(gòu)造方法

在這里，構(gòu)造Request和Response對象。

解析http協(xié)議

解析完后的數(shù)據(jù)存儲到 AbstractInputBuffer的下面兩個屬性中

protected Request request;protected MimeHeaders headers;

request對象就是 HttpServletRequest 對象的原型。

解析完之后，調(diào)用下面的service方法。

這里的service方法會調(diào)用servlet中的service方法并傳入request和response對象，然后根據(jù)請求的方法來決定調(diào)用的是servlet的doGet方法還是doPost或其它的方法。

到此 Connector的整理流程就結(jié)束了。

簡單梳理下

1. Connector

根據(jù)協(xié)議來選擇協(xié)議的處理類，tomcat默認的處理類是Http11Protocol。

2. JIoEndpoint

創(chuàng)建ServerSocket 連接

創(chuàng)建接受請求的線程 Acceptor對象。

創(chuàng)建處理請求的線程池 executor。

3. Http11Processor

主要負責(zé)解析http協(xié)議的
1. 解析請求行 （來確定http協(xié)議、請求的url、請求的method）
2. 解析請求頭 headers
3.并把解析后的結(jié)果交給 Container 處理

connector 可配置的部分參數(shù)

參數(shù)值根據(jù)自己項目做響應(yīng)修改。下面的只是個例子

<Connector port="8080" protocol="HTTP/1.1"acceptCount="1000"disableUploadTimeout="true"enableLookups="false"keepAliveTimeout="20"maxThreads="500" minThreads="500"maxProcessor="500"minSpareThreads="20"maxKeepAliveRequests="1"connectionTimeout="20" redirectPort="8443"allowTrace="false"acceptorThreadCount="2"acceptorThreadPriority="7"socket.tcpNoDelay="true"threadPriority="8"tcpNoDelay="true"compression="on"emptySessionPath="true" />

本人簡書blog地址：http://www.jianshu.com/u/1f0067e24ff8????
點擊這里快速進入簡書

GIT地址：http://git.oschina.net/brucekankan/
點擊這里快速進入GIT

總結(jié)

以上是生活随笔為你收集整理的Tomcat connector 实现原理的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。