Tomcat處理請(qǐng)求的線程模型詳解
一、前言
JAVA后端項(xiàng)目，運(yùn)行在容器tomcat中，由于現(xiàn)在springboot的內(nèi)置tomcat容器，其默認(rèn)配置屏蔽了很多對(duì)tomcat的認(rèn)知，但是對(duì)tomcat的學(xué)習(xí)和認(rèn)識(shí)是比較重要的，所以專門查資料加深了理解，本文主要討論在springboot集成下的tomcat9的請(qǐng)求過程，線程模型為NIO。
二、tomcat結(jié)構(gòu)
找了張結(jié)構(gòu)圖，每個(gè)模塊的意思和作用就不詳解了，可以搜其他文章
三、探討tomcat是如何處理請(qǐng)求
自己畫了一個(gè)connector的結(jié)構(gòu)
1、初始化
在springboot啟動(dòng)后，org.springframework.context.support.AbstractApplicationContext#finishRefresh，這里進(jìn)去調(diào)用org.springframework.boot.web.servlet.context.WebServerStartStopLifecycle.start()方法啟動(dòng)TomcatWebServer，初始化tomcat。
通過這樣的調(diào)用鏈到達(dá)org.apache.tomcat.util.net.NioEndpoint#startInternal(),進(jìn)行初始化Endpoint中的Acceptor和Poller，這兩者都實(shí)現(xiàn)了Runnable接口，初始化后就通過線程start啟動(dòng)了。
2、如何處理客戶端請(qǐng)求
Acceptor： 接收器，作用是接受scoket網(wǎng)絡(luò)請(qǐng)求，并調(diào)用setSocketOptions()封裝成為NioSocketWrapper，并注冊(cè)到Poller的events中。注意查看run方法org.apache.tomcat.util.net.Acceptor#run
@Override
public void run() {
int errorDelay = 0;
try {
// Loop until we receive a shutdown command
while (!stopCalled) {
// Loop if endpoint is paused
while (endpoint.isPaused() && !stopCalled) {
state = AcceptorState.PAUSED;
try {
Thread.sleep(50);
} catch (InterruptedException e) {
// Ignore
}
}
if (stopCalled) {
break;
}
state = AcceptorState.RUNNING;
try {
//if we have reached max connections, wait
endpoint.countUpOrAwaitConnection();
// Endpoint might have been paused while waiting for latch
// If that is the case, don't accept new connections
if (endpoint.isPaused()) {
continue;
}
U socket = null;
try {
// 等待下一個(gè)請(qǐng)求進(jìn)來
socket = endpoint.serverSocketAccept();
} catch (Exception ioe) {
// We didn't get a socket
endpoint.countDownConnection();
if (endpoint.isRunning()) {
// Introduce delay if necessary
errorDelay = handleExceptionWithDelay(errorDelay);
// re-throw
throw ioe;
} else {
break;
}
}
// Successful accept, reset the error delay
errorDelay = 0;
// Configure the socket
if (!stopCalled && !endpoint.isPaused()) {
// 注冊(cè)socket到Poller，生成PollerEvent事件
if (!endpoint.setSocketOptions(socket)) {
endpoint.closeSocket(socket);
}
} else {
endpoint.destroySocket(socket);
}
} catch (Throwable t) {
ExceptionUtils.handleThrowable(t);
String msg = sm.getString("endpoint.accept.fail");
// APR specific.
// Could push this down but not sure it is worth the trouble.
if (t instanceof Error) {
Error e = (Error) t;
if (e.getError() == 233) {
// Not an error on HP-UX so log as a warning
// so it can be filtered out on that platform
// See bug 50273
log.warn(msg, t);
} else {
log.error(msg, t);
}
} else {
log.error(msg, t);
}
}
}
} finally {
stopLatch.countDown();
}
state = AcceptorState.ENDED;
}
Poller：輪詢器，輪詢是否有事件達(dá)到，有請(qǐng)求事件到達(dá)后，以NIO的處理方式，查詢Selector取出所有請(qǐng)求，遍歷每個(gè)請(qǐng)求的需求，分配給Executor線程池執(zhí)行。查看org.apache.tomcat.util.net.NioEndpoint.Poller#run()
public void run() {
// Loop until destroy() is called
while (true) {
boolean hasEvents = false;
try {
if (!close) {
hasEvents = events();
if (wakeupCounter.getAndSet(-1) > 0) {
// If we are here, means we have other stuff to do
// Do a non blocking select
keyCount = selector.selectNow();
} else {
keyCount = selector.select(selectorTimeout);
}
wakeupCounter.set(0);
}
if (close) {
events();
timeout(0, false);
try {
selector.close();
} catch (IOException ioe) {
log.error(sm.getString("endpoint.nio.selectorCloseFail"), ioe);
}
break;
}
// Either we timed out or we woke up, process events first
if (keyCount == 0) {
hasEvents = (hasEvents | events());
}
} catch (Throwable x) {
ExceptionUtils.handleThrowable(x);
log.error(sm.getString("endpoint.nio.selectorLoopError"), x);
continue;
}
//查詢selector取出所有請(qǐng)求
Iterator<SelectionKey> iterator =
keyCount > 0 ? selector.selectedKeys().iterator() : null;
// Walk through the collection of ready keys and dispatch
// any active event.
while (iterator != null && iterator.hasNext()) {
SelectionKey sk = iterator.next();
iterator.remove();
NioSocketWrapper socketWrapper = (NioSocketWrapper) sk.attachment();
//處理請(qǐng)求key
if (socketWrapper != null) {
processKey(sk, socketWrapper);
}
}
// Process timeouts
timeout(keyCount,hasEvents);
}
getStopLatch().countDown();
}
請(qǐng)求過程大致如下圖：
總結(jié)
本篇文章就到這里了，希望能夠給你帶來幫助，也希望您能夠多多關(guān)注腳本之家的更多內(nèi)容!
相關(guān)文章
Spring Boot 2 整合 QuartJob 實(shí)現(xiàn)定時(shí)器實(shí)時(shí)管理功能
Quartz是一個(gè)完全由java編寫的開源作業(yè)調(diào)度框架，形式簡(jiǎn)易，功能強(qiáng)大。接下來通過本文給大家分享Spring Boot 2 整合 QuartJob 實(shí)現(xiàn)定時(shí)器實(shí)時(shí)管理功能，感興趣的朋友一起看看吧2019-11-11
SpringBoot熱部署Springloaded實(shí)現(xiàn)過程解析
這篇文章主要介紹了SpringBoot熱部署Springloaded實(shí)現(xiàn)過程解析,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-03-03
MyBatis的每一個(gè)查詢映射的返回類型都是ResultMap，當(dāng)我們提供返回類型屬性是resultType時(shí)，MyBatis會(huì)自動(dòng)給我們把對(duì)應(yīng)值賦給resultType所指定對(duì)象的屬性，當(dāng)我們提供返回類型是resultMap時(shí)，將數(shù)據(jù)庫(kù)中列數(shù)據(jù)復(fù)制到對(duì)象的相應(yīng)屬性上，可以用于復(fù)制查詢，兩者不能同時(shí)用2022-04-04
這篇文章主要介紹了Kotlin this詳解及實(shí)例的相關(guān)資料,需要的朋友可以參考下2017-06-06
JAVA maven項(xiàng)目使用釘釘SDK獲取token、用戶
這篇文章主要介紹了JAVA maven項(xiàng)目使用釘釘SDK獲取token、用戶，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-06-06
這篇文章主要介紹了java Date類詳解及使用總結(jié)的相關(guān)資料,需要的朋友可以參考下2017-02-02
下面小編就為大家?guī)硪黄獪\談Java中的克隆close()和賦值引用的區(qū)別。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2016-09-09
這篇文章簡(jiǎn)單主要介紹了java貪心算法，包含貪心算法的基本思路，性質(zhì)，以及實(shí)現(xiàn)示例，有需要的小伙伴參考下2015-02-02
這篇文章主要為大家詳細(xì)介紹了微信開發(fā)之使用java獲取簽名signature，感興趣的小伙伴們可以參考一下2016-08-08
Spring Security 使用 OncePerRequestFilter
OncePerRequestFilter是一個(gè)過濾器,每個(gè)請(qǐng)求都會(huì)執(zhí)行一次；一般開發(fā)中主要是做檢查是否已登錄、Token是否過期和授權(quán)等操作,而每個(gè)操作都是一個(gè)過濾器,下面介紹Spring Security 使用 OncePerRequestFilter 過濾器校驗(yàn)登錄過期、請(qǐng)求日志等操作方法,感興趣的朋友一起看看吧2024-06-06