php-frm进程管理,PHP内核探索-进程管理
進(jìn)程管理方式
首先我們了解一下php的三種不同的進(jìn)程管理方式：
static：靜態(tài)管理進(jìn)程。在啟動(dòng)時(shí)，master按照pm.max_children配置fork出對(duì)應(yīng)數(shù)量的work進(jìn)程，即work的進(jìn)程是固定不變的。
dynamic：動(dòng)態(tài)管理進(jìn)程。在fpm啟動(dòng)時(shí)先按照pm.start_servers初始化一定數(shù)量的work進(jìn)程，運(yùn)行期間如果master發(fā)現(xiàn)空閑work進(jìn)程低于pm.min_spare_servers配置數(shù)(表示請(qǐng)求比較多，work處理不過(guò)來(lái))時(shí)就會(huì)主動(dòng)fork work進(jìn)程，但是總的work數(shù)不能超過(guò)pm.max_children，然后如果發(fā)現(xiàn)空閑的work數(shù)超過(guò)了pm.max_spare_servers配置數(shù)(表示空閑的work比較多)，master則會(huì)殺掉一些work進(jìn)程，避免占用過(guò)多資源。
ondemand：這種方式一般很少用，在啟動(dòng)時(shí)不分配worker進(jìn)程，等到有請(qǐng)求了后再通知master進(jìn)程fork worker進(jìn)程，總的worker數(shù)不超過(guò)pm.max_children，處理完成后worker進(jìn)程不會(huì)立即退出，當(dāng)空閑時(shí)間超過(guò)pm.process_idle_timeout后再退出
下面我們看下fpm在執(zhí)行完fpm_run()之后master進(jìn)入fpm_event_loop()的邏輯
void fpm_event_loop(int err)
{
//創(chuàng)建一個(gè)io read的監(jiān)聽事件，這里監(jiān)聽的就是在fpm_init()階段中通過(guò)socketpair()創(chuàng)建管道sp[0]
//當(dāng)sp[0]可讀時(shí)將回調(diào)fpm_got_signal()
fpm_event_set(&signal_fd_event, fpm_signals_get_fd(), FPM_EV_READ, &fpm_got_signal, NULL);
fpm_event_add(&signal_fd_event, 0);
//如果在php-fpm.conf配置了request_terminate_timeout則啟動(dòng)心跳檢查
if (fpm_globals.heartbeat > 0) {
fpm_pctl_heartbeat(NULL, 0, NULL);
}
//定時(shí)觸發(fā)進(jìn)程管理
fpm_pctl_perform_idle_server_maintenance_heartbeat(NULL, 0, NULL);
//進(jìn)入事件循環(huán)，master進(jìn)程將阻塞在此
while (1) {
...
//等待IO事件
ret = module->wait(fpm_event_queue_fd, timeout);
...
//檢查定時(shí)器事件
...
}
}
這就是master整體的處理，其進(jìn)程管理主要依賴注冊(cè)的幾個(gè)事件，接下來(lái)我們?cè)敿?xì)分析下這幾個(gè)事件的功能。
(1)sp[1]管道可讀事件：
在fpm_init()階段master曾創(chuàng)建了一個(gè)全雙工的管道：sp，然后在這里創(chuàng)建了一個(gè)sp[0]可讀的事件，當(dāng)sp[0]可讀時(shí)將交由fpm_got_signal()處理，向sp[1]寫數(shù)據(jù)時(shí)sp[0]才會(huì)可讀，那么什么時(shí)機(jī)會(huì)向sp[1]寫數(shù)據(jù)呢？前面已經(jīng)提到了：當(dāng)master收到注冊(cè)的那幾種信號(hào)時(shí)會(huì)寫入sp[1]端，這個(gè)時(shí)候?qū)⒂|發(fā)sp[0]可讀事件。
這個(gè)事件是master用于處理信號(hào)的，我們根據(jù)master注冊(cè)的信號(hào)逐個(gè)看下不同用途：
SIGINT/SIGTERM/SIGQUIT:退出fpm，在master收到退出信號(hào)后將向所有的worker進(jìn)程發(fā)送退出信號(hào)，然后master退出
SIGUSR1:重新加載日志文件，生產(chǎn)環(huán)境中通常會(huì)對(duì)日志進(jìn)行切割，切割后會(huì)生成一個(gè)新的日志文件，如果fpm不重新加載將無(wú)法繼續(xù)寫入日志，這個(gè)時(shí)候就需要向master發(fā)送一個(gè)USR1的信號(hào)
SIGUSR2:重啟fpm，首先master也是會(huì)向所有的worker進(jìn)程發(fā)送退出信號(hào)，然后master會(huì)調(diào)用execvp()重新啟動(dòng)fpm，最后舊的master退出
SIGCHLD:這個(gè)信號(hào)是子進(jìn)程退出時(shí)操作系統(tǒng)發(fā)送給父進(jìn)程的，子進(jìn)程退出時(shí)，內(nèi)核將子進(jìn)程置為僵尸狀態(tài)，這個(gè)進(jìn)程稱為僵尸進(jìn)程，它只保留最小的一些內(nèi)核數(shù)據(jù)結(jié)構(gòu)，以便父進(jìn)程查詢子進(jìn)程的退出狀態(tài)，只有當(dāng)父進(jìn)程調(diào)用wait或者waitpid函數(shù)查詢子進(jìn)程退出狀態(tài)后子進(jìn)程才告終止，fpm中當(dāng)worker進(jìn)程因?yàn)楫惓Ｔ?比如coredump了)退出而非master主動(dòng)殺掉時(shí)master將受到此信號(hào)，這個(gè)時(shí)候父進(jìn)程將調(diào)用waitpid()查下子進(jìn)程的退出，然后檢查下是不是需要重新fork新的worker
具體處理邏輯在fpm_got_signal()函數(shù)中，這里不再羅列。
(2)fpm_pctl_perform_idle_server_maintenance_heartbeat():
這是進(jìn)程管理實(shí)現(xiàn)的主要事件，master啟動(dòng)了一個(gè)定時(shí)器，每隔1s觸發(fā)一次，主要用于dynamic、ondemand模式下的worker管理，master會(huì)定時(shí)檢查各worker pool的worker進(jìn)程數(shù)，通過(guò)此定時(shí)器實(shí)現(xiàn)worker數(shù)量的控制，處理邏輯如下：
static void fpm_pctl_perform_idle_server_maintenance(struct timeval *now)
{
for (wp = fpm_worker_all_pools; wp; wp = wp->next) {
struct fpm_child_s *last_idle_child = NULL; //空閑時(shí)間最久的worker
int idle = 0; //空閑worker數(shù)
int active = 0; //忙碌worker數(shù)
for (child = wp->children; child; child = child->next) {
//根據(jù)worker進(jìn)程的fpm_scoreboard_proc_s->request_stage判斷
if (fpm_request_is_idle(child)) {
//找空閑時(shí)間最久的worker
...
idle++;
}else{
active++;
}
}
...
//ondemand模式
if (wp->config->pm == PM_STYLE_ONDEMAND) {
if (!last_idle_child) continue;
fpm_request_last_activity(last_idle_child, &last);
fpm_clock_get(&now);
if (last.tv_sec < now.tv_sec - wp->config->pm_process_idle_timeout) {
//如果空閑時(shí)間最長(zhǎng)的worker空閑時(shí)間超過(guò)了process_idle_timeout則殺掉該worker
last_idle_child->idle_kill = 1;
fpm_pctl_kill(last_idle_child->pid, FPM_PCTL_QUIT);
}
continue;
}
//dynamic
if (wp->config->pm != PM_STYLE_DYNAMIC) continue;
if (idle > wp->config->pm_max_spare_servers && last_idle_child) {
//空閑worker太多了，殺掉
last_idle_child->idle_kill = 1;
fpm_pctl_kill(last_idle_child->pid, FPM_PCTL_QUIT);
wp->idle_spawn_rate = 1;
continue;
}
if (idle < wp->config->pm_min_spare_servers) {
//空閑worker太少了，如果總worker數(shù)未達(dá)到max數(shù)則fork
...
}
}
}
(3)fpm_pctl_heartbeat():
這個(gè)事件是用于限制worker處理單個(gè)請(qǐng)求最大耗時(shí)的，php-fpm.conf中有一個(gè)request_terminate_timeout的配置項(xiàng)，如果worker處理一個(gè)請(qǐng)求的總時(shí)長(zhǎng)超過(guò)了這個(gè)值那么master將會(huì)向此worker進(jìn)程發(fā)送kill -TERM信號(hào)殺掉worker進(jìn)程，此配置單位為秒，默認(rèn)值為0表示關(guān)閉此機(jī)制，另外fpm打印的slow log也是在這里完成的。
static void fpm_pctl_check_request_timeout(struct timeval *now)
{
struct fpm_worker_pool_s *wp;
for (wp = fpm_worker_all_pools; wp; wp = wp->next) {
int terminate_timeout = wp->config->request_terminate_timeout;
int slowlog_timeout = wp->config->request_slowlog_timeout;
struct fpm_child_s *child;
if (terminate_timeout || slowlog_timeout) {
for (child = wp->children; child; child = child->next) {
//檢查當(dāng)前當(dāng)前worker處理的請(qǐng)求是否超時(shí)
fpm_request_check_timed_out(child, now, terminate_timeout, slowlog_timeout);
}
}
}
}
除了上面這幾個(gè)事件外還有一個(gè)沒有提到，那就是ondemand模式下master監(jiān)聽的新請(qǐng)求到達(dá)的事件，因?yàn)閛ndemand模式下fpm啟動(dòng)時(shí)是不會(huì)預(yù)創(chuàng)建worker的，有請(qǐng)求時(shí)才會(huì)生成子進(jìn)程，所以請(qǐng)求到達(dá)時(shí)需要通知master進(jìn)程，這個(gè)事件是在fpm_children_create_initial()時(shí)注冊(cè)的，事件處理函數(shù)為fpm_pctl_on_socket_accept()，具體邏輯這里不再展開，比較容易理解。
總結(jié)
以上是生活随笔為你收集整理的php-frm进程管理,PHP内核探索-进程管理的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 同学们对《现代软件工程》课程的意见
- 下一篇： 洛谷找最小值c语言,洛谷 P1478 陶