本篇文章主要會介紹nginx中請求的接收流程,包括請求頭的解析和請求體的讀取流程。
首先介紹一下rfc2616中定義的http請求基本格式:
Request = Request-Line *(( general-header | request-header | entity-header ) CRLF) CRLF [ message-body ] </span>
第一行是請求行(request line),用來說明請求方法,要訪問的資源以及所使用的HTTP版本:
Request-Line = Method SP Request-URI SP HTTP-Version CRLF</span>
請求方法(Method)的定義如下,其中最常用的是GET,POST方法:
Method = "OPTIONS" | "GET" | "HEAD" | "POST" | "PUT" | "DELETE" | "TRACE" | "CONNECT" | extension-method extension-method = token
要訪問的資源由統一資源地位符URI(Uniform Resource Identifier)確定,它的一個比較通用的組成格式(rfc2396)如下:
<scheme>://<authority><path>?<query>
一般來說根據請求方法(Method)的不同,請求URI的格式會有所不同,通常只需寫出path和query部分。
http版本(version)定義如下,現在用的一般為1.0和1.1版本:
HTTP/<major>.<minor>
請求行的下一行則是請求頭,rfc2616中定義了3種不同類型的請求頭,分別為general-header,request-header和entity-header,每種類型rfc中都定義了一些通用的頭,其中entity-header類型可以包含自定義的頭。
現在開始介紹nginx中請求頭的解析,nginx的請求處理流程中,會涉及到2個非常重要的數據結構,ngx_connection_t和ngx_http_request_t,分別用來表示連接和請求,這2個數據結構在本書的前篇中已經做了比較詳細的介紹,沒有印象的讀者可以翻回去復習一下,整個請求處理流程從頭到尾,對應著這2個數據結構的分配,初始化,使用,重用和銷毀。
nginx在初始化階段,具體是在init process階段的ngx_event_process_init函數中會為每一個監聽套接字分配一個連接結構(ngx_connection_t),并將該連接結構的讀事件成員(read)的事件處理函數設置為ngx_event_accept,并且如果沒有使用accept互斥鎖的話,在這個函數中會將該讀事件掛載到nginx的事件處理模型上(poll或者epoll等),反之則會等到init process階段結束,在工作進程的事件處理循環中,某個進程搶到了accept鎖才能掛載該讀事件。
static ngx_int_t ngx_event_process_init(ngx_cycle_t *cycle) { ... /* 初始化用來管理所有定時器的紅黑樹 */ if (ngx_event_timer_init(cycle->log) == NGX_ERROR) { return NGX_ERROR; } /* 初始化事件模型 */ for (m = 0; ngx_modules[m]; m++) { if (ngx_modules[m]->type != NGX_EVENT_MODULE) { continue; } if (ngx_modules[m]->ctx_index != ecf->use) { continue; } module = ngx_modules[m]->ctx; if (module->actions.init(cycle, ngx_timer_resolution) != NGX_OK) { /* fatal */ exit(2); } break; } ... /* for each listening socket */ /* 為每個監聽套接字分配一個連接結構 */ ls = cycle->listening.elts; for (i = 0; i < cycle->listening.nelts; i++) { c = ngx_get_connection(ls[i].fd, cycle->log); if (c == NULL) { return NGX_ERROR; } c->log = &ls[i].log; c->listening = &ls[i]; ls[i].connection = c; rev = c->read; rev->log = c->log; /* 標識此讀事件為新請求連接事件 */ rev->accept = 1; ... #if (NGX_WIN32) /* windows環境下不做分析,但原理類似 */ #else /* 將讀事件結構的處理函數設置為ngx_event_accept */ rev->handler = ngx_event_accept; /* 如果使用accept鎖的話,要在后面搶到鎖才能將監聽句柄掛載上事件處理模型上 */ if (ngx_use_accept_mutex) { continue; } /* 否則,將該監聽句柄直接掛載上事件處理模型 */ if (ngx_event_flags & NGX_USE_RTSIG_EVENT) { if (ngx_add_conn(c) == NGX_ERROR) { return NGX_ERROR; } } else { if (ngx_add_event(rev, NGX_READ_EVENT, 0) == NGX_ERROR) { return NGX_ERROR; } } #endif } return NGX_OK; }
新聞熱點
疑難解答