ngx_event_core_module模塊的ngx_event_process_init方法對事件模塊做了一些初始化。其中包括將“請求連接”這樣一個讀事件對應的處理方法（handler）設置為ngx_event_accept函數，并將此事件添加到epoll模塊中。當有新連接事件發生時，ngx_event_accept就會被調用。大致流程是這樣：

worker進程在ngx_worker_process_cycle方法中不斷循環調用ngx_process_events_and_timers函數處理事件，這個函數是事件處理的總入口。

ngx_process_events_and_timers會調用ngx_process_events，這是一個宏，相當于ngx_event_actions.process_events，ngx_event_actions是個全局的結構體，存儲了對應事件驅動模塊（這里是epoll模塊）的10個函數接口。所以這里就是調用了ngx_epoll_module_ctx.actions.process_events函數，也就是ngx_epoll_process_events函數來處理事件。

ngx_epoll_process_events調用Linux函數接口epoll_wait獲得“有新連接”這個事件，然后調用這個事件的handler處理函數來對這個事件進行處理。

在上面已經說過handler已經被設置成了ngx_event_accept函數，所以就調用ngx_event_accept進行實際的處理。

下面分析ngx_event_accept方法，它的流程圖如下所示：

經過精簡的代碼如下，注釋中的序號對應上圖的序號：

voidngx_event_accept(ngx_event_t *ev){ socklen_t  socklen; ngx_err_t  err; ngx_log_t  *log; ngx_uint_t  level; ngx_socket_t  s; ngx_event_t  *rev, *wev; ngx_listening_t  *ls; ngx_connection_t *c, *lc; ngx_event_conf_t *ecf; u_char  sa[NGX_SOCKADDRLEN];  if (ev->timedout) {  if (ngx_enable_accept_events((ngx_cycle_t *) ngx_cycle) != NGX_OK) {   return;  }   ev->timedout = 0; }  ecf = ngx_event_get_conf(ngx_cycle->conf_ctx, ngx_event_core_module);  if (ngx_event_flags & NGX_USE_RTSIG_EVENT) {  ev->available = 1;  } else if (!(ngx_event_flags & NGX_USE_KQUEUE_EVENT)) {  ev->available = ecf->multi_accept; }  lc = ev->data; ls = lc->listening; ev->ready = 0;  do {  socklen = NGX_SOCKADDRLEN;   /* 1、accept方法試圖建立連接，非阻塞調用 */  s = accept(lc->fd, (struct sockaddr *) sa, &socklen);   if (s == (ngx_socket_t) -1)  {   err = ngx_socket_errno;    if (err == NGX_EAGAIN)   {    /* 沒有連接，直接返回 */    return;   }    level = NGX_LOG_ALERT;    if (err == NGX_ECONNABORTED) {    level = NGX_LOG_ERR;    } else if (err == NGX_EMFILE || err == NGX_ENFILE) {    level = NGX_LOG_CRIT;   }    if (err == NGX_ECONNABORTED) {    if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) {     ev->available--;    }     if (ev->available) {     continue;    }   }    if (err == NGX_EMFILE || err == NGX_ENFILE) {    if (ngx_disable_accept_events((ngx_cycle_t *) ngx_cycle)     != NGX_OK)    {     return;    }     if (ngx_use_accept_mutex) {     if (ngx_accept_mutex_held) {      ngx_shmtx_unlock(&ngx_accept_mutex);      ngx_accept_mutex_held = 0;     }      ngx_accept_disabled = 1;     } else {     ngx_add_timer(ev, ecf->accept_mutex_delay);    }   }    return;  }   /* 2、設置負載均衡閾值 */  ngx_accept_disabled = ngx_cycle->connection_n / 8        - ngx_cycle->free_connection_n;   /* 3、從連接池獲得一個連接對象 */  c = ngx_get_connection(s, ev->log);   /* 4、為連接創建內存池 */  c->pool = ngx_create_pool(ls->pool_size, ev->log);   c->sockaddr = ngx_palloc(c->pool, socklen);   ngx_memcpy(c->sockaddr, sa, socklen);   log = ngx_palloc(c->pool, sizeof(ngx_log_t));   /* set a blocking mode for aio and non-blocking mode for others */  /* 5、設置套接字屬性為阻塞或非阻塞 */  if (ngx_inherited_nonblocking) {   if (ngx_event_flags & NGX_USE_AIO_EVENT) {    if (ngx_blocking(s) == -1) {     ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno,         ngx_blocking_n " failed");     ngx_close_accepted_connection(c);     return;    }   }   } else {   if (!(ngx_event_flags & (NGX_USE_AIO_EVENT|NGX_USE_RTSIG_EVENT))) {    if (ngx_nonblocking(s) == -1) {     ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno,         ngx_nonblocking_n " failed");     ngx_close_accepted_connection(c);     return;    }   }  }   *log = ls->log;   c->recv = ngx_recv;  c->send = ngx_send;  c->recv_chain = ngx_recv_chain;  c->send_chain = ngx_send_chain;   c->log = log;  c->pool->log = log;   c->socklen = socklen;  c->listening = ls;  c->local_sockaddr = ls->sockaddr;  c->local_socklen = ls->socklen;   c->unexpected_eof = 1;   rev = c->read;  wev = c->write;   wev->ready = 1;   if (ngx_event_flags & (NGX_USE_AIO_EVENT|NGX_USE_RTSIG_EVENT)) {   /* rtsig, aio, iocp */   rev->ready = 1;  }   if (ev->deferred_accept) {   rev->ready = 1;   }   rev->log = log;  wev->log = log;   /*   * TODO: MT: - ngx_atomic_fetch_add()   *  or protection by critical section or light mutex   *   * TODO: MP: - allocated in a shared memory   *   - ngx_atomic_fetch_add()   *  or protection by critical section or light mutex   */   c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);   if (ls->addr_ntop) {   c->addr_text.data = ngx_pnalloc(c->pool, ls->addr_text_max_len);   if (c->addr_text.data == NULL) {    ngx_close_accepted_connection(c);    return;   }    c->addr_text.len = ngx_sock_ntop(c->sockaddr, c->socklen,            c->addr_text.data,            ls->addr_text_max_len, 0);   if (c->addr_text.len == 0) {    ngx_close_accepted_connection(c);    return;   }  }   /* 6、將新連接對應的讀寫事件添加到epoll對象中 */  if (ngx_add_conn && (ngx_event_flags & NGX_USE_EPOLL_EVENT) == 0) {   if (ngx_add_conn(c) == NGX_ERROR) {    ngx_close_accepted_connection(c);    return;   }  }   log->data = NULL;  log->handler = NULL;   /* 7、TCP建立成功調用的方法，這個方法在ngx_listening_t結構體中 */  ls->handler(c);  } while (ev->available); /* available標志表示一次盡可能多的建立連接，由配置項multi_accept決定 */}