文章6：Nginx中的Epoll事件处理机制

欢迎转载转载请注明出处http://blog.csdn.net/yankai0219/article/details/8453313

0.序1.Epoll事件初始化2.Epoll事件处理

0.序在Linux下，Nginx默认的事件处理机制是Epoll事件处理机制。当然Nginx也可以使用select等事件处理机制，因此Nginx为了支持和开发具体的I/O模型，Nginx将事件处理机制抽象化。在ngx_epoll_module.c中，可以看到。
1.Epoll事件初始化 从总图中来看，我们可以更好的明白Epoll事件初始化所牵涉的内容。主要看ngx_worker_process_init函数中内容 1）ngx_epoll_init 通过epoll_create函数创建了epfd句柄，这是epoll的接口，之后所有的函数调用都要使用该epfd句柄。 2）之后在ngx_event_process_init中，通过epoll_ctl将监听套接字和其对应的事件类型添加到epfd句柄中。通过这两步，就完成了epoll事件处理的三部曲中的前两部，接下来就是由epoll_wait等待事件的发生。
2.Epoll事件处理 1）epoll_wait函数在ngx_epoll_process_events中，这个函数是由ngx_process_events_and_timers函数调用的。关于ngx_process_events_and_timers函数的介绍，详见文章4：Nginx源码分析-事件循环修改版。 2）关于ngx_epoll_process_events的处理

static ngx_int_tngx_epoll_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, ngx_uint_t flags){    int                events;    uint32_t           revents;    ngx_int_t          instance, i;    ngx_uint_t         level;    ngx_err_t          err;    ngx_event_t       *rev, *wev, **queue;    ngx_connection_t *c;
    /* NGX_TIMER_INFINITE == INFTIM */
    ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,                   "epoll timer: %M", timer);/* 等待事件发生。最长等待事件为timer；nginx通过红黑树专门维护了一个计时器*/    events = epoll_wait(ep, event_list, ( int) nevents, timer);
    err = (events == -1) ? ngx_errno : 0;
    if (flags & NGX_UPDATE_TIME || ngx_event_timer_alarm) {        ngx_time_update();    }
    if (err) { /*处理wait错误*/    }
    if (events == 0) {   /*epoll_wait返回事件数为0，可能是timeout返回，也可能不是timeout返回。非timeout返回则是error*/    }
    ngx_mutex_lock(ngx_posted_events_mutex);/*只有在使用线程时，该函数才有作用*//*处理wait的事件，wait的事件及其处理方式都在event_list数组中，个数为events个。*/    for (i = 0; i < events; i++) { ...... /*取得发生的一个事件*/        revents = event_list[i].events; /*处理wait的错误返回状态*/        if (revents & (EPOLLERR|EPOLLHUP)) {            ngx_log_debug2(NGX_LOG_DEBUG_EVENT, cycle->log, 0,                           "epoll_wait() error on fd:%d ev:%04XD" ,                           c->fd, revents);        }

        if ((revents & (EPOLLERR|EPOLLHUP)) && (revents & (EPOLLIN|EPOLLOUT)) == 0)        {            /*             * if the error events were returned without EPOLLIN or EPOLLOUT,             * then add these flags to handle the events at least in one             * active handler             */
            revents |= EPOLLIN|EPOLLOUT;        }/*该事件是一个读事件，并该连接上注册的读事件是active的*/        if ((revents & EPOLLIN) && rev->active) {
            if ((flags & NGX_POST_THREAD_EVENTS) && !rev->accept) {                rev->posted_ready = 1;
            } else {                rev->ready = 1;            }/*根据文章8：Nginx accept互斥锁和文章和文章4：Nginx源码分析-事件循环修改版中所讲，抢到accept互斥体的进程A，进程A会对所发生的事件进行NGX_POST_EVENTS标记，先将事件存入ngx_posted_accept_events或ngx_posted_events数组中，之后在进程A解除accept互斥锁以后，才会处理这些事件。*/            if (flags & NGX_POST_EVENTS) {
                queue = (ngx_event_t **) (rev->accept ?                               &ngx_posted_accept_events : &ngx_posted_events);
                ngx_locked_post_event(rev, queue);
            } else {                rev->handler(rev);            }        }/*写事件的方式与读事件一样*/        wev = c->write;
        if ((revents & EPOLLOUT) && wev->active) {
            if (c->fd == -1 || wev->instance != instance) {
                /*                 * the stale event from a file descriptor                 * that was just closed in this iteration                 */
                ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,                               "epoll: stale event %p" , c);                continue;            }
            if (flags & NGX_POST_THREAD_EVENTS) {                wev->posted_ready = 1;
            } else {                wev->ready = 1;            }
            if (flags & NGX_POST_EVENTS) {                ngx_locked_post_event(wev, &ngx_posted_events);
            } else {                wev->handler(wev);            }        }    }
    ngx_mutex_unlock(ngx_posted_events_mutex);
    return NGX_OK;}

参考文章http://www.alidata.org/archives/1296

秒客网

文章6：Nginx中的Epoll事件处理机制

相关文章