nginx惊群问题如何解决

void ngx_process_events_and_timers(ngx_cycle_t *cycle) {
 ngx_uint_t flags;
 ngx_msec_t timer, delta;

 if (ngx_trylock_accept_mutex(cycle) == ngx_error) {
  return;
 }

 // 那面入手下手措置事故，对于于kqueue模子，其指向的是ngx_kqueue_process_events()法子，
 // 而对于于epoll模子，其指向的是ngx_epoll_process_events()法子
 // 那个法子的首要做用是，正在对于应的事故模子外猎取事变列表，而后将变乱加添到ngx_posted_accept_events
 // 行列步队或者者ngx_posted_events行列步队外
 (void) ngx_process_events(cycle, timer, flags);

 // 那面入手下手措置accept事变，将其交由ngx_event_accept.c的ngx_event_accept()办法处置；
 ngx_event_process_posted(cycle, &ngx_posted_accept_events);

 // 入手下手开释锁
 if (ngx_accept_mutex_held) {
  ngx_shmtx_unlock(&ngx_accept_mutex);
 }

 // 奈何没有须要正在事变行列步队外入止措置，则直截处置该事变
 // 对于于变乱的处置惩罚，假设是accept事变，则将其交由ngx_event_accept.c的ngx_event_accept()法子处置惩罚；
 // 要是是读事故，则将其交由ngx_http_request.c的ngx_http_wait_request_handler()办法处置惩罚；
 // 对于于措置实现的事变，末了会交由ngx_http_request.c的ngx_http_keepalive_handler()办法处置。

 // 那面入手下手措置除了accept事故中的其他变乱
 ngx_event_process_posted(cycle, &ngx_posted_events);
}

ngx_int_t ngx_trylock_accept_mutex(ngx_cycle_t *cycle) {
 // 测验考试利用cas算法猎取同享锁
 if (ngx_shmtx_trylock(&ngx_accept_mutex)) {

  // ngx_accept_mutex_held为1表现当提高程曾经猎取到了锁
  if (ngx_accept_mutex_held && ngx_accept_events == 0) {
   return ngx_ok;
  }

  // 那面首要是将当前毗连的文件形貌符注册到对于应事变的行列步队外，比喻kqueue模子的change_list数组
  // nginx正在封用各个worker历程的时辰，默许环境高，worker过程是会承继master过程所监听的socket句柄的，
  // 那便招致一个答题，等于当某个端心有客户端事故时，便会把监听该端心的历程皆给叫醒，
  // 然则只要一个worker历程可以或许顺遂措置该事变，而其他的历程被叫醒以后创造事故曾逾期，
  // 因此会延续入进期待状况，这类情形称为"惊群"气象。
  // nginx摒挡惊群景象的体式格局一圆里是经由过程那面的同享锁的体式格局，即惟独猎取到锁的worker历程才气处置
  // 客户端变乱，但实践上，worker过程是经由过程正在猎取锁的进程外，为当前worker过程从新加添各个端心的监听事变，
  // 而其他worker历程则没有会监听。也便是说统一光阴只需一个worker过程会监听各个端心，
  // 如许便制止了"惊群"答题。
  // 那面的ngx_enable_accept_events()办法即是为当进步程从新加添各个端心的监听事故的。
  if (ngx_enable_accept_events(cycle) == ngx_error) {
   ngx_shmtx_unlock(&ngx_accept_mutex);
   return ngx_error;
  }

  // 标识表记标帜当前曾经顺遂猎取到了锁
  ngx_accept_events = 0;
  ngx_accept_mutex_held = 1;

  return ngx_ok;
 }

 // 前里猎取锁掉败了，因此那面需求重置ngx_accept_mutex_held的形态，而且将当前衔接的变乱给取销失
 if (ngx_accept_mutex_held) {
  // 若何怎样当进步程的ngx_accept_mutex_held为1，则将其重置为0，而且将当进步程正在各个端心上的监听
  // 事变给增除了失
  if (ngx_disable_accept_events(cycle, 0) == ngx_error) {
   return ngx_error;
  }

  ngx_accept_mutex_held = 0;
 }

 return ngx_ok;
}