接上文。
nginx以单进程在console运行起来,阅读core/nginx.c中的main方法,前面都是初始化的代码,先不仔细看,容易陷入细致魔戒。直接找到ngx_single_process_cycle的定义,在os/unix/ngx_process_cycle.c中。
在第一个for循环中添加如下代码:
for (i = 0;
ngx_modules[i];
i++) {
char * p = NULL;
if (ngx_modules[i]->commands != NULL)
{
p = ngx_modules[i]->commands->name.data;
}
if (ngx_modules[i]->init_process) {
if (ngx_modules[i]->init_process(cycle) == NGX_ERROR) {
/* fatal */
exit(2);
}
printf("[ngx_process_cycle] module ctx_index=%d index=%d name=%s init process\n", ngx_modules[i]->ctx_index, ngx_modules[i]->index, p);
}
else
{
printf("[ngx_process_cycle] module ctx_index=%d index=%d name=%s\n", ngx_modules[i]->ctx_index, ngx_modules[i]->index, p);
}
}
printf("[ngx_process_cycle] for ngx_modules init done\n");
作用是打印当前nginx中有哪些模块和相关的索引、名字。
在第二个for循环中,主要就是ngx_process_events方法,查找发现这是一个宏,然后这个宏又是一个全局变量,因为我们加载的epoll模块,所以在event/modules/ngx_epoll_module.c
中找到代码:
ngx_event_actions = ngx_epoll_module_ctx.actions;
发现ngx_process_events方法其实就是ngx_epoll_module_ctx模块中的actions中的ngx_epoll_process_events方法。在这个方法中找到epoll_wait方法被调用的地方,加上如下代码:
printf("[ngx_epoll_module] epoll wait\n");
events = epoll_wait(ep, event_list, nevents, timer);
printf("[ngx_epoll_module] epoll wait ---\n");
重新make运行结果:
[main] to start ngx_single_process_cycle发现共有25个模块,只有connections模块有init_process方法,还有一些模块name为空。最后程序进入到epoll模块,阻塞在epoll_wait调用处,CTRL+C推出后才执行了后面的打印语句。
[ngx_process_cycle] module ctx_index=0 index=0 name=daemon
[ngx_process_cycle] module ctx_index=0 index=1 name=error_log
[ngx_process_cycle] module ctx_index=0 index=2 name=include
[ngx_process_cycle] module ctx_index=0 index=3 name=events
[ngx_process_cycle] module ctx_index=0 index=4 name=connections init process
[ngx_process_cycle] module ctx_index=1 index=5 name=rtsig_signo
[ngx_process_cycle] module ctx_index=2 index=6 name=epoll_events
[ngx_process_cycle] module ctx_index=0 index=7 name=http
[ngx_process_cycle] module ctx_index=0 index=8 name=server
[ngx_process_cycle] module ctx_index=1 index=9 name=log_format
[ngx_process_cycle] module ctx_index=2 index=10 name=(null)
[ngx_process_cycle] module ctx_index=3 index=11 name=index
[ngx_process_cycle] module ctx_index=4 index=12 name=allow
[ngx_process_cycle] module ctx_index=5 index=13 name=rewrite
[ngx_process_cycle] module ctx_index=6 index=14 name=proxy_pass
[ngx_process_cycle] module ctx_index=7 index=15 name=(null)
[ngx_process_cycle] module ctx_index=8 index=16 name=(null)
[ngx_process_cycle] module ctx_index=9 index=17 name=(null)
[ngx_process_cycle] module ctx_index=10 index=18 name=(null)
[ngx_process_cycle] module ctx_index=11 index=19 name=gzip
[ngx_process_cycle] module ctx_index=12 index=20 name=charset_map
[ngx_process_cycle] module ctx_index=13 index=21 name=userid
[ngx_process_cycle] module ctx_index=14 index=22 name=expires
[ngx_process_cycle] module ctx_index=15 index=23 name=output_buffers
[ngx_process_cycle] module ctx_index=16 index=24 name=(null)
[ngx_process_cycle] module ctx_index=17 index=25 name=(null)
[ngx_process_cycle] for ngx_modules init done
[ngx_epoll_module] epoll wait
^C[ngx_epoll_module] epoll wait —
这里可以仔细看一下nginx对模块的定义, 看代码的时候容易发现nginx里实际用的类型都以_t结尾,而如果这个类型定义的时候如果是结构体则实际类型都以_s结尾,nginx_module_s的定义在core/ngx_conf_file.h文件中:
struct ngx_module_s {
ngx_uint_tctx_index;
ngx_uint_tindex;
void*ctx;
ngx_command_t*commands;
ngx_uint_ttype;
ngx_int_t(*init_module)(ngx_cycle_t *cycle);
ngx_int_t(*init_process)(ngx_cycle_t *cycle);
#if 0
ngx_int_t(*init_thread)(ngx_cycle_t *cycle);
#endif
};
其中有两个索引号,还有命令和3个函数,具体什么含义以后用到再看。
还有另外两个结构体ngx_event_module_t和ngx_event_actions_t; 后者是前者的成员;前者就是nginx事件模块,但是抽象的,具体到某个平台上会有不同的类型,此处为epoll。
ngx_event_module_t如下:
typedef struct {
ngx_str_t*name;
void*(*create_conf)(ngx_cycle_t *cycle);
char*(*init_conf)(ngx_cycle_t *cycle, void *conf);
ngx_event_actions_tactions;
} ngx_event_module_t;
epoll实例如下:
ngx_event_module_tngx_epoll_module_ctx = {
&epoll_name,
ngx_epoll_create_conf,/* create configuration */
ngx_epoll_init_conf,/* init configuration */{
ngx_epoll_add_event,/* add an event */
ngx_epoll_del_event,/* delete an event */
ngx_epoll_add_event,/* enable an event */
ngx_epoll_del_event,/* disable an event */
ngx_epoll_add_connection,/* add an connection */
ngx_epoll_del_connection,/* delete an connection */
NULL,/* process the changes */
ngx_epoll_process_events,/* process the events */
ngx_epoll_init,/* init the events */
ngx_epoll_done,/* done the events */
}
};
正好ngx_event_module_t中的actions成员在ngx_epoll_module_ctx中定义为与epoll相关的一些函数,而前面的ngx_process_events则是由下面的两行代码串联起来的:
event/ngx_event.h中
#define ngx_process_eventsngx_event_actions.process_events
【网络编程|nginx 源码(4)主流程】event/modules/ngx_epoll_module.c中
ngx_event_actions = ngx_epoll_module_ctx.actions;
ngx_event_actions作为全局变量定义在event/ngx_event.c中:
ngx_event_actions_tngx_event_actions;
接下来看一下epoll在nginx中的使用。
to be continued …
推荐阅读
- Go|Docker后端部署详解(Go+Nginx)
- 后台|NATAPP内网穿透通过nginx实现一个端口访问多个不同端口服务
- nginx-1.20.2安装使用
- NGINX 创始人 Igor Sysoev 退出 F5(20 年发展“简史”令人肃然起敬)
- 日记博文|几种网络编程方式的比较
- Android源码|okhttp源码分析(一)——基本流程(超详细)
- Android|App启动(一)Application的创建
- Nginx|Nginx~从入门到入坑。
- Android|Flutter的绘制流程简述
- C++|浅析boost::asio::deadline_timer运行机制