nginx处理http请求流程
监听套接字ngx_listenting_t->fd由获取accept_mutex的worker进程加入epoll监控,其handler为ngx_event_accept;
注:每个fd赋予一个ngx_connection_t,且c->read->handler = ngx_event_accept(详见ngx_event_process_init);
当客户端发起新连接时,epoll_wait返回,将其加入accepted队列,然后调用ngx_event_accept处理;
接受完客户端连接后,立即调用ngx_listening_t->handler,即ngx_http_init_connection;
ngx_http_init_connection
将当前连接的读事件revent->handler设置为ngx_http_init_request;
将当前连接的读事件revent加入定时器,超时时间为client_header_timeout;
将当前连接的读事件revent加入epoll监控;
注:当连接第一次出现可读事件时,才会调用ngx_http_init_request
ngx_http_init_request
检查是否超时client_header_timeout;
创建ngx_http_request_t,
将revent->handler重置为ngx_http_process_request_line;
创建读缓冲区client_header_buffer_size && ngx_http_request_t内存池
为ngx_http_request_t->ctx分配ngx_http_max_module个成员的指针数组(注1);
调用ngx_http_process_request_line;
ngx_http_process_request_line
接收请求行,格式为: 请求方法 uri http版本;
可调用多次;
执行完毕后将revent->handler重置为ngx_http_process_request_headers;
ngx_http_process_request_headers
解析请求头;
调用ngx_http_process_request处理http请求;
ngx_http_process_request
把读事件从定时器移除,无需再接受http请求头;
将当前连接读事件c->read->handler设置为ngx_http_request_handler;
检查ngx_http_request_t->internal,为1表示需要跳转,将phase_handler改为server_rewrite_index,即调用NGX_HTTP_SERVER_REWRITE_PHASE阶段的handler;
设置ngx_http_request_t->write_event_handler = ngx_http_core_run_phases;
调用ngx_http_core_run_phases;
执行post子请求;
问1:nginx拥有众多http模块,如何将其整合并确保http请求会用到相应模块?
nginx将http请求划分11个阶段,每一阶段可包含多个http模块,每个模块handler运行结果决定下一个模块;
每个http阶段由ngx_http_phase_handler_s描述,包含3个成员:checker,handler以及 next;
Nginx不允许直接调用http模块的handler,而是通过提供的checker封装调用,共有7个http请求阶段实现了checker(4个),也就是说只有这7个阶段允许第3方模块注册;
Nginx初始化时,调用每个http模块的ngx_http_module_t->postconfiguration将自身的handler加入cmcf->phases(二维数组);
然后通过ngx_http_init_phase_handlers()将cmcf->phases重组为一维数组cmcf->phase_engine.handlers,此时所有的ngx_http_phase_handler_s都位于其中;
一个http请求经过解析请求行和请求头后,最终调用ngx_http_core_run_phases,其以http请求的phase_handler为下标,尝试遍历cmcf->phase_engine.handlers (可能因为处理结果提前返回)
ngx_http_core_run_phases(ngx_http_request_t *r)
{
ngx_int_t rc;
ngx_http_phase_handler_t *ph;
ngx_http_core_main_conf_t *cmcf;
cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
ph = cmcf->phase_engine.handlers;
while (ph[r->phase_handler].checker) {
rc = ph[r->phase_handler].checker(r, &ph[r->phase_handler]);
if (rc == NGX_OK) {
return;
}
}
}
以上是接受客户端连接,并根据http请求行和请求头执行相应http模块,http请求可能还有包体,由http模块负责处理;
一般有两种方法: 1 接收包体并存入内存或文件; 2 接收包体后直接丢弃;
注1: http请求上下文
Nginx采用全异步机制,一个http请求可能要多次调度http模块才能完成,需要上下文结构体保存处理过程的中间状态;
一个http请求对应每个http模块都有一个独立的上下文结构体,由ngx_http_request_t -> ** ctx保存;
每个模块上下文结构体各异,通常在http请求第一次调用handler时分配;
Nginx提供两个宏用于获取和设置上下文
#define ngx_http_get_module_ctx(r,module) (r)->ctx[module.ctx_index]
#define ngx_http_set_ctx(r, c, module) r->ctx[module.ctx_index] = c;
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。