ngx_http_process_request_line函数解析

处理请求行,一般的http请求过程中,ngx_http_process_request_line函数被ngx_http_wait_request_handler调用,并且在ngx_http_wait_request_handler中被设置为读事件的回调函数。在连接被accept之后,有数据到达之后会执行ngx_http_create_request函数,之后再有读事件被触发时被调用的回调函数就是ngx_http_process_request_line。主要代码和解析如下。

判断是否超时,如果超时,报错并且结束请求。

if (rev->timedout) {
    ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out");
    c->timedout = 1;
    ngx_http_close_request(r, NGX_HTTP_REQUEST_TIME_OUT);
    return;
}

剩下的过程全部在一个for(;;){...}块中执行。

ngx_http_read_request_header函数如果返回NGX_AGAIN,说明尚有数据未接受完,读事件还会被触发,而且读事件回调函数依然是ngx_http_process_request_line。如果返回NGX_ERROR,说明出问题了,需要结束请求。正常的话,ngx_http_read_request_header返回了接受到的字符个数,并且说明已经接受完了。

if (rc == NGX_AGAIN) {
    n = ngx_http_read_request_header(r);
    if (n == NGX_AGAIN || n == NGX_ERROR) {
        return;
    }
}

ngx_http_read_request_header函数将接受到的内容存到了r->header_in,接下来ngx_http_parse_request_line函数解析请求行。ngx_http_parse_request_line函数有可能返回的结果有三类,一类是NGX_OK,一类是INVALID相关的,另一类是NGX_AGAIN,下面分类进行分析。

rc = ngx_http_parse_request_line(r, r->header_in);

按照代码的顺序,首先是返回了NGX_OK,返回NGX_OK说明请求行已经完整的接受并解析,主要代码如下。

if (rc == NGX_OK) {

根据请求行解析结果初始化r结构体

    r->request_line.len = r->request_end - r->request_start;
    r->request_line.data = r->request_start;
    r->request_length = r->header_in->pos - r->request_start;
    r->method_name.len = r->method_end - r->request_start + 1;
    r->method_name.data = r->request_line.data;
    if (r->http_protocol.data) {
        r->http_protocol.len = r->request_end - r->http_protocol.data;
    }

解析uri,函数中主要初始化了r结构体中的uri和args相关的变量,并且判断了请求行中是否存在非法字符。

    if (ngx_http_process_request_uri(r) != NGX_OK) {
        return;
    }

关于host_start和host_end在ngx_http_parse_request_line函数中有可能被赋值。如果在本机起一个nginx,监听80端口,用curl工具发送这样一条请求:curl -x 127.0.0.1:80 http://192.168.119.51:80/test.html。如果GDB调试的话可以看到请求行是:GET http://192.168.119.51:80/test.html HTTP/1.1xxxxxx。而非常见的GET /test.html HTTP/1.1xxxxxx。个人认为这是为了兼容http 0.9。此时上述两个变量就不是0x0了。在淘宝团队的nginx博客中是这样描述的:请求行的uri里面包含了域名部分。本人也理解的不是很透彻。

    if (r->host_start && r->host_end) {
        host.len = r->host_end - r->host_start;
        host.data = r->host_start;
        rc = ngx_http_validate_host(&host, r->pool, 0);
        if (rc == NGX_DECLINED) {
            ngx_log_error(NGX_LOG_INFO, c->log, 0,
                          "client sent invalid host in request line");
            ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
            return;
        }
        if (rc == NGX_ERROR) {
            ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
            return;
        }
        if (ngx_http_set_virtual_server(r, &host) == NGX_ERROR) {
            return;
        }
        r->headers_in.server = host;
    }

http0.9不需要解析请求头,直接处理请求即可。r->headers_in.server变量是在上一个if块中被赋值的。http0.9的请求不知道怎么模拟。。。

    if (r->http_version < NGX_HTTP_VERSION_10) {
        if (r->headers_in.server.len == 0
            && ngx_http_set_virtual_server(r, &r->headers_in.server)
               == NGX_ERROR)
        {
            return;
        }
        ngx_http_process_request(r);
        return;
    }
    if (ngx_list_init(&r->headers_in.headers, r->pool, 20,
                      sizeof(ngx_table_elt_t))
        != NGX_OK)
    {
        ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
        return;
    }
    c->log->action = "reading client request headers";

设置读事件回调函数,再有数据到达时调用请求头处理函数。当前可能已经收到了请求头数据,所以马上执行一次。

    rev->handler = ngx_http_process_request_headers;
    ngx_http_process_request_headers(rev);
    return;
}

ngx_http_parse_request_line函数返回结果如果不是NGX_OK,也不是NGX_AGAIN,那就一定是INVALID相关的,需要返回错误并且结束请求。

if (rc != NGX_AGAIN) {
    ngx_log_error(NGX_LOG_INFO, c->log, 0,
                  ngx_http_client_errors[rc - NGX_HTTP_CLIENT_ERROR]);
    ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
    return;
}

最后只剩下ngx_http_parse_request_line函数返回NGX_AGAIN的情况了。需要判断是否请求头部过大,过大的话就要开辟更大的buffer继续处理ngx_http_parse_request_line函数。

if (r->header_in->pos == r->header_in->end) {
    rv = ngx_http_alloc_large_header_buffer(r, 1);
    if (rv == NGX_ERROR) {
        ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
        return;
    }
    if (rv == NGX_DECLINED) {
        r->request_line.len = r->header_in->end - r->request_start;
        r->request_line.data = r->request_start;
        ngx_log_error(NGX_LOG_INFO, c->log, 0,
                      "client sent too long URI");
        ngx_http_finalize_request(r, NGX_HTTP_REQUEST_URI_TOO_LARGE);
        return;
    }
}
时间: 2024-10-18 07:18:33

ngx_http_process_request_line函数解析的相关文章

ngx_http_process_request_headers函数解析

ngx_http_process_request_headers函数被ngx_http_process_request_line函数调用,将请求头逐个放到r->headers_in.headers结构体中.由于不确定请求中一共有多少个header,所以这个函数主要功能也是在for(;;){}循环中完成,一下所有的代码都是在上述循环内部的.主要代码和解析如下: 判断是否超时,如果超时,报错并结束请求.    if (rev->timedout) {        ngx_log_error(NG

AngularJS指令中的compile与link函数解析

AngularJS指令中的compile与link函数解析 通常大家在使用ng中的指令的时候,用的链接函数最多的是link属性,下面这篇文章将告诉大家complie,pre-link,post-link的用法与区别. 原文地址 angularjs里的指令非常神奇,允许你创建非常语义化以及高度重用的组件,可以理解为web components的先驱者. 网上已经有很多介绍怎么使用指令的文章以及相关书籍,相互比较的话,很少有介绍compile与link的区别,更别说pre-link与post-lin

iOS 基础函数解析 - Foundation Functions Reference

Foundation Functions Reference Framework Foundation/Foundation.h Declared in NSBundle.h NSByteOrder.h NSDecimal.h NSException.h NSObjCRuntime.h NSObject.h NSPathUtilities.h NSRange.h NSZone.h Overview This chapter describes the functions and function

thread.join函数,java多线程中的join函数解析

join函数的作用,是让当前线程等待,直到调用join()的 线程结束或者等到一段时间,我们来看以下代码 1 package mian; 2 3 4 public class simpleplela { 5 static void threadMessage(String message) { 6 String threadName = 7 Thread.currentThread().getName(); 8 9 System.out.println(threadName+" "+m

socket使用TCP协议时,send、recv函数解析以及TCP连接关闭的问题

Tcp协议本身是可靠的,并不等于应用程序用tcp发送数据就一定是可靠的.不管是否阻塞,send发送的大小,并不代表对端recv到多少的数据. 在阻塞模式下, send函数的过程是将应用程序请求发送的数据拷贝到发送缓存中发送并得到确认后再返回.但由于发送缓存的存在,表现为:如果发送缓存大小比请求发送的大小要大,那么send函数立即返回,同时向网络中发送数据;否则,send向网络发送缓存中不能容纳的那部分数据,并等待对端确认后再返回(接收端只要将数据收到接收缓存中,就会确认,并不一定要等待应用程序调

BulkLoop例程の初始化函数and重复调度函数の解析

//----------------------------------------------------------------------------- // File: bulkloop.c // Contents: Hooks required to implement USB peripheral function. // // $Archive: /USB/Examples/FX2LP/bulkloop/bulkloop.c $ // $Date: 3/23/05 2:55p $

C++虚函数解析(转载)

虚函数详解第一篇:对象内存模型浅析 C++中的虚函数的内部实现机制到底是怎样的呢? 鉴于涉及到的内容有点多,我将分三篇文章来介绍. 第一篇:对象内存模型浅析,这里我将对对象的内存模型进行简单的实验和总结. 第二篇:继承对象的构造和析构浅析,这里我将对存在继承关系的对象的构造和析构进行简单的实验和总结. 第三篇:虚函数的内部机制浅析,这里我将对虚函数内部的实现机制进行实验总结. 我使用的编译器是VS2008,有不足或者不准确的地方,欢迎大家拍砖(我个人非常迫切的希望得到大家的指正),我会及时修正相

PHP json_decode 函数解析 json 结果为 NULL 的解决方法

在做网站 CMS 模块时,对于模块内容 content 字段,保存的是 json 格式的字符串,所以在后台进行模块内容的编辑操作 ( 取出保存的数据 ) 时,需要用到 json_decode() 函数. 但是在解析的时候,使用 json_decode() 函数解析的结果一直是 NULL,没有出现希望解析成的数组.下面是问题和分析: 1. 当输出 json 字符串时,代码和页面的显示内容分别是: echo $content = $res[0]['con']['content']; 只需要考虑 $c

用函数解析类似于php.ini的配置文件

配置文件可以写成类似于php.ini文件的格式,用parse_ini_file函数解析. 1 > 配置文件格式 [database]host=localhostuser=tianyu 2> 进行解析 <?php    var_dump(parse_ini_file('./test.ini',true));?> 3> 打印结果: array (size=1)   'database' =>      array (size=2)       'host' => st