nginx的worker-master启动之worker进程

嗯，这篇文章主要讲worker进程，从哪里开始讲呢，在上面的文章我们已经知道在master进程中会调用start_worker_process函数开启worker进程，在该函数中会调用ngx_spawn_process函数真正的创建worker进程，那么就从ngx_spawn_process函数开始吧（src/os/unix/Ngx_process.c）：

其实函数还是比较简单的，首先是：//找到ngx_processes中一个空闲的位置，用来放置fork出来的进程的信息
if (respawn >= 0) {
s = respawn;

} else {
for (s = 0; s < ngx_last_process; s++) {
if (ngx_processes[s].pid == -1) {
break;
}
}
//达到最大的进程限制了
if (s == NGX_MAX_PROCESSES) {
ngx_log_error(NGX_LOG_ALERT, cycle->log, 0,
"no more than %d processes can be spawned",
NGX_MAX_PROCESSES);
return NGX_INVALID_PID;
}
}
这部分代码主要是在全局变量ngx_processes中找到一个空闲的位置，用来保存待会创建的子进程的信息。

接下来的部分是创建socketpair，用于进程间的通信，这里就不细写了，以后写进程间通信的部分再写吧。好吧接下来就是等了好久的fork函数了： pid = fork();

switch (pid) {

case -1:
ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
"fork() failed while spawning \"%s\"", name);
ngx_close_channel(ngx_processes[s].channel, cycle->log);
return NGX_INVALID_PID;

case 0: //子进程，开始执行它的函数
ngx_pid = ngx_getpid();
proc(cycle, data); //执行work进程的进程函数
break;

default:
break;
}
子进程直接运行传进来的worker进程的运行函数即可了，该函数为ngx_worker_process_cycle，定义在Ngx_process_cycle.c当中，现在来看这个函数吧，好吧，首先是一句代码：

ngx_process = NGX_PROCESS_WORKER;   //修改该子进程全局变量ngx_process的值表示为worker进程

这里用来表示当前进程是worker进程。

worker进程的运行函数首先会调用ngx_worker_process_init函数初始化，那么还是先看这个函数吧。
其实这个函数重要的代码页没多少，首先是获取ngx_core_module模块的配置，然后通过它设置一些类似于优先级的东西。然后又一段比较重要的代码：//在这里进行各个模块的初始化，这样保证每一个fork出来的子进程都可以访问模块
for (i = 0; ngx_modules[i]; i++) {
if (ngx_modules[i]->init_process) {
if (ngx_modules[i]->init_process(cycle) == NGX_ERROR) {
/* fatal */
exit(2);
}
}
}
因为这里已经是在worker子进程当中运行了，所以每个子进程都会从master进程中继承全局变量ngx_modules，当然还有许多的其他变量。这里会循环遍历所有的模块，调用它们的init_process函数，这样可以保证它们在当前worker进程中可以用，ngx_worker_process_init剩下的代码就是关于设置进程间通信的了，以后再说。

现在回到ngx_worker_process_cycle函数，当初始化完成了以后，那么就可以直接进入worker进程的主循环了，处理一些从master传过来的命令，具体命令式怎么传过来的以后再讲。接着解释调用很重要的函数ngx_process_events_and_timers来处理所有的事件以及定时。

好了，worker进程也差不多了，下面的文章讲进程间的通信。