Nginx源码学习——优雅的停止Nginx服务

命令

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;
       }
   }