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_read_discarded_request_body进行接收包体后直接丢弃操作。
一、丢包初始化流程
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;
}
