Nginx的事件处理机制

时间：2014-10-10 12:42:55 阅读：267 评论：0 收藏：0 [点我收藏+]

void
ngx_process_events_and_timers(ngx_cycle_t *cycle)
{
ngx_uint_t flags;
ngx_msec_t timer, delta;
if (ngx_timer_resolution) {
timer = NGX_TIMER_INFINITE;
flags = 0;
} else {
timer = ngx_event_find_timer();
flags = NGX_UPDATE_TIME;
}
/*ngx_use_accept_mutex变量代表是否使用accept相互排斥体
默认是使用，accept_mutex off;指令关闭。
accept mutex的作用就是避免惊群，同一时候实现负载均衡。
*/
if (ngx_use_accept_mutex) {
/*
ngx_accept_disabled变量在ngx_event_accept函数中计算。
假设ngx_accept_disabled大于了0，就表示该进程接受的
连接过多，因此就放弃一次争抢accept mutex的机会，同一时候将
自己减1。然后，继续处理已有连接上的事件。Nginx就借用
此变量实现了进程关于连接的基本负载均衡。
*/
if (ngx_accept_disabled > 0) {
ngx_accept_disabled--;
} else {
/* ngx_accept_disabled小于0，连接数没超载*/
/*尝试锁accept mutex，仅仅有成功获取锁的进程，才会将listen
套接字放入epoll中。因此，这就保证了仅仅有一个进程拥有
监听套接口，故全部进程堵塞在epoll_wait时，不会出现惊群现象。
*/
if (ngx_trylock_accept_mutex(cycle) == NGX_ERROR) {
return;
}
if (ngx_accept_mutex_held) {
/*获取锁的进程，将加入一个NGX_POST_EVENTS标志，
此标志的作用是将全部产生的事件放入一个队列中，
等释放锁后，再慢慢来处理事件。由于，处理事件可能
会非常耗时，假设不先释放锁再处理的话，该进程就长
时间霸占了锁，导致其它进程无法获取锁，这样accept
的效率就低了。
*/
flags |= NGX_POST_EVENTS;
} else {
/*没有获得锁的进程，当然不须要NGX_POST_EVENTS标志了。
但须要设置最长延迟多久，再次去争抢锁。
*/
if (timer == NGX_TIMER_INFINITE
|| timer > ngx_accept_mutex_delay)
{
timer = ngx_accept_mutex_delay;
}
}
}
}
delta = ngx_current_msec;
/*epoll開始wait事件了,ngx_process_events的详细实现是相应到
epoll模块中的ngx_epoll_process_events函数。单独分析epoll
模块的时候，再详细看看。
*/
(void) ngx_process_events(cycle, timer, flags);
delta = ngx_current_msec - delta; /*统计本次wait事件的耗时*/
/*ngx_posted_accept_events是一个事件队列
暂存epoll从监听套接口wait到的accept事件。
前文提到的NGX_POST_EVENTS标志被使用后，就会将
全部的accept事件暂存到这个队列。
这里完毕对队列中的accept事件的处理，实际就是调用
ngx_event_accept函数来获取一个新的连接，然后放入
epoll中。
*/
if (ngx_posted_accept_events) {
ngx_event_process_posted(cycle, &ngx_posted_accept_events);
}
/*全部accept事件处理完毕，假设拥有锁的话，就赶紧释放了。
其它进程还等着抢了。
*/
if (ngx_accept_mutex_held) {
ngx_shmtx_unlock(&ngx_accept_mutex);
}
/*delta是上文对epoll wait事件的耗时统计，存在毫秒级的耗时
就对全部事件的timer进行检查，假设time out就从timer rbtree中，
删除到期的timer，同一时候调用相应事件的handler函数完毕处理。
*/
if (delta) {
ngx_event_expire_timers();
}
/*处理普通事件（连接上获得的读写事件）队列上的全部事件，
由于每一个事件都有自己的handler方法，该怎么处理事件就
依赖于事件的详细handler了。
*/
if (ngx_posted_events) {
if (ngx_threaded) {
ngx_wakeup_worker_thread(cycle);
} else {
ngx_event_process_posted(cycle, &ngx_posted_events);
}
}
}

Nginx的事件处理机制

原文：http://www.cnblogs.com/blfshiye/p/4015466.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年09月23日 (328)
2021年09月24日 (313)
2021年09月17日 (191)
2021年09月15日 (369)
2021年09月16日 (411)
2021年09月13日 (439)
2021年09月11日 (398)
2021年09月12日 (393)
2021年09月10日 (160)
2021年09月08日 (222)