ngx_http_wait_request_handler函数解析

2434t

在普通的http请求过程中，ngx_event_accept函数中ls->handler(c);调用了ngx_http_init_connection函数，ngx_http_init_connection函数会调用ngx_http_wait_request_handler。主要代码和解析如下。

查看事件是否已过期，如果已过期，直接断开连接

1 2 3 4 5

if (rev->timedout) {     ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out");     ngx_http_close_connection(c);     return; }

调用recv函数，接收数据。函数原型在ngx_recv.c中定义，根据是否使用kqueue（一种i/o复用技术），有两种函数定义。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16

n = c->recv(c, b->last, size); if (n == NGX_AGAIN) {     尚未有数据道来，由于Nginx的事件驱动机制，程序不会阻塞，注册读事件并返回。     if (ngx_handle_read_event(rev, 0) != NGX_OK)     {         ngx_http_close_connection(c);         return;     }     连接有可能什么实质性工作都不做，所以暂且释放内存。     if (ngx_pfree(c->pool, b->start) == NGX_OK)     {         b->start = NULL;     }     return; }

recv函数返回了错误，直接断开连接并返回。

1 2 3 4

if (n == NGX_ERROR) {     ngx_http_close_connection(c);     return; }

client主动断开了连接。

1 2 3 4 5 6

if (n == 0) {     ngx_log_error(NGX_LOG_INFO, c->log, 0,                   "client closed connection");     ngx_http_close_connection(c);     return; }

如果有类似于“listen 80 proxy_protocol;”的配置，尚未仔细研究

1 2 3 4

if (hc->proxy_protocol) {         ... } ngx_reusable_connection(c, 0);

调用ngx_http_create_request函数初始化一个ngx_http_request_t结构体。

1 2 3 4 5

c->data = ngx_http_create_request(c); if (c->data == NULL) {     ngx_http_close_connection(c);     return; }

将目标连接的读事件回调函数设置为处理处理请求行

1	rev->handler = ngx_http_process_request_line;

获取已经有数据到达，所以马上执行处理请求行函数，在ngx_http_process_request_line中循环调用recv函数，从缓冲区中取东西出来。ngx_thttp_process_request_line函数可能会被调用多次。

1	ngx_http_process_request_line(rev);