php-fpm的reload操作如何實現(xiàn)

這期內(nèi)容當中小編將會給大家?guī)碛嘘P(guān)php-fpm的reload操作如何實現(xiàn)，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

 摘要：reload會讓sleep提前結(jié)束，所以就探究了下fpm的reload操作如何實現(xiàn)？

php-fpm的reload過程

本文在PHP7.0 fpm下分析，process_control_timeout設(shè)置不為0。

重啟信號

首先，我們從 可以知道，fpm的reload操作實際上就是對fpm進程發(fā)送了USR2信號。

fpm的master進程中， 通過 注冊了信號處理函數(shù) ：

int fpm_signals_init_main() /* {{{ */{ struct sigactionact;
  // 。。。。。。  memset(&act, 0, sizeof(act));
act.sa_handler = sig_handler;
sigfillset(&act.sa_mask);
  if (0 > sigaction(SIGTERM,  &act, 0) ||
    0 > sigaction(SIGINT,  &act, 0) ||
    0 > sigaction(SIGUSR1,  &act, 0) ||
    0 > sigaction(SIGUSR2,  &act, 0) ||
    0 > sigaction(SIGCHLD,  &act, 0) ||
    0 > sigaction(SIGQUIT,  &act, 0)) {
zlog(ZLOG_SYSERROR, "failed to init signals: sigaction()"); return -1;
} return 0;
}/* }}} */

簡而言之，通過 設(shè)置為block掉所有的信號，然后通過sigaction設(shè)置對應(yīng)的信號處理函數(shù)。

當我們reload fpm時，systemctl向fpm的master進程發(fā)送USR2信號，執(zhí)行函數(shù) ：

static void sig_handler(int signo) /* {{{ */{ static const char sig_chars[NSIG + 1] = {
[SIGTERM] = 'T',
[SIGINT]  = 'I',
[SIGUSR1] = '1',
[SIGUSR2] = '2',
[SIGQUIT] = 'Q',
[SIGCHLD] = 'C'
}; char s;
        // ***
s = sig_chars[signo];
zend_quiet_write(sp[1], &s, sizeof(s));
errno = saved_errno;
}/* }}} */

關(guān)鍵點在 zend_quiet_write，它就是 。sig_handler函數(shù)就是向sp[ 1 ]中寫入了一個字符串2。

此處需要注意的是，sp[0]和sp[1]是通過 創(chuàng)建的本地套接字。

master開始重啟 之前的信號處理函數(shù)，在信號發(fā)生的時候會被調(diào)用，但是程序的主邏輯仍然不會被打亂，那fpm master進程怎么知道要reload呢？

答案就在 中，這是master進程的事件循環(huán)。

在循環(huán)之前， 我們需要用 sp[0] 一個 struct fpm_event_s，添加到監(jiān)聽的fd中：

int fpm_event_set(struct fpm_event_s *ev, int fd, int flags, void (*callback)(struct fpm_event_s *, short, void *), void *arg) /* {{{ */{ if (!ev || !callback || fd < -1) { return -1;
}
memset(ev, 0, sizeof(struct fpm_event_s));
ev->fd = fd;
ev->callback = callback;
ev->arg = arg;
ev->flags = flags; return 0;
}/* }}} */

然后將這個 struct fpm_event_s，也就是代碼中的ev， 監(jiān)聽的fd中。

實際上，這個添加過程也和fpm不同的異步模型有關(guān)（都是由對應(yīng)fpm_event_module_s的add方法實現(xiàn)的），比如 就是將ev參數(shù)整體放到epoll_event的data.ptr中的。（poll的add可以參考 ）

當所有的fd都添加了之后（當然不僅僅是signal相關(guān)的fd咯），我們就可以使用 等待事件來臨了。 （epoll和poll也都各自實現(xiàn)了wait方法）

好，回到sig_handler給sp[1]寫了個字符串2。 wait方法 接到了信號，拿到對應(yīng)的ev，調(diào)用 ，實際上就是調(diào)用了 ，就是 ：

static void fpm_got_signal(struct fpm_event_s *ev, short which, void *arg) /* {{{ */{ char c; int res, ret; int fd = ev->fd;
  do {
res = read(fd, &c, 1);
  switch (c) { // 。。。。。。
case '2' :                  /* SIGUSR2 */
zlog(ZLOG_DEBUG, "received SIGUSR2");
zlog(ZLOG_NOTICE, "Reloading in progress ...");
fpm_pctl(FPM_PCTL_STATE_RELOADING, FPM_PCTL_ACTION_SET); break;
}
  if (fpm_globals.is_child) { break;
}
} while (1); return;
}/* }}} */

如果接收到了字符串2，則執(zhí)行

fpm_pctl(FPM_PCTL_STATE_RELOADING, FPM_PCTL_ACTION_SET)

實際上就 ：

void fpm_pctl(int new_state, int action) /* {{{ */{ switch (action) { case FPM_PCTL_ACTION_SET :
//。。。。。。
fpm_signal_sent = 0;
fpm_state = new_state;
zlog(ZLOG_DEBUG, "switching to '%s' state", fpm_state_names[fpm_state]); /* fall down */  case FPM_PCTL_ACTION_TIMEOUT :
fpm_pctl_action_next(); break; //。。。。。
}
}/* }}} */

即，將fpm_state設(shè)置為FPM_PCTL_STATE_RELOADING后，沒有break，繼續(xù)執(zhí)行 ：

static void fpm_pctl_action_next() /* {{{ */
{ int sig, timeout;
  if (!fpm_globals.running_children) {
fpm_pctl_action_last();
}
  if (fpm_signal_sent == 0) { if (fpm_state == FPM_PCTL_STATE_TERMINATING) { sig = SIGTERM;
} else { sig = SIGQUIT;
}
timeout = fpm_global_config.process_control_timeout;
} else { if (fpm_signal_sent == SIGQUIT) { sig = SIGTERM;
} else { sig = SIGKILL;
}
timeout = 1;
}
fpm_pctl_kill_all(sig);
fpm_signal_sent = sig;
fpm_pctl_timeout_set(timeout);
}
/* }}} */

即，給所有子進程發(fā)送SIGQUIT信號。

這邊還有一個 ，這個等會討論。

子進程處理信號 父進程發(fā)送完信號了，就該子進程處理啦。

子進程只有 交給sig_soft_quit處理。子進程初始化完成后，收到了SIGQUIT信號，由sig_soft_quit處理，最終調(diào)用 處理：

void fcgi_terminate(void){
in_shutdown = 1;
}

就是將in_shutdown設(shè)置為1。

子進程退出 子進程的循環(huán)主體在 fcgi_accept_request 中，其中多出判斷in_shutdown，若為1則直接退出：

超時處理 前面提到的 是 。執(zhí)行了如下操作：

fpm_pctl(FPM_PCTL_STATE_UNSPECIFIED, FPM_PCTL_ACTION_TIMEOUT);

在這種條件下， ，直接退出了子進程。

為何sleep會被打斷？ 我們可以看到， 就是系統(tǒng)調(diào)用sleep（php_sleep是sleep的一個宏）：

/* {{{ proto void sleep(int seconds)
   Delay for a given number of seconds */PHP_FUNCTION(sleep)
{
zend_longnum;
  if (zend_parse_parameters(ZEND_NUM_ARGS(), "l", &num) == FAILURE) {
RETURN_FALSE;
}
php_sleep((unsigned int)num);
}/* }}} */

sleep函數(shù)執(zhí)行時，此時進程的狀態(tài)是S：

interruptiblesleep 此時一旦有信號觸發(fā)，立馬處理信號，比如我們剛剛說過的SIGQUIT，結(jié)束了之后發(fā)現(xiàn)，sleep執(zhí)行完了。

因為 寫了啊：

<b>sleep</b>() makesthecallingthreadsleepuntil <i>seconds</i> secondshave 
elapsedor a signalarriveswhichis not ignored.

需要注意的是， ，所以即使信號打斷了sleep，也僅僅是跳過sleep繼續(xù)執(zhí)行而已。

上述就是小編為大家分享的php-fpm的reload操作如何實現(xiàn)了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道。