zoukankan      html  css  js  c++  java

  • nginx的进程模型

    nginx采用的也是大部分http服务器的做法，就是master,worker模型，一个master进程管理站个或者多个worker进程，基本的事件处理都是放在woker中，master负责一些全局初始化，以及对worker的管理。

    在nginx中master和worker的通信是通过socketpair来实现的，每次fork完一个子进程之后，将这个子进程的socketpaire句柄传递给前面已经存在的子进程，这样子进程之间也就可以通信了。


    nginx中fork子进程是在ngx_spawn_process中进行的：

    第一个参数是全局的配置，第二个参数是子进程需要执行的函数，第三个参数是proc的参数。第四个类型。

    Java代码  收藏代码
    1. ngx_pid_t  
    2. ngx_spawn_process(ngx_cycle_t *cycle, ngx_spawn_proc_pt proc, void *data,  
    3.     char *name, ngx_int_t respawn)  



    这个函数主要的任务就是：

    1 有一个ngx_processes全局数组，包含了所有的存货的子进程，这里会fork出来的子进程放入到相应的位置。并设置这个进程的相关属性。

    2 创建socketpair，并设置相关属性。


    3 在子进程中执行传递进来的函数。

    在看详细代码之前，我们先来看几个主要的数据结构：

    首先是进程结构，这个结构体表示了一个进程。包含了它的id状态，channel等等。

    Java代码  收藏代码
    1. typedef struct {  
    2. ///进程id  
    3.     ngx_pid_t           pid;  
    4. ///进程的退出状态(主要在waitpid中进行处理).  
    5.     int                 status;  
    6. ///进程channel(也就是通过socketpair创建的两个句柄)  
    7.     ngx_socket_t        channel[2];  
    8.   
    9. ///进程的执行函数（也就是每次spawn，子进程所要执行的那个函数).  
    10.     ngx_spawn_proc_pt   proc;  
    11.     void               *data;  
    12.     char               *name;  
    13. ///进程的几个状态。  
    14.     unsigned            respawn:1;  
    15.     unsigned            just_respawn:1;  
    16.     unsigned            detached:1;  
    17.     unsigned            exiting:1;  
    18.     unsigned            exited:1;  
    19. } ngx_process_t;  



    下面我们来看详细的代码。
    先来看第一部分：

    Java代码  收藏代码
    1.    
    2. //全局的进程表，保存了存活的子进程。  
    3. ngx_process_t    ngx_processes[NGX_MAX_PROCESSES];  
    4. ...................................  
    5. u_long     on;  
    6.     ngx_pid_t  pid;  
    7. ///表示将要fork的子进程在ngx_processes中的位置，  
    8.     ngx_int_t  s;  
    9. ///首先，如果传递进来的类型大于0,则就是已经确定这个进程已经退出，我们就可以直接确定slot。  
    10.     if (respawn >= 0) {  
    11.         s = respawn;  
    12.   
    13.     } else {  
    14. ///遍历ngx_processess，从而找到空闲的slot，从而等会fork完毕后,将子进程信息放入全局进程信息表的相应的slot。  
    15.         for (s = 0; s < ngx_last_process; s++) {  
    16.             if (ngx_processes[s].pid == -1) {  
    17.                 break;  
    18.             }  
    19.         }  
    20. ///到达最大进程限制报错。  
    21.         if (s == NGX_MAX_PROCESSES) {  
    22.             ngx_log_error(NGX_LOG_ALERT, cycle->log, 0,  
    23.                           "no more than %d processes can be spawned",  
    24.                           NGX_MAX_PROCESSES);  
    25.             return NGX_INVALID_PID;  
    26.         }  
    27.     }  




    接下来新建一对socketpair句柄，然后初始化相关属性。

    Java代码  收藏代码
    1. ///如果类型为NGX_PROCESS_DETACHED，则说明是热代码替换(热代码替换也是通过这个函数进行处理的)，因此不需要新建socketpair。  
    2. if (respawn != NGX_PROCESS_DETACHED) {  
    3.   
    4.         /* Solaris 9 still has no AF_LOCAL */  
    5. ///建立socketpair  
    6.         if (socketpair(AF_UNIX, SOCK_STREAM, 0, ngx_processes[s].channel) == -1)  
    7.         {  
    8.             ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,  
    9.                           "socketpair() failed while spawning "%s"", name);  
    10.             return NGX_INVALID_PID;  
    11.         }  
    12.         。。。。。。。。。。。。。。。。。。。。。。。。。。。。  
    13. ///设置非阻塞模式  
    14.         if (ngx_nonblocking(ngx_processes[s].channel[0]) == -1) {  
    15. ........................................................  
    16.         }  
    17.   
    18.         if (ngx_nonblocking(ngx_processes[s].channel[1]) == -1) {  
    19. ........................................  
    20.         }  
    21.   
    22. ///打开异步模式  
    23.         on = 1;  
    24.         if (ioctl(ngx_processes[s].channel[0], FIOASYNC, &on) == -1) {  
    25. .................................................  
    26.         }  
    27. ///设置异步io的所有者  
    28.         if (fcntl(ngx_processes[s].channel[0], F_SETOWN, ngx_pid) == -1) {  
    29.   
    30. ..............................................  
    31.         }  
    32. ///当exec后关闭句柄。  
    33.         if (fcntl(ngx_processes[s].channel[0], F_SETFD, FD_CLOEXEC) == -1) {................................................  
    34.         }  
    35.   
    36.         if (fcntl(ngx_processes[s].channel[1], F_SETFD, FD_CLOEXEC) == -1) {  
    37.   。。。。。。。。。。。。。。。。。。。。。。。。。。  
    38.         }  
    39. ///设置当前的子进程的句柄  
    40.         ngx_channel = ngx_processes[s].channel[1];  
    41.   
    42.     } else {  
    43.         ngx_processes[s].channel[0] = -1;  
    44.         ngx_processes[s].channel[1] = -1;  
    45.     }  





    接下来就是fork子进程，并设置进程相关参数。

    Java代码  收藏代码
    1. ///设置进程在进程表中的slot。  
    2. ngx_process_slot = s;  
    3.   
    4.   
    5.     pid = fork();  
    6.   
    7.     switch (pid) {  
    8.   
    9.     case -1:  
    10.         ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,  
    11.                       "fork() failed while spawning "%s"", name);  
    12.         ngx_close_channel(ngx_processes[s].channel, cycle->log);  
    13.         return NGX_INVALID_PID;  
    14.   
    15.     case 0  
    16. ///子进程，因此执行传递进来的子进程的函数  
    17.         ngx_pid = ngx_getpid();  
    18.         proc(cycle, data);  
    19.         break;  
    20.   
    21.     default:  
    22.         break;  
    23.     }  
    24.   
    25.     ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "start %s %P", name, pid);  
    26.   
    27.     ngx_processes[s].pid = pid;  
    28.     ngx_processes[s].exited = 0;  
    29.   
    30. ///如果大于0,则说明我们确定了重启的子进程，因此下面的初始化就用已死的子进程的就够了。  
    31.     if (respawn >= 0) {  
    32.         return pid;  
    33.     }  
    34. ///开始初始化进程结构。  
    35.     ngx_processes[s].proc = proc;  
    36.     ngx_processes[s].data = data;  
    37.     ngx_processes[s].name = name;  
    38.     ngx_processes[s].exiting = 0;  
    39.   
    40.   
    41. ///设置相关状态。  
    42.     switch (respawn) {  
    43.   
    44.     case NGX_PROCESS_RESPAWN:  
    45.         ngx_processes[s].respawn = 1;  
    46.         ngx_processes[s].just_respawn = 0;  
    47.         ngx_processes[s].detached = 0;  
    48.         break;  
    49.   
    50.     case NGX_PROCESS_JUST_RESPAWN:  
    51.         ngx_processes[s].respawn = 1;  
    52.         ngx_processes[s].just_respawn = 1;  
    53.         ngx_processes[s].detached = 0;  
    54.         break;  
    55.   
    56.     case NGX_PROCESS_DETACHED:  
    57.         ngx_processes[s].respawn = 0;  
    58.         ngx_processes[s].just_respawn = 0;  
    59.         ngx_processes[s].detached = 1;  
    60.         break;  
    61.     }  
    62.   
    63.     if (s == ngx_last_process) {  
    64.         ngx_last_process++;  
    65.     }  
    66.   
    67. return pid;  



    这里有个问题，那就是后面fork的子进程如何来让前面已经fork的子进程得到自己的进程相关信息呢。在nginx中是每次新的子进程fork 完毕后，然后父进程此时将这个子进程id，以及流管道的句柄channel[0]传递给前面的子进程。这样子进程之间也可以通信了。

    先来看相关的数据结构：

    Java代码  收藏代码
    1. ///封装了父子进程之间传递的信息。  
    2. typedef struct {  
    3. ///对端将要做得命令。  
    4.      ngx_uint_t  command;  
    5. ///当前的子进程id  
    6.      ngx_pid_t   pid;  
    7. ///在全局进程表中的位置  
    8.      ngx_int_t   slot;  
    9. ///传递的fd  
    10.      ngx_fd_t    fd;  
    11. } ngx_channel_t;  



    接下来来看代码：

    Java代码  收藏代码
    1. static void  
    2. ngx_start_worker_processes(ngx_cycle_t *cycle, ngx_int_t n, ngx_int_t type)  
    3. {  
    4.     ngx_int_t      i, s;  
    5.     ngx_channel_t  ch;  
    6.   
    7. ....................................  
    8. ///传递给其他子进程的命令  
    9.     ch.command = NGX_CMD_OPEN_CHANNEL;  
    10.   
    11. ///这里n，就是从配置文件中读取的，需要几个子进程。  
    12.     for (i = 0; i < n; i++) {  
    13.   
    14.         cpu_affinity = ngx_get_cpu_affinity(i);  
    15.   
    16. ///这个函数刚才介绍过了。就是fork子进程。  
    17.         ngx_spawn_process(cycle, ngx_worker_process_cycle, NULL,  
    18.                           "worker process", type);  
    19. ///初始化channel，ngx_process_slot这个我们在上面的spawn函数中已经赋值完毕，就是当前子进程的位置。  
    20.         ch.pid = ngx_processes[ngx_process_slot].pid;  
    21.         ch.slot = ngx_process_slot;  
    22.         ch.fd = ngx_processes[ngx_process_slot].channel[0];  
    23.   
    24. ///遍历整个进程表  
    25.         for (s = 0; s < ngx_last_process; s++) {  
    26. ///遇到非存活的进程就跳过。  
    27.             if (s == ngx_process_slot  
    28.                 || ngx_processes[s].pid == -1  
    29.                 || ngx_processes[s].channel[0] == -1)  
    30.             {  
    31.                 continue;  
    32.             }  
    33.   
    34.             ngx_log_debug6(NGX_LOG_DEBUG_CORE, cycle->log, 0,  
    35.                           "pass channel s:%d pid:%P fd:%d to s:%i pid:%P fd:%d",  
    36.                           ch.slot, ch.pid, ch.fd,  
    37.                           s, ngx_processes[s].pid,  
    38.                           ngx_processes[s].channel[0]);  
    39.   
    40.             /* TODO: NGX_AGAIN */  
    41. ///然后传递这个channel给其他子进程(主要是传递句柄)。  
    42.             ngx_write_channel(ngx_processes[s].channel[0],  
    43.                               &ch, sizeof(ngx_channel_t), cycle->log);  
    44.         }  
    45.     }  
    46. }  



    而在子进程中是如何处理的呢，子进程的管道可读事件捕捉函数是ngx_channel_handler(ngx_event_t *ev)，在这个函数中，会读取mseeage，然后解析，并根据不同的命令做不同的处理，来看它的代码片断：

    Java代码  收藏代码
    1. ///这里ch为读取的channel。  
    2.   
    3.         switch (ch.command) {  
    4.   
    5.         case NGX_CMD_QUIT:  
    6.             ngx_quit = 1;  
    7.             break;  
    8.   
    9.         case NGX_CMD_TERMINATE:  
    10.             ngx_terminate = 1;  
    11.             break;  
    12.   
    13.         case NGX_CMD_REOPEN:  
    14.             ngx_reopen = 1;  
    15.             break;  
    16.   
    17.         case NGX_CMD_OPEN_CHANNEL:  
    18. ///可以看到操作很简单，就是对ngx_processes全局进程表进行赋值。  
    19.             ngx_processes[ch.slot].pid = ch.pid;  
    20.             ngx_processes[ch.slot].channel[0] = ch.fd;  
    21.             break;  
    22.   
    23.         case NGX_CMD_CLOSE_CHANNEL:  
    24. .....................................................  
    25.   
    26.             if (close(ngx_processes[ch.slot].channel[0]) == -1) {  
    27.                 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno,  
    28.                               "close() channel failed");  
    29.             }  
    30.   
    31.             ngx_processes[ch.slot].channel[0] = -1;  
    32.             break;  
    33.         }  



    接下来详细的来看worker和master如何进行交互，以及master如何同外部进行交互(比如热代码替换，reconfig这些操作)。

    在nginx中，worker和master的交互，我们前面已经提过了，就是通过流管道以及信号，而master与外部的交互是通过信号来进行的。

    在看master得主循环之前，我们先来看信号处理和函数，在nginx中，父子进程的信号处理函数是相同的，只不过有一个变量在master和worker中赋值不同，以此来区分。

    在信号处理中，通过设置相应的标志变量，从而在主循环中，判断这些变量，从而做相应的操作。

    Java代码  收藏代码
    1. ///定义的信号值。  
    2. #define NGX_SHUTDOWN_SIGNAL      QUIT  
    3. #define NGX_TERMINATE_SIGNAL     TERM  
    4. #define NGX_NOACCEPT_SIGNAL      WINCH  
    5. #define NGX_RECONFIGURE_SIGNAL   HUP  
    6.   
    7. #if (NGX_LINUXTHREADS)  
    8. #define NGX_REOPEN_SIGNAL        INFO  
    9. #define NGX_CHANGEBIN_SIGNAL     XCPU  
    10. #else  
    11. #define NGX_REOPEN_SIGNAL        USR1  
    12. #define NGX_CHANGEBIN_SIGNAL     USR2  
    13. #endif  
    14.   
    15.   
    16. void  
    17. ngx_signal_handler(int signo)  
    18. {  
    19.     char            *action;  
    20.     ngx_int_t        ignore;  
    21.     ngx_err_t        err;  
    22.     ngx_signal_t    *sig;  
    23.   
    24.     ignore = 0;  
    25.   
    26.     err = ngx_errno;  
    27.   
    28. ///首先得到当前的信号值  
    29.     for (sig = signals; sig->signo != 0; sig++) {  
    30.         if (sig->signo == signo) {  
    31.             break;  
    32.         }  
    33.     }  
    34.   
    35.     ngx_time_update(0, 0);  
    36.   
    37.     action = "";  
    38.   
    39. ///这里ngx_process在master和worker中赋值不同。  
    40.     switch (ngx_process) {  
    41. ///master中。  
    42.     case NGX_PROCESS_MASTER:  
    43.     case NGX_PROCESS_SINGLE:  
    44.         switch (signo) {  
    45.   
    46.         case ngx_signal_value(NGX_SHUTDOWN_SIGNAL):  
    47. ///如果接受到quit信号，则准备退出进程。  
    48.             ngx_quit = 1;  
    49.             action = ", shutting down";  
    50.             break;  
    51.   
    52.         case ngx_signal_value(NGX_TERMINATE_SIGNAL):  
    53.         case SIGINT:  
    54. ///sigint信号，则  
    55.             ngx_terminate = 1;  
    56.             action = ", exiting";  
    57.             break;  
    58.   
    59.         case ngx_signal_value(NGX_NOACCEPT_SIGNAL):  
    60. ///winch信号，停止接受accept。  
    61.             ngx_noaccept = 1;  
    62.             action = ", stop accepting connections";  
    63.             break;  
    64.   
    65.         case ngx_signal_value(NGX_RECONFIGURE_SIGNAL):  
    66. ///sighup信号用来reconfig  
    67.             ngx_reconfigure = 1;  
    68.             action = ", reconfiguring";  
    69.             break;  
    70.   
    71.         case ngx_signal_value(NGX_REOPEN_SIGNAL):  
    72. ///用户信号，用来reopen  
    73.             ngx_reopen = 1;  
    74.             action = ", reopening logs";  
    75.             break;  
    76. ///热代码替换.  
    77.         case ngx_signal_value(NGX_CHANGEBIN_SIGNAL):  
    78.             if (getppid() > 1 || ngx_new_binary > 0) {  
    79.   
    80.                 /* 
    81.                  * Ignore the signal in the new binary if its parent is 
    82.                  * not the init process, i.e. the old binary's process 
    83.                  * is still running.  Or ignore the signal in the old binary's 
    84.                  * process if the new binary's process is already running. 
    85.                  */  
    86. ///上面注释很详细，我就不解释了。。  
    87.                 action = ", ignoring";  
    88.                 ignore = 1;  
    89.                 break;  
    90.             }  
    91. ///正常情况下，需要热代码替换。设置标志位  
    92.             ngx_change_binary = 1;  
    93.             action = ", changing binary";  
    94.             break;  
    95.   
    96.         case SIGALRM:  
    97.             break;  
    98.   
    99.         case SIGIO:  
    100.             ngx_sigio = 1;  
    101.             break;  
    102.   
    103.         case SIGCHLD:  
    104. ///子进程已退出，设置标记。  
    105.             ngx_reap = 1;  
    106.             break;  
    107.         }  
    108.   
    109.         break;  
    110. ///worker的信号处理。worker的比较简单。  
    111.     case NGX_PROCESS_WORKER:  
    112.         switch (signo) {  
    113.   
    114.         case ngx_signal_value(NGX_NOACCEPT_SIGNAL):  
    115.             ngx_debug_quit = 1;  
    116.         case ngx_signal_value(NGX_SHUTDOWN_SIGNAL):  
    117.             ngx_quit = 1;  
    118.             action = ", shutting down";  
    119.             break;  
    120.   
    121.         case ngx_signal_value(NGX_TERMINATE_SIGNAL):  
    122.         case SIGINT:  
    123.             ngx_terminate = 1;  
    124.             action = ", exiting";  
    125.             break;  
    126.   
    127.         case ngx_signal_value(NGX_REOPEN_SIGNAL):  
    128.             ngx_reopen = 1;  
    129.             action = ", reopening logs";  
    130.             break;  
    131.   
    132.  ...............................................  
    133.         }  
    134.   
    135.         break;  
    136.     }  
    137.   
    138. ................................................  
    139.   
    140. ///最终如果信号是sigchld，我们收割僵尸进程(用waitpid)。  
    141.     if (signo == SIGCHLD) {  
    142.         ngx_process_get_status();  
    143.     }  
    144.   
    145.     ngx_set_errno(err);  
    146. }  



    先来看master的主循环，处理其实很简单，就是在循环过程中判断相应的条件，然后进入相应的处理。这里的相关标志位基本都是在上面的信号处理函数中赋值的。：

    Java代码  收藏代码
    1. for ( ;; ) {  
    2. ///delay用来等待子进程退出的时间，由于我们接受到SIGINT信号后，我们需要先发送信号给子进程，而子进程的退出需要一定的时间，超时时如果子进程已退出，我们父进程就直接退出，否则发送sigkill信号给子进程(强制退出),然后再退出。  
    3.         if (delay) {  
    4.             delay *= 2;  
    5. ..............................................  
    6.   
    7.             itv.it_interval.tv_sec = 0;  
    8.             itv.it_interval.tv_usec = 0;  
    9.             itv.it_value.tv_sec = delay / 1000;  
    10.             itv.it_value.tv_usec = (delay % 1000 ) * 1000;  
    11. ///设置定时器。  
    12.             if (setitimer(ITIMER_REAL, &itv, NULL) == -1) {  
    13.                 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,  
    14.                               "setitimer() failed");  
    15.             }  
    16.         }  
    17. ///延时，等待定时器。  
    18.   
    19.         sigsuspend(&set);  
    20.   
    21.         ngx_time_update(0, 0);  
    22.   
    23.         ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "wake up");  
    24.   
    25. ///ngx_reap为1,说明有子进程已经退出。  
    26.         if (ngx_reap) {  
    27.             ngx_reap = 0;  
    28.             ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "reap children");  
    29. ///这个里面处理退出的子进程(有的worker异常退出，这时我们就需要重启这个worker )，如果所有子进程都退出则会返回0.  
    30.             live = ngx_reap_children(cycle);  
    31.         }  
    32.   
    33. ///如果没有存活的子进程，并且收到了ngx_terminate或者ngx_quit信号，则master退出。  
    34.         if (!live && (ngx_terminate || ngx_quit)) {  
    35.             ngx_master_process_exit(cycle);  
    36.         }  
    37. ///收到了sigint信号。  
    38.         if (ngx_terminate) {  
    39. ///设置延时。  
    40.             if (delay == 0) {  
    41.                 delay = 50;  
    42.             }  
    43.   
    44.             if (delay > 1000) {  
    45. ///如果超时，则强制杀死worker  
    46.                 ngx_signal_worker_processes(cycle, SIGKILL);  
    47.             } else {  
    48. ///负责发送sigint给worker，让它退出。  
    49.                 ngx_signal_worker_processes(cycle,  
    50.                                        ngx_signal_value(NGX_TERMINATE_SIGNAL));  
    51.             }  
    52.   
    53.             continue;  
    54.         }  
    55.   
    56. ///收到quit信号。  
    57.         if (ngx_quit) {  
    58. ///发送给worker quit信号  
    59.             ngx_signal_worker_processes(cycle,  
    60.                                         ngx_signal_value(NGX_SHUTDOWN_SIGNAL));  
    61.   
    62.             ls = cycle->listening.elts;  
    63.             for (n = 0; n < cycle->listening.nelts; n++) {  
    64.                 if (ngx_close_socket(ls[n].fd) == -1) {  
    65.                     ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_socket_errno,  
    66.                                   ngx_close_socket_n " %V failed",  
    67.                                   &ls[n].addr_text);  
    68.                 }  
    69.             }  
    70.             cycle->listening.nelts = 0;  
    71.   
    72.             continue;  
    73.         }  
    74.   
    75. ///收到需要reconfig的信号  
    76.         if (ngx_reconfigure) {  
    77.             ngx_reconfigure = 0;  
    78. ///判断是否热代码替换后的新的代码还在运行中(也就是还没退出当前的master)。如果还在运行中，则不需要重新初始化config。  
    79.             if (ngx_new_binary) {  
    80.                 ngx_start_worker_processes(cycle, ccf->worker_processes,  
    81.                                            NGX_PROCESS_RESPAWN);  
    82.                 ngx_start_cache_manager_process(cycle, NGX_PROCESS_RESPAWN);  
    83.                 ngx_noaccepting = 0;  
    84.   
    85.                 continue;  
    86.             }  
    87.   
    88.             ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "reconfiguring");  
    89. ///重新初始化config，并重新启动新的worker  
    90.             cycle = ngx_init_cycle(cycle);  
    91.             if (cycle == NULL) {  
    92.                 cycle = (ngx_cycle_t *) ngx_cycle;  
    93.                 continue;  
    94.             }  
    95.   
    96.             ngx_cycle = cycle;  
    97.             ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx,  
    98.                                                    ngx_core_module);  
    99.             ngx_start_worker_processes(cycle, ccf->worker_processes,  
    100.                                        NGX_PROCESS_JUST_RESPAWN);  
    101.             ngx_start_cache_manager_process(cycle, NGX_PROCESS_JUST_RESPAWN);  
    102.             live = 1;  
    103.             ngx_signal_worker_processes(cycle,  
    104.                                         ngx_signal_value(NGX_SHUTDOWN_SIGNAL));  
    105.         }  
    106. ///这个标志没弄懂有什么意义。代码里面是当热代码替换后，如果ngx_noacceptig被设置了，则设置这个标志位(难道意思是热代码替换前要先停止当前的accept连接？)  
    107.         if (ngx_restart) {  
    108.             ngx_restart = 0;  
    109.             ngx_start_worker_processes(cycle, ccf->worker_processes,  
    110.                                        NGX_PROCESS_RESPAWN);  
    111.             ngx_start_cache_manager_process(cycle, NGX_PROCESS_RESPAWN);  
    112.             live = 1;  
    113.         }  
    114. ///重新打开log  
    115.         if (ngx_reopen) {  
    116.             ngx_reopen = 0;  
    117.             ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "reopening logs");  
    118.             ngx_reopen_files(cycle, ccf->user);  
    119.             ngx_signal_worker_processes(cycle,  
    120.                                         ngx_signal_value(NGX_REOPEN_SIGNAL));  
    121.         }  
    122.   
    123. ///热代码替换  
    124.         if (ngx_change_binary) {  
    125.             ngx_change_binary = 0;  
    126.             ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "changing binary");  
    127. ///进行热代码替换，这里是调用execve来执行新的代码。  
    128.             ngx_new_binary = ngx_exec_new_binary(cycle, ngx_argv);  
    129.         }  
    130. ///接受到停止accept连接，其实也就是worker退出(有区别的是，这里master不需要退出).。  
    131.         if (ngx_noaccept) {  
    132.             ngx_noaccept = 0;  
    133.             ngx_noaccepting = 1;  
    134. ///给worker发送信号。  
    135.             ngx_signal_worker_processes(cycle,  
    136.                                         ngx_signal_value(NGX_SHUTDOWN_SIGNAL));  
    137.         }  
    138.     }  
    139. }  




    然后来看worker的主循环,worker的比较简单。逻辑和master的很相似：

      

    Java代码  收藏代码
      1.  for ( ;; ) {  
      2. ///ngx_exiting是当收到master的quit命令后，设置为1,然后等待其他资源退出。  
      3.         if (ngx_exiting) {  
      4.   
      5.             c = cycle->connections;  
      6. .............................................  
      7. ///定时器超时则退出worker  
      8.             if (ngx_event_timer_rbtree.root == ngx_event_timer_rbtree.sentinel)  
      9.             {  
      10.                 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exiting");  
      11.   
      12.                 ngx_worker_process_exit(cycle);  
      13.             }  
      14.         }  
      15.   
      16.         ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "worker cycle");  
      17.   
      18.         ngx_process_events_and_timers(cycle);  
      19.   
      20. ///收到shutdown命令则worker直接退出  
      21.         if (ngx_terminate) {  
      22.             ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exiting");  
      23.   
      24.             ngx_worker_process_exit(cycle);  
      25.         }  
      26.   
      27. ///收到quit命令  
      28.         if (ngx_quit) {  
      29.             ngx_quit = 0;  
      30.             ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0,  
      31.                           "gracefully shutting down");  
      32.             ngx_setproctitle("worker process is shutting down");  
      33.   
      34.             if (!ngx_exiting) {  
      35. ///关闭socket，然后设置退出标志。  
      36.                 ngx_close_listening_sockets(cycle);  
      37.                 ngx_exiting = 1;  
      38.             }  
      39.         }  
      40.   
      41. ///收到master重新打开log的命令。  
      42.         if (ngx_reopen) {  
      43.             ngx_reopen = 0;  
      44.             ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "reopening logs");  
      45.             ngx_reopen_files(cycle, -1);  
      46.         }  
      47.     }  
  • 相关阅读:
    BestCoder Round #71 (div.2) （hdu 5621）
    BestCoder Round #71 (div.2) （hdu 5620 菲波那切数列变形）
    BestCoder Round #69 (div.2) Baby Ming and Weight lifting（hdu 5610）
    BestCoder Round #70 Jam's math problem（hdu 5615）
    BestCoder Round #68 (div.2) tree（hdu 5606）
    poj 2299 Ultra-QuickSort(归并排序或是bit 树+离散化皆可)
    hdu 3874 Necklace(bit树+事先对查询区间右端点排序)
    HDU 4300 Clairewd’s message(KMP)
    HDU 3308 LCIS(线段树单点更新区间合并）
    PKU 3667 Hotel(线段树）
  • 原文地址：https://www.cnblogs.com/rosekin/p/3804026.html
Copyright © 2011-2022 走看看