Nginx丟棄http包體處理實例詳解

http框架丟棄http請求包體和上一篇文章http框架接收包體， 都是由http框架提供的兩個方法，供http各個模塊調(diào)用，從而決定對包體做什么處理。是選擇丟棄還是接收，都是由模塊決定的。例如靜態(tài)資源模塊，如果接收到來自瀏覽器的get請求，請求某個文件時，則直接返回這個文件內(nèi)容給瀏覽器就可以了。沒有必要再接收包體數(shù)據(jù)，get請求實際上也不會有包體。因此靜態(tài)資源模塊將調(diào)用http框架提供的丟棄包體函數(shù)進行丟包處理。

        相比接收包體過程， 丟棄包體操作就簡單很多了，至少不需要把包體存放到http結(jié)構(gòu)中的request_body緩沖區(qū)，也不需要考慮包體是否只存放到內(nèi)存，或者只存放到文件中等問題， 框架接收完包體后就直接丟棄了。丟棄包體由三部分組成:

        (1) http模塊首次調(diào)用框架提供的ngx_http_discard_request_body函數(shù)，做些初始化操作。例如如果一次操作無法丟棄所有包體 ，則需要重新把讀事件注冊到epoll中，這樣再次調(diào)度執(zhí)行時，能夠繼續(xù)執(zhí)行丟包操作。再者，調(diào)用實際的丟包函數(shù)ngx_http_read_discarded_request_body進行丟棄包體操作。

        (2)如果一次操作無法丟棄所有包體，則在事件再次被調(diào)度時，繼續(xù)接收剩余的包體數(shù)據(jù)，然后丟棄。

        (3)實際的丟包處理，也就是接收包體后，直接丟棄。

        從圖中可以看出這三個過程中，丟包流程是一個公共的功能。也就是說不管http模塊調(diào)用ngx_http_discard_request_body函數(shù)開始進行丟包處理，還是一次調(diào)度沒有接收完全部包體時，由ngx_http_discarded_request_body_handler負責丟棄剩余的包體操作， 都會調(diào)用公共的丟包函數(shù)ngx_http_read_discarded_request_body進行接收包體后直接丟棄操作。

一、丟包初始化流程

        ngx_http_discard_request_body是被http模塊調(diào)用，用于丟棄包體的函數(shù)。對于模塊來講是一個透明的操作。也就是說模塊只需要調(diào)用這個接口就可以丟棄http請求包體，而不需要知道http框架是如何實現(xiàn)這個接口的?？v使框架一次調(diào)度沒有丟棄完所有包體，下一次調(diào)度執(zhí)行時會再次進行丟包操作，但對模塊來說，他們是不知道的。

//功能: 丟棄http包體的首次回調(diào)函數(shù)，如果一次性不能全部接收完成并丟棄，則設(shè)置 
//  讀事件的回調(diào)為ngx_http_discarded_request_body_handler 
ngx_int_t ngx_http_discard_request_body(ngx_http_request_t *r) 
{ 
 
 //需要丟棄的包體不用考慮超時問題 
 if (rev->timer_set) 
 { 
  ngx_del_timer(rev); 
 } 
 
 //包體長度小于等于0，則直接返回。表示丟棄包體 
 //如果已經(jīng)接收過包體了，這時也不需要在接收。通常情況下get請求沒有包體，因此包體長度為0 
 if (r->headers_in.content_length_n <= 0 || r->request_body) 
 { 
  return NGX_OK; 
 } 
 
 size = r->header_in->last - r->header_in->pos; 
 //已經(jīng)預(yù)先接收了部分包體 
 if (size) 
 { 
  //包體未全部接收完成 
  if (r->headers_in.content_length_n > size) 
  { 
   r->header_in->pos += size; 
   r->headers_in.content_length_n -= size; 
 
  } 
  else 
  { 
   //包體已經(jīng)全部接收 
   r->header_in->pos += (size_t) r->headers_in.content_length_n; 
   r->headers_in.content_length_n = 0; 
   return NGX_OK; 
  } 
 } 
 
 //設(shè)置后續(xù)讀事件的回調(diào) 
 r->read_event_handler = ngx_http_discarded_request_body_handler; 
 
 //注冊讀事件回調(diào)，插入到epoll 
 ngx_handle_read_event(rev, 0)); 
  
 //接收包體內(nèi)容 
 if (ngx_http_read_discarded_request_body(r) == NGX_OK) 
 { 
  //表示已經(jīng)接收到完整的包體了，將延遲關(guān)閉清0 
  r->lingering_close = 0; 
 
 } 
 else 
 { 
  //表示需要多次調(diào)度才能完成丟棄包體這個操作，于是把引用計數(shù)加1，防止這邊在丟棄包體，而其他 
  //事件卻已經(jīng)讓請求意外銷毀 
  r->count++; 
  //標識為正在丟棄包體 
  r->discard_body = 1; 
 } 
 
 return NGX_OK; 
}  

         在接收http請求頭部時，如果也順便接收了http包體數(shù)據(jù)，這個時候就沒有必要繼續(xù)執(zhí)行剩余的操作，丟棄包體成功，函數(shù)直接返回。如果一次調(diào)度沒有丟棄完所有包體，則會設(shè)置http請求結(jié)構(gòu)ngx_http_request_s的讀事件read_event_handler為:ngx_http_discarded_request_body_handler, 下一次被調(diào)度時由這個函數(shù)負責丟棄剩余的包體。因此ngx_http_discard_request_body只會被http模塊首次調(diào)用。

        函數(shù)也會調(diào)用實際的丟包函數(shù)ngx_http_read_discarded_request_body開始進行接收包體后直接丟棄處理。

二、丟包處理 

       ngx_http_read_discarded_request_body函數(shù)負責接收來自客戶端的包體數(shù)據(jù)，然后再丟棄。因此對于模塊而言，就是丟棄包體操作，但對于框架而言，丟棄包體操作其實就是接收包體操作, 只不過接收后的包體數(shù)據(jù)沒有交給模塊使用而已。為什么框架要接收包體后再直接丟棄呢? 豈不是多此一舉。其實不然，之所以這樣做是有原因的。假設(shè)某個不健壯的客戶端瀏覽器使用阻塞的方法向nginx服務(wù)器發(fā)送了http包體數(shù)據(jù)， 如果nginx框架不接收的話，會導致客戶端瀏覽器超時沒有反應(yīng)，從而導致客戶端瀏覽器關(guān)閉這個連接。因此nginx的http框架要先從內(nèi)核中接收來自客戶端的包體數(shù)據(jù)， 但這些數(shù)據(jù)對于模塊而言是沒有用的，因此接收后的這些數(shù)據(jù)會直接被丟棄。

//功能: 從內(nèi)核中讀取數(shù)據(jù)到nginx中，nginx不對收到的數(shù)據(jù)進行處理。相當于丟棄包體 
static ngx_int_t ngx_http_read_discarded_request_body(ngx_http_request_t *r) 
{ 
 //用于接收包體的臨時緩沖區(qū) 
 u_char buffer[NGX_HTTP_DISCARD_BUFFER_SIZE]; 
 
 for ( ;; ) 
 { 
  //已經(jīng)全部丟棄成功 
  if (r->headers_in.content_length_n == 0) 
  { 
   //設(shè)置丟棄后的讀事件回調(diào)，再有讀事件時，不做任何處理 
   r->read_event_handler = ngx_http_block_reading; 
   return NGX_OK; 
  } 
   
  //從內(nèi)核中接收包體到臨時緩沖區(qū) 
  n = r->connection->recv(r->connection, buffer, size); 
 
  //更新剩余需要接收的包體大小 
  r->headers_in.content_length_n -= n; 
 } 
} 

        函數(shù)內(nèi)部只是使用一個臨時的緩沖區(qū)變量存放每次接收來自內(nèi)核的包體數(shù)據(jù)。并沒有把這部分數(shù)據(jù)保存到http請求結(jié)構(gòu)中的request_body緩沖區(qū)。因此包體數(shù)據(jù)沒有交給http模塊，相當于被丟棄了。在所有包體從內(nèi)核中接收完成時，設(shè)置http請求結(jié)構(gòu)ngx_http_request_s的讀事件read_event_handler回調(diào)設(shè)置為: ngx_http_block_reading， 表示再收到來自客戶端的數(shù)據(jù)，則不進行任何處理了。因為已經(jīng)接收完所有的包體數(shù)據(jù)，也就不需要理會來自客戶端瀏覽器的其它數(shù)據(jù)。

三、丟棄剩余的包體

        ngx_http_discarded_request_body_handler用于在一次調(diào)度中沒有丟棄完所有包體，則該函數(shù)會表調(diào)用，用于丟棄剩余的包體。函數(shù)內(nèi)部也會調(diào)用實際的丟棄包體函數(shù)，進行接收包體然后丟棄操作。nginx服務(wù)器做了一個優(yōu)化處理，會設(shè)置一個總超時時間，如果超過這個時間都還沒有丟棄完全部的包體，則會關(guān)閉這個連接。這是一種對服務(wù)器保護的措施，避免長時間的丟包操作占用服務(wù)器資源。

//功能: 第1次未能全部丟棄包體時，該函數(shù)被調(diào)用。之后有讀事件時，該函數(shù)被調(diào)用 
void ngx_http_discarded_request_body_handler(ngx_http_request_t *r) 
{ 
 //檢測延遲關(guān)閉時間,如果總時長超過了lingering_time，則不再接收任何包體，這是一個總時間。 
 //總超時后，將直接光比連接 
 if (r->lingering_time) 
 { 
  timer = (ngx_msec_t) (r->lingering_time - ngx_time()); 
  //已經(jīng)到達了延遲關(guān)閉時間 
  if (timer <= 0) 
  { 
   //清空丟棄包體標識，表示包體已經(jīng)丟棄 
   r->discard_body = 0;  
   //延遲關(guān)閉開關(guān)清0 
   r->lingering_close = 0; 
   ngx_http_finalize_request(r, NGX_ERROR); 
   return; 
  } 
 
 } 
 
 //接收包體后丟棄 
 rc = ngx_http_read_discarded_request_body(r); 
 //表示包體已經(jīng)全部丟棄 
 if (rc == NGX_OK) 
 { 
  r->discard_body = 0;  //包體已經(jīng)全部接收完 
  r->lingering_close = 0;  //清空延遲關(guān)閉標志 
  ngx_http_finalize_request(r, NGX_DONE); 
  return; 
 } 
} 

        ngx_http_discarded_request_body_handler這個函數(shù)是怎么被事件對象調(diào)用的呢? 在前面的文章已經(jīng)分析了，ngx_connection_s讀事件的回調(diào)設(shè)置為ngx_http_request_handler。   因此在讀事件發(fā)生時，會回調(diào)請求結(jié)構(gòu)的讀回調(diào)。如果還不是不清楚這個調(diào)用過程，可以參考: nginx處理http請求這篇文章

static void ngx_http_request_handler(ngx_event_t *ev) 
{ 
 //如果同時發(fā)生讀寫事件，則只有寫事件才會觸發(fā)。寫事件優(yōu)先級更高 
 if (ev->write)  
 { 
  r->write_event_handler(r); //在函數(shù)ngx_http_handler設(shè)置為ngx_http_core_run_phases 
 } 
 else 
 { 
  r->read_event_handler(r); //在函數(shù)ngx_http_process_request設(shè)置為ngx_http_block_reading 
 } 
} 

        到此為止，http框架丟棄包體的流程已經(jīng)分析完成了。

感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！

最新評論