命令
nginx -s quit 或 kill -s SIGQUIT <nginx master pid> 可以优雅的关闭服务。它们都是通过发送信号实现的。具体见——向master进程发送信号。
具体过程
由 向master进程发送信号 一文可知，捕捉到信号并处理后，master进程被唤醒，它将检测被信号处理函数改写过的全局变量的值，进而决定下一步的执行。
当在终端执行 nginx -s quit 或 kill -s SIGQUIT <nginx master pid>命令后，全局变量ngx_quit被置位为1；
//ngx_signal_handler函数代码片段
case ngx_signal_value(NGX_SHUTDOWN_SIGNAL):
ngx_quit = 1;
action = ", shutting down";
break;
master进程循环内部,与quit相关代码如下所示。
首先，调用ngx_signal_worker_processed函数，第二个参数ngx_signal_value(NGX_SHUTDOWN_SIGNAL)实际上就是SIGQUIT信号，该函数将通知所有子进程终止。
其次，关闭所有监听socket，并复位cycle指针指向的配置项结构体的成员listening,该成员与监听socket有关。
if (ngx_quit) {
ngx_signal_worker_processes(cycle,ngx_signal_value(NGX_SHUTDOWN_SIGNAL));
ls = cycle->listening.elts;
for (n = 0; n < cycle->listening.nelts; n++) {
if (ngx_close_socket(ls[n].fd) == -1) {
ngx_log_error(...)
}
}
cycle->listening.nelts = 0;
continue;
}
下面看ngx_signal_worker_processed函数
//片段1
static void
ngx_signal_worker_processes(ngx_cycle_t *cycle, int signo)
{
......
ngx_channel_t ch;
switch (signo) {
case ngx_signal_value(NGX_SHUTDOWN_SIGNAL):
ch.command = NGX_CMD_QUIT;
break;
case ngx_signal_value(NGX_TERMINATE_SIGNAL):
ch.command = NGX_CMD_TERMINATE;
break;
case ngx_signal_value(NGX_REOPEN_SIGNAL):
ch.command = NGX_CMD_REOPEN;
break;
default:
ch.command = 0;
}
......
}
ngx_signal_worker_processed函数中有一个重要的结构体ngx_channel_t,具体如下：
typedef struct {
ngx_uint_t command;//传递的TCP消息中的命令
ngx_pid_t pid; //一般是发送命令方的进程id
ngx_int_t slot;//表示发送命令方在ngx_processes进程数组间的序号
ngx_fd_t fd;//通信的套接字句柄
} ngx_channel_t;
通过该结构体和与其相关的三个函数实现master进程与worker进程的通信，具体见 master与worker的通信机制 一文。先简单介绍下这三个函数：
ngx_open_channel——建立通信通道
ngx_write_channel——向另一进程发送消息
ngx_read_channel——读取所获得的消息
当判断信号为 ngx_signal_value(NGX_SHUTDOWN_SIGNAL),即SIGQUIT后，令ch.command = NGX_CMD_QUIT，调用ngx_write_channel函数将给命令发送给子进程。
//通过CHANNEL发送命令给待终止的子进程，子进程调用ngx_channel_handler 处理
//由于是非阻塞socket,函数返回前，命令将被传递给子进程
if (ch.command) {
if (ngx_write_channel(ngx_processes[i].channel[0],
&ch, sizeof(ngx_channel_t), cycle->log)
== NGX_OK)
{
if (signo != ngx_signal_value(NGX_REOPEN_SIGNAL)) {
ngx_processes[i].exiting = 1;
}
continue;
}
}
