nginx守护进程worker

cheng029

本文着手分析一下Nginx的worker进程的情况。

首先找到worker进程的入口地方—— ngx_worker_process_cycle。这个函数不光是worker进程的入口函数，同时也是worker进程循环工作的主体函数，看函数名含有一个cycle嘛。进入这个cycle函数，第一件事就是调用ngx_worker_process_init(cycle, 1);对worker进程进行初始化操作。先看看这个worker进程的初始化过程。

ngx_process = NGX_PROCESS_WORKER;
if (ngx_set_environment(cycle, NULL) == NULL) {

exit(2);
}

进入初始化就将全局变量ngx_process设置为worker进程的标志，由于这个变量是从master进程复制过来的，所以没设置前就是master进程的标志。然后设置相应的环境变量。接下去就是设置了一些列的资源限制，id等玩意，这里就忽略代码了。

for (i = 0; ngx_modules; i++) {
if (ngx_modules->init_process) {
if (ngx_modules->init_process(cycle) == NGX_ERROR) {

exit(2);
}
}
}

此处循环调用每个模块的init_process，完成每个模块自定义的进程初始化操作，一般在模块定义的时候设置这个回调指针的值，即注册一个函数给它。做模块开发的时候，貌似使用得挺少的，遇到的时候好好关注下。

for (n = 0; n < ngx_last_process; n++) {


if (ngx_processes[n].pid == -1) {
continue;
}

if (n == ngx_process_slot) {
continue;
}

if (ngx_processes[n].channel[1] == -1) {
continue;
}

if (close(ngx_processes[n].channel[1]) == -1) {
ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
"close() channel failed");
}
}

if (close(ngx_processes[ngx_process_slot].channel[0]) == -1) {
ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
"close() channel failed");
}

针对这段代码采用直接注释代码的方式进行分析，感觉挺自然的，还不错，以后碰到比较长的代码段都采用这种方式进行了。

if (ngx_add_channel_event(cycle, ngx_channel, NGX_READ_EVENT,
ngx_channel_handler)
== NGX_ERROR)
{

exit(2);
}

ngx_channel就是worker进程channel的读端，这里调用ngx_add_channel_event将channel放入 Nginx关心的集合中，同时关注起这个channel上的读事件，也即这个channel上有数据到来后，就立马采取读channel操作。此处的添加一个channel的读事件是worker进程初始化的关键之处。到此，初始化过程就结束了，回到worker循环主体看看吧。

for ( ;; ) {

if (ngx_exiting) {
c = cycle->connections;

for (i = 0; i connection_n; i++) {

if (c.fd != -1 && c.idle) {
c.close = 1;
c.read->handler(c.read);
}
}


if (ngx_event_timer_rbtree.root == ngx_event_timer_rbtree.sentinel)
{
ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exiting");
ngx_worker_process_exit(cycle);
}
}
ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "worker cycle");

ngx_process_events_and_timers(cycle);

if (ngx_terminate) {
ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exiting");
ngx_worker_process_exit(cycle);
}


if (ngx_quit) {
ngx_quit = 0;
ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0,
"gracefully shutting down");
ngx_setproctitle("worker process is shutting down");
if (!ngx_exiting) {
ngx_close_listening_sockets(cycle);
ngx_exiting = 1;
}
}

if (ngx_reopen) {
ngx_reopen = 0;
ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "reopening logs");
ngx_reopen_files(cycle, -1);
}
}

通过上述分析发现worker进程的cycle比master简单不少啊，到此，worker进程的大体框架就差不多了。下一篇计划分析master和worker间的channel通信。

plantegg

有竞争才有进步嘛

lihu129c

男人与女人,终究也只是欲望的动物吧!真的可以因为爱而结合吗?对不起,我也不知道。。

zhltom

勃起不是万能的，但不能勃起却是万万都不能的!

wdx1992828

只要不下流，我们就是主流!

my11502207

人生不能像做菜、把所有的料都准备好才下锅!

zhouying23

站的更高，尿的更远。