Nginx丟棄http包體怎麼處理

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

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

        相較於接收包體過程， 丟棄包體作業就簡單很多了，至少不需要把包體存​​放到http結構中的request_body緩衝區，也不需要考慮包體是否只存放到內存，或只存放到文件中等問題， 框架接收完包體後就直接丟棄了。丟棄包體由三個部分組成:

        (1) http模組首次呼叫框架提供的ngx_http_discard_request_body函數，做些初始化作業。例如如果一次操作無法丟棄所有包體 ，則需要重新把讀取事件註冊到epoll中，這樣再次調度執行時，能夠繼續執行丟包操作。再者，呼叫實際的丟包函數ngx_http_read_discarded_request_body進行丟棄包體操作。

        (2)如果操作無法丟棄所有包體，則在事件再次調度時，繼續接收剩餘的包體數據，然後丟棄。

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

        從圖中可看出這三個流程中，丟包流程是一個公開的功能。也就是說不管http模組呼叫ngx_http_discard_request_body函數開始進行丟包處理，還是一次調度沒有接收完全部包體時，由ngx_http_discarded_request_body_handler負責剩餘的包體操作， 都會呼叫公共的丟包函式後直接呼叫公用的丟包函式後直接呼叫包體丟棄操作。

一、丟包初始化流程

        ngx_http_discard_request_body是被http模組調用，用於丟棄包體的函數。對於模組來講是一個透明的操作。也就是說模組只需要呼叫這個介面就可以丟棄http請求包體，而不需要知道http框架是如何實作這個介面的。縱使框架一次調度沒有丟棄所有包體，下一次調度執行時會再次進行丟包操作，但對模組來說，他們是不知道的。

//功能: 丢弃http包体的首次回调函数，如果一次性不能全部接收完成并丢弃，则设置 
//  读事件的回调为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，则直接返回。表示丢弃包体 
 //如果已经接收过包体了，这时也不需要在接收。通常情况下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; 
 //已经预先接收了部分包体 
 if (size) 
 { 
  //包体未全部接收完成 
  if (r->headers_in.content_length_n > size) 
  { 
   r->header_in->pos += size; 
   r->headers_in.content_length_n -= size; 
 
  } 
  else 
  { 
   //包体已经全部接收 
   r->header_in->pos += (size_t) r->headers_in.content_length_n; 
   r->headers_in.content_length_n = 0; 
   return ngx_ok; 
  } 
 } 
 
 //设置后续读事件的回调 
 r->read_event_handler = ngx_http_discarded_request_body_handler; 
 
 //注册读事件回调，插入到epoll 
 ngx_handle_read_event(rev, 0)); 
  
 //接收包体内容 
 if (ngx_http_read_discarded_request_body(r) == ngx_ok) 
 { 
  //表示已经接收到完整的包体了，将延迟关闭清0 
  r->lingering_close = 0; 
 
 } 
 else 
 { 
  //表示需要多次调度才能完成丢弃包体这个操作，于是把引用计数加1，防止这边在丢弃包体，而其他 
  //事件却已经让请求意外销毁 
  r->count++; 
  //标识为正在丢弃包体 
  r->discard_body = 1; 
 } 
 
 return ngx_ok; 
}

         在接收http請求頭部時，如果也順便接收了http包體數據，這個時候就沒有必要繼續執行剩餘的操作，丟棄包體成功，函數直接回傳。如果一次調度沒有丟棄所有包體，則會設定http請求結構ngx_http_request_s的讀取事件read_event_handler為:ngx_http_discarded_request_body_handler, 下一次被調度時由這個函數負責丟棄剩餘的包體。因此ngx_http_discard_request_body只會被http模組首次呼叫。

        函數也會呼叫實際的丟包函數ngx_http_read_discarded_request_body開始進行接收包體後直接丟棄處理。

二、丟包處理 

       ngx_http_read_discarded_request_body函數負責接收來自客戶端的包體數據，然後丟棄。因此對於模組而言，就是丟棄包體操作，但對於框架而言，丟棄包體操作其實就是接收包體操作, 只不過接收後的包體資料沒有交給模組使用而已。為什麼框架要接收包體後再直接丟棄? 豈不是多此一舉。其實不然，之所以這樣做是有原因的。假設某個不健壯的客戶端瀏覽器使用阻塞的方法向nginx伺服器發送了http包體數據， 如果nginx框架不接收的話，會導致客戶端瀏覽器超時沒有反應，從而導致客戶端瀏覽器關閉這個連接。因此nginx的http框架要先從核心接收來自客戶端的包體數據， 但這些數據對於模組而言是沒有用的，因此接收後的這些數據會直接被丟棄。

//功能: 从内核中读取数据到nginx中，nginx不对收到的数据进行处理。相当于丢弃包体 
static ngx_int_t ngx_http_read_discarded_request_body(ngx_http_request_t *r) 
{ 
 //用于接收包体的临时缓冲区 
 u_char buffer[ngx_http_discard_buffer_size]; 
 
 for ( ;; ) 
 { 
  //已经全部丢弃成功 
  if (r->headers_in.content_length_n == 0) 
  { 
   //设置丢弃后的读事件回调，再有读事件时，不做任何处理 
   r->read_event_handler = ngx_http_block_reading; 
   return ngx_ok; 
  } 
   
  //从内核中接收包体到临时缓冲区 
  n = r->connection->recv(r->connection, buffer, size); 
 
  //更新剩余需要接收的包体大小 
  r->headers_in.content_length_n -= n; 
 } 
}

        函数内部只是使用一个临时的缓冲区变量存放每次接收来自内核的包体数据。并没有把这部分数据保存到http请求结构中的request_body缓冲区。因此包体数据没有交给http模块，相当于被丢弃了。在所有包体从内核中接收完成时，设置http请求结构ngx_http_request_s的读事件read_event_handler回调设置为: ngx_http_block_reading， 表示再收到来自客户端的数据，则不进行任何处理了。因为已经接收完所有的包体数据，也就不需要理会来自客户端浏览器的其它数据。

三、丢弃剩余的包体

        ngx_http_discarded_request_body_handler用于在一次调度中没有丢弃完所有包体，则该函数会表调用，用于丢弃剩余的包体。函数内部也会调用实际的丢弃包体函数，进行接收包体然后丢弃操作。nginx服务器做了一个优化处理，会设置一个总超时时间，如果超过这个时间都还没有丢弃完全部的包体，则会关闭这个连接。这是一种对服务器保护的措施，避免长时间的丢包操作占用服务器资源。

//功能: 第1次未能全部丢弃包体时，该函数被调用。之后有读事件时，该函数被调用 
void ngx_http_discarded_request_body_handler(ngx_http_request_t *r) 
{ 
 //检测延迟关闭时间,如果总时长超过了lingering_time，则不再接收任何包体，这是一个总时间。 
 //总超时后，将直接光比连接 
 if (r->lingering_time) 
 { 
  timer = (ngx_msec_t) (r->lingering_time - ngx_time()); 
  //已经到达了延迟关闭时间 
  if (timer <= 0) 
  { 
   //清空丢弃包体标识，表示包体已经丢弃 
   r->discard_body = 0;  
   //延迟关闭开关清0 
   r->lingering_close = 0; 
   ngx_http_finalize_request(r, ngx_error); 
   return; 
  } 
 
 } 
 
 //接收包体后丢弃 
 rc = ngx_http_read_discarded_request_body(r); 
 //表示包体已经全部丢弃 
 if (rc == ngx_ok) 
 { 
  r->discard_body = 0;  //包体已经全部接收完 
  r->lingering_close = 0;  //清空延迟关闭标志 
  ngx_http_finalize_request(r, ngx_done); 
  return; 
 } 
}

        ngx_http_discarded_request_body_handler这个函数是怎么被事件对象调用的呢? 在前面的文章已经分析了，ngx_connection_s读事件的回调设置为ngx_http_request_handler。   因此在读事件发生时，会回调请求结构的读回调。如果还不是不清楚这个调用过程，可以参考:

static void ngx_http_request_handler(ngx_event_t *ev) 
{ 
 //如果同时发生读写事件，则只有写事件才会触发。写事件优先级更高 
 if (ev->write)  
 { 
  r->write_event_handler(r); //在函数ngx_http_handler设置为ngx_http_core_run_phases 
 } 
 else 
 { 
  r->read_event_handler(r); //在函数ngx_http_process_request设置为ngx_http_block_reading 
 } 
}

以上是Nginx丟棄http包體怎麼處理的詳細內容。更多資訊請關注PHP中文網其他相關文章！