php-frm进程管理,PHP内核探索-进程管理
進(jìn)程管理方式
首先我們了解一下php的三種不同的進(jìn)程管理方式：
static：靜態(tài)管理進(jìn)程。在啟動時，master按照pm.max_children配置fork出對應(yīng)數(shù)量的work進(jìn)程，即work的進(jìn)程是固定不變的。
dynamic：動態(tài)管理進(jìn)程。在fpm啟動時先按照pm.start_servers初始化一定數(shù)量的work進(jìn)程，運(yùn)行期間如果master發(fā)現(xiàn)空閑work進(jìn)程低于pm.min_spare_servers配置數(shù)(表示請求比較多，work處理不過來)時就會主動fork work進(jìn)程，但是總的work數(shù)不能超過pm.max_children，然后如果發(fā)現(xiàn)空閑的work數(shù)超過了pm.max_spare_servers配置數(shù)(表示空閑的work比較多)，master則會殺掉一些work進(jìn)程，避免占用過多資源。
ondemand：這種方式一般很少用，在啟動時不分配worker進(jìn)程，等到有請求了后再通知master進(jìn)程fork worker進(jìn)程，總的worker數(shù)不超過pm.max_children，處理完成后worker進(jìn)程不會立即退出，當(dāng)空閑時間超過pm.process_idle_timeout后再退出
下面我們看下fpm在執(zhí)行完fpm_run()之后master進(jìn)入fpm_event_loop()的邏輯
void fpm_event_loop(int err)
{
//創(chuàng)建一個io read的監(jiān)聽事件，這里監(jiān)聽的就是在fpm_init()階段中通過socketpair()創(chuàng)建管道sp[0]
//當(dāng)sp[0]可讀時將回調(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則啟動心跳檢查
if (fpm_globals.heartbeat > 0) {
fpm_pctl_heartbeat(NULL, 0, NULL);
}
//定時觸發(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);
...
//檢查定時器事件
...
}
}
這就是master整體的處理，其進(jìn)程管理主要依賴注冊的幾個事件，接下來我們詳細(xì)分析下這幾個事件的功能。
(1)sp[1]管道可讀事件：
在fpm_init()階段master曾創(chuàng)建了一個全雙工的管道：sp，然后在這里創(chuàng)建了一個sp[0]可讀的事件，當(dāng)sp[0]可讀時將交由fpm_got_signal()處理，向sp[1]寫數(shù)據(jù)時sp[0]才會可讀，那么什么時機(jī)會向sp[1]寫數(shù)據(jù)呢？前面已經(jīng)提到了：當(dāng)master收到注冊的那幾種信號時會寫入sp[1]端，這個時候?qū)⒂|發(fā)sp[0]可讀事件。
這個事件是master用于處理信號的，我們根據(jù)master注冊的信號逐個看下不同用途：
SIGINT/SIGTERM/SIGQUIT:退出fpm，在master收到退出信號后將向所有的worker進(jìn)程發(fā)送退出信號，然后master退出
SIGUSR1:重新加載日志文件，生產(chǎn)環(huán)境中通常會對日志進(jìn)行切割，切割后會生成一個新的日志文件，如果fpm不重新加載將無法繼續(xù)寫入日志，這個時候就需要向master發(fā)送一個USR1的信號
SIGUSR2:重啟fpm，首先master也是會向所有的worker進(jìn)程發(fā)送退出信號，然后master會調(diào)用execvp()重新啟動fpm，最后舊的master退出
SIGCHLD:這個信號是子進(jìn)程退出時操作系統(tǒng)發(fā)送給父進(jìn)程的，子進(jìn)程退出時，內(nèi)核將子進(jìn)程置為僵尸狀態(tài)，這個進(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主動殺掉時master將受到此信號，這個時候父進(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啟動了一個定時器，每隔1s觸發(fā)一次，主要用于dynamic、ondemand模式下的worker管理，master會定時檢查各worker pool的worker進(jìn)程數(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; //空閑時間最久的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)) {
//找空閑時間最久的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) {
//如果空閑時間最長的worker空閑時間超過了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():
這個事件是用于限制worker處理單個請求最大耗時的，php-fpm.conf中有一個request_terminate_timeout的配置項(xiàng)，如果worker處理一個請求的總時長超過了這個值那么master將會向此worker進(jìn)程發(fā)送kill -TERM信號殺掉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處理的請求是否超時
fpm_request_check_timed_out(child, now, terminate_timeout, slowlog_timeout);
}
}
}
}
除了上面這幾個事件外還有一個沒有提到，那就是ondemand模式下master監(jiān)聽的新請求到達(dá)的事件，因?yàn)閛ndemand模式下fpm啟動時是不會預(yù)創(chuàng)建worker的，有請求時才會生成子進(jìn)程，所以請求到達(dá)時需要通知master進(jìn)程，這個事件是在fpm_children_create_initial()時注冊的，事件處理函數(shù)為fpm_pctl_on_socket_accept()，具體邏輯這里不再展開，比較容易理解。
總結(jié)
以上是生活随笔為你收集整理的php-frm进程管理,PHP内核探索-进程管理的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 同学们对《现代软件工程》课程的意见
- 下一篇： 洛谷找最小值c语言,洛谷 P1478 陶