从应用程序的启动过程中main功能开始跟踪。
解析命令行參数并保存到ngx_cycle_t结构体中&＃xff0c;在ngx_process_options函数中将保存配置文件路径。
调用ngx_add_inherited_sockets函数获取环境变量中关于平滑升级的一些信息。平滑升级时&＃xff0c;旧的master进程会通过环境变量发送传递一些信息给新的master进程&＃xff0c;新的master进程启动后要去环境变量中取得这些信息&＃xff0c;这就是这个函数的作用。
调用ngx_init_cycle初始化ngx_cycle_t结构体&＃xff0c;当中包含&＃xff1a;
假设配置文件设为单进程工作模式&＃xff08;master_process为off&＃xff09;&＃xff0c;将调用ngx_single_process_cycle函数。在该函数中调用全部模块的init_process方法&＃xff0c;该方法保存在ngx_module_t->init_process函数指针中。系统进入单进程模循环工作。
假设配置文件设为master-worker工作模式&＃xff08;master_process为on&＃xff09;&＃xff0c;则调用ngx_master_process_cycle函数。该函数fork&＃xff08;封装在ngx_start_worker_processes函数中&＃xff09;出work子进程。work进程会进入ngx_worker_process_cycle函数。该函数首先调用ngx_worker_process_init方法&＃xff0c;后者调用全部模块的init_process方法。然后work进程在ngx_worker_process_cycle中循环工作。
再来一张总体流程图&＃xff1a;
worker进程工作流程
worker进程在ngx_worker_process_cycle函数的for循环中不断执行。它检查四个标志位&＃xff1a;
- ngx_terminate&＃xff1a;表示强制关闭进程。由信号处理函数ngx_signal_handler函数置1.
- ngx_quit&＃xff1a;表示优雅关闭进程&＃xff0c;由信号处理函数ngx_signal_handler函数置1.
- ngx_reopen&＃xff1a;表示又一次打开文件&＃xff0c;由信号处理函数ngx_signal_handler函数置1.
- ngx_exiting&＃xff1a;表示将要退出进程&＃xff0c;仅在为0且ngx_quit被置的情况下置1.
标志位和信号相应关系例如以下图&＃xff1a;
worker进程通过检查以上四个标志位来决定程序运行流。我把整个函数做了简化。代码例如以下&＃xff1a;
static void
ngx_worker_process_cycle(ngx_cycle_t *cycle, void *data)
{ngx_int_t worker &＃61; (intptr_t) data;ngx_uint_t i;ngx_connection_t *c;/* 该函数内会调用全部模块的init_process方法 */ngx_worker_process_init(cycle, worker);...for ( ;; ){/* 退出进程标识 */if (ngx_exiting){c &＃61; cycle->connections;/* 关闭全部连接 */for (i &＃61; 0; i connection_n; i&＃43;&＃43;){if (c[i].fd !&＃61; -1 && c[i].idle){c[i].close &＃61; 1; /* close标识置1 */c[i].read->handler(c[i].read); /* 调用读事件处理方法 */}}if (ngx_event_timer_rbtree.root &＃61;&＃61; ngx_event_timer_rbtree.sentinel){/* 红黑树为空&＃xff0c;已经处理全然部事件。调用全部模块的exit_process方法 */ngx_worker_process_exit(cycle);}}/* 还有事件须要处理&＃xff0c;继续向下运行 */ngx_process_events_and_timers(cycle); /* 处理事件&＃xff0c;事件模块核心方法 *//* 强制关闭进程 */if (ngx_terminate)ngx_worker_process_exit(cycle); /* 直接调用全部模块的exit_process方法退出worker进程 *//* 优雅的关闭连接 */if (ngx_quit){ngx_quit &＃61; 0;ngx_setproctitle("worker process is shutting down"); /* 改动进程名字 */if (!ngx_exiting){ngx_close_listening_sockets(cycle); /* 关闭监听句柄 */ngx_exiting &＃61; 1; /* ngx_exiting标识唯一被改动的地方 */}}if (ngx_reopen){/* 又一次打开全部文件 */ngx_reopen &＃61; 0;ngx_reopen_files(cycle, -1);}}
}
流程图例如以下&＃xff1a;
master进程工作流程
master进程在函数ngx_master_process_cycle中不断循环。它不处理网络事件&＃xff0c;它仅仅是管理worker子进程。
和worker进程类似。master通过监控七个标志位来决定程序运行流。这七个标志位例如以下所看到的&＃xff1a;
下面是经过简化的ngx_master_process_cycle函数&＃xff1a;
void
ngx_master_process_cycle(ngx_cycle_t *cycle)
{.../* 依据配置文件启动worker_processes个work子进程 */ngx_start_worker_processes(cycle, ccf->worker_processes,NGX_PROCESS_RESPAWN);/* master进程 */for ( ;; ){sigsuspend(&set); /* 堵塞&＃xff0c;等待信号 */if (ngx_reap){ngx_reap &＃61; 0;/* 监控全部子进程&＃xff0c;又一次启动非正常退出的子进程 */live &＃61; ngx_reap_children(cycle);}/* live为0表示全部子进程已经退出 */if (!live && (ngx_terminate || ngx_quit)){/* 满足上述条件&＃xff0c;退出master进程&＃xff0c;包含&＃xff1a;* 1、删除存储进程的pid文件* 2、调用全部模块的exit_master方法* 3、关闭监听port* 4、销毁内存池*/ngx_master_process_exit(cycle);}if (ngx_terminate) /* 强制关闭 */{if (delay > 1000){ngx_signal_worker_processes(cycle, SIGKILL); /* SIGKILL &＃61; 9 */}else{/* NGX_TERMINATE_SIGNAL &＃61; TERM &＃61; 15* 向每一个子进程发送TERM信号*/ngx_signal_worker_processes(cycle,ngx_signal_value(NGX_TERMINATE_SIGNAL));}continue; /* 跳上去挂起 */}if (ngx_quit) /* 优雅的退出。向全部子进程发送QUIT信号 */{ngx_signal_worker_processes(cycle,ngx_signal_value(NGX_SHUTDOWN_SIGNAL)); /* NGX_SHUTDOWN_SIGNAL &＃61; QUIT */ls &＃61; cycle->listening.elts;/* 关闭全部port */for (n &＃61; 0; n listening.nelts; n&＃43;&＃43;)ngx_close_socket(ls[n].fd)&＃xff1b;cycle->listening.nelts &＃61; 0;continue; /* 跳上去挂起 */}if (ngx_reconfigure) /* 须要又一次读取配置文件 */{/* 又一次读取配置文件后&＃xff0c;生成新的worker进程&＃xff0c;销毁旧的worker进程 */ngx_reconfigure &＃61; 0;cycle &＃61; ngx_init_cycle(cycle); /* 又一次配置ngx_cycle_t结构体 */ngx_cycle &＃61; cycle;ccf &＃61; (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx, ngx_core_module);/* 又一次派生子进程 */ngx_start_worker_processes(cycle, ccf->worker_processes, NGX_PROCESS_JUST_RESPAWN);ngx_start_cache_manager_processes(cycle, 1);live &＃61; 1; /* 表示有子进程在执行 *//* 向旧的子进程发送QUIT信号&＃xff0c;要求它们退出 */ngx_signal_worker_processes(cycle, ngx_signal_value(NGX_SHUTDOWN_SIGNAL));}if (ngx_restart) /* 重新启动work进程 */{ngx_restart &＃61; 0;ngx_start_worker_processes(cycle, ccf->worker_processes, NGX_PROCESS_RESPAWN);ngx_start_cache_manager_processes(cycle, 0);live &＃61; 1; /* 表示有子进程在执行 */}if (ngx_reopen) /* 又一次打开全部文件 */{ngx_reopen &＃61; 0;ngx_reopen_files(cycle, ccf->user);/* 向全部子进程发送USR1信号&＃xff0c;要求每一个子进程又一次打开文件 */ngx_signal_worker_processes(cycle, ngx_signal_value(NGX_REOPEN_SIGNAL));}if (ngx_change_binary) /* 平滑升级 */{ngx_change_binary &＃61; 0;ngx_new_binary &＃61; ngx_exec_new_binary(cycle, ngx_argv); /* 新的子进程启动新版本号的Nginx */}if (ngx_noaccept) /* 优雅的关闭服务 */{ngx_noaccept &＃61; 0;ngx_noaccepting &＃61; 1;/* 向全部子进程发送QUIT信号&＃xff0c;要求它们优雅的关闭服务 */ngx_signal_worker_processes(cycle, ngx_signal_value(NGX_SHUTDOWN_SIGNAL));}}
}
流程图例如以下&＃xff1a;
參考&＃xff1a;
《深入理解Nginx》 P275-P286.
版权声明&＃xff1a;本文博主原创文章&＃xff0c;博客&＃xff0c;未经同意不得转载。
京公网安备 11010802041100号