nginx 源码学习笔记（二十一）—— event 模块(二) ——事件驱动核心ngx_process_events_and_timers

叁歲伎倆 2022-05-08 23:26 167阅读 0赞

首先继续回忆下，之前子线程执行操作里面有一个未涉及的内容ngx\_process\_events\_and\_timers，今天我们就来研究下这个函数。

本篇文章来自于：[http://blog.csdn.net/lengzijian/article/details/7601730][http_blog.csdn.net_lengzijian_article_details_7601730]

先来看一下第十九节的部分截图：

![1337925963_5996.png][]

今天主要讲解的就是事件驱动函数，图中的红色部分：

**\[cpp\]** [view plain][][copy][view plain][print][view plain][?][view plain]

1.  src/event/ngx\_event.c
2.  
3.  void
4.  ngx\_process\_events\_and\_timers(ngx\_cycle\_t \*cycle)
5.  \{
6.  ngx\_uint\_t flags;
7.  ngx\_msec\_t timer, delta;
8.  
9.  if (ngx\_timer\_resolution) \{
10. timer = NGX\_TIMER\_INFINITE;
11. flags = 0;
12. 
13. \} else \{
14. timer = ngx\_event\_find\_timer();
15. flags = NGX\_UPDATE\_TIME;
16. \}
17. 
18. /\*
19. ngx\_use\_accept\_mutex变量代表是否使用accept互斥体
20. 默认是使用，可以通过accept\_mutex off;指令关闭；
21. accept mutex 的作用就是避免惊群，同时实现负载均衡
22. \*/
23. if (ngx\_use\_accept\_mutex) \{
24. 
25. /\*
26. ngx\_accept\_disabled变量在ngx\_event\_accept函数中计算。
27. 如果ngx\_accept\_disabled大于0，就表示该进程接受的链接过多，
28. 因此放弃一次争抢accept mutex的机会，同时将自己减一。
29. 然后，继续处理已有连接上的事件。
30. nginx就利用这一点实现了继承关于连接的基本负载均衡。
31. \*/
32. if (ngx\_accept\_disabled > 0) \{
33. ngx\_accept\_disabled--;
34. 
35. \} else \{
36. /\*
37. 尝试锁accept mutex，只有成功获取锁的进程，才会将listen套接字放到epoll中。
38. 因此，这就保证了只有一个进程拥有监听套接口，故所有进程阻塞在epoll\_wait时，
39. 才不会惊群现象。
40. \*/
41. if (ngx\_trylock\_accept\_mutex(cycle) == NGX\_ERROR) \{
42. return;
43. \}
44. 
45. if (ngx\_accept\_mutex\_held) \{
46. /\*
47. 如果进程获得了锁，将添加一个 NGX\_POST\_EVENTS 标志。
48. 这个标志的作用是将所有产生的事件放入一个队列中，等释放后，在慢慢来处理事件。
49. 因为，处理时间可能会很耗时，如果不先施放锁再处理的话，该进程就长时间霸占了锁，
50. 导致其他进程无法获取锁，这样accept的效率就低了。
51. \*/
52. flags |= NGX\_POST\_EVENTS;
53. 
54. \} else \{
55. /\*
56. 没有获得所得进程，当然不需要NGX\_POST\_EVENTS标志。
57. 但需要设置延时多长时间，再去争抢锁。
58. \*/
59. if (timer == NGX\_TIMER\_INFINITE
60. || timer > ngx\_accept\_mutex\_delay)
61. \{
62. timer = ngx\_accept\_mutex\_delay;
63. \}
64. \}
65. \}
66. \}
67. 
68. delta = ngx\_current\_msec;
69. 
70. /\*接下来，epoll要开始wait事件，
71. ngx\_process\_events的具体实现是对应到epoll模块中的ngx\_epoll\_process\_events函数
72. 这里之后会详细讲解的哦
73. \*/
74. (void) ngx\_process\_events(cycle, timer, flags);
75. //统计本次wait事件的耗时
76. delta = ngx\_current\_msec - delta;
77. 
78. ngx\_log\_debug1(NGX\_LOG\_DEBUG\_EVENT, cycle->log, 0,
79. "timer delta: %M", delta);
80. 
81. /\*
82. ngx\_posted\_accept\_events是一个事件队列，暂存epoll从监听套接口wait到的accept事件。
83. 前文提到的NGX\_POST\_EVENTS标志被使用后，会将所有的accept事件暂存到这个队列
84. \*/
85. if (ngx\_posted\_accept\_events) \{
86. ngx\_event\_process\_posted(cycle, &ngx\_posted\_accept\_events);
87. \}
88. //所有accept事件处理完之后，如果持有锁的话，就释放掉。
89. if (ngx\_accept\_mutex\_held) \{
90. ngx\_shmtx\_unlock(&ngx\_accept\_mutex);
91. \}
92. 
93. /\*
94. delta是之前统计的耗时，存在毫秒级的耗时，就对所有时间的timer进行检查，
95. 如果timeout 就从time rbtree中删除到期的timer，同时调用相应事件的handler函数处理
96. \*/
97. if (delta) \{
98. ngx\_event\_expire\_timers();
99. \}
100. 
101. ngx\_log\_debug1(NGX\_LOG\_DEBUG\_EVENT, cycle->log, 0,
102. "posted events %p", ngx\_posted\_events);
103. 
104. /\*
105. 处理普通事件(连接上获得的读写事件)，
106. 因为每个事件都有自己的handler方法，
107. \*/
108. if (ngx\_posted\_events) \{
109. if (ngx\_threaded) \{
110. ngx\_wakeup\_worker\_thread(cycle);
111. 
112. \} else \{
113. ngx\_event\_process\_posted(cycle, &ngx\_posted\_events);
114. \}
115. \}
116. \}

之前有说过accept事件，其实他就是监听套接口上是否有新来的事件，下面介绍下accept时间的handler方法：

ngx\_event\_accept：

**\[cpp\]** [view plain][][copy][view plain][print][view plain][?][view plain]

1.  src/event/ngx\_event\_accept.c
2.  
3.  void
4.  ngx\_event\_accept(ngx\_event\_t \*ev)
5.  \{
6.  socklen\_t socklen;
7.  ngx\_err\_t err;
8.  ngx\_log\_t \*log;
9.  ngx\_socket\_t s;
10. ngx\_event\_t \*rev, \*wev;
11. ngx\_listening\_t \*ls;
12. ngx\_connection\_t \*c, \*lc;
13. ngx\_event\_conf\_t \*ecf;
14. u\_char sa\[NGX\_SOCKADDRLEN\];
15. 
16. //省略部分代码
17. 
18. lc = ev->data;
19. ls = lc->listening;
20. ev->ready = 0;
21. 
22. ngx\_log\_debug2(NGX\_LOG\_DEBUG\_EVENT, ev->log, 0,
23. "accept on %V, ready: %d", &ls->addr\_text, ev->available);
24. 
25. do \{
26. socklen = NGX\_SOCKADDRLEN;
27. //accept一个新的连接
28. s = accept(lc->fd, (struct sockaddr \*) sa, &socklen);
29. //省略部分代码
30. 
31. /\*
32. accept到一个新的连接后，就重新计算ngx\_accept\_disabled的值，
33. 它主要是用来做负载均衡，之前有提过。
34. 
35. 这里，我们可以看到他的就只方式
36. “总连接数的八分之一 - 剩余的连接数“
37. 总连接指每个进程设定的最大连接数，这个数字可以再配置文件中指定。
38. 
39. 所以每个进程到总连接数的7/8后，ngx\_accept\_disabled就大于零，连接超载了
40. 
41. \*/
42. 
43. ngx\_accept\_disabled = ngx\_cycle->connection\_n / 8
44. \- ngx\_cycle->free\_connection\_n;
45. 
46. //获取一个connection
47. c = ngx\_get\_connection(s, ev->log);
48. 
49. //为新的链接创建起一个memory pool
50. //连接关闭的时候，才释放pool
51. 
52. c->pool = ngx\_create\_pool(ls->pool\_size, ev->log);
53. if (c->pool == NULL) \{
54. ngx\_close\_accepted\_connection(c);
55. return;
56. \}
57. 
58. c->sockaddr = ngx\_palloc(c->pool, socklen);
59. if (c->sockaddr == NULL) \{
60. ngx\_close\_accepted\_connection(c);
61. return;
62. \}
63. 
64. ngx\_memcpy(c->sockaddr, sa, socklen);
65. 
66. log = ngx\_palloc(c->pool, sizeof(ngx\_log\_t));
67. if (log == NULL) \{
68. ngx\_close\_accepted\_connection(c);
69. return;
70. \}
71. 
72. /\* set a blocking mode for aio and non-blocking mode for others \*/
73. 
74. if (ngx\_inherited\_nonblocking) \{
75. if (ngx\_event\_flags & NGX\_USE\_AIO\_EVENT) \{
76. if (ngx\_blocking(s) == -1) \{
77. ngx\_log\_error(NGX\_LOG\_ALERT, ev->log, ngx\_socket\_errno,
78. ngx\_blocking\_n " failed");
79. ngx\_close\_accepted\_connection(c);
80. return;
81. \}
82. \}
83. 
84. \} else \{
85. //我们使用epoll模型，这里我们设置连接为nonblocking
86. if (!(ngx\_event\_flags & (NGX\_USE\_AIO\_EVENT|NGX\_USE\_RTSIG\_EVENT))) \{
87. if (ngx\_nonblocking(s) == -1) \{
88. ngx\_log\_error(NGX\_LOG\_ALERT, ev->log, ngx\_socket\_errno,
89. ngx\_nonblocking\_n " failed");
90. ngx\_close\_accepted\_connection(c);
91. return;
92. \}
93. \}
94. \}
95. 
96. \*log = ls->log;
97. //初始化新的连接
98. c->recv = ngx\_recv;
99. c->send = ngx\_send;
100. c->recv\_chain = ngx\_recv\_chain;
101. c->send\_chain = ngx\_send\_chain;
102. 
103. c->log = log;
104. c->pool->log = log;
105. 
106. c->socklen = socklen;
107. c->listening = ls;
108. c->local\_sockaddr = ls->sockaddr;
109. 
110. c->unexpected\_eof = 1;
111. 
112. \#if (NGX\_HAVE\_UNIX\_DOMAIN)
113. if (c->sockaddr->sa\_family == AF\_UNIX) \{
114. c->tcp\_nopush = NGX\_TCP\_NOPUSH\_DISABLED;
115. c->tcp\_nodelay = NGX\_TCP\_NODELAY\_DISABLED;
116. \#if (NGX\_SOLARIS)
117. /\* Solaris's sendfilev() supports AF\_NCA, AF\_INET, and AF\_INET6 \*/
118. c->sendfile = 0;
119. \#endif
120. \}
121. \#endif
122. 
123. rev = c->read;
124. wev = c->write;
125. 
126. wev->ready = 1;
127. 
128. if (ngx\_event\_flags & (NGX\_USE\_AIO\_EVENT|NGX\_USE\_RTSIG\_EVENT)) \{
129. /\* rtsig, aio, iocp \*/
130. rev->ready = 1;
131. \}
132. 
133. if (ev->deferred\_accept) \{
134. rev->ready = 1;
135. \#if (NGX\_HAVE\_KQUEUE)
136. rev->available = 1;
137. \#endif
138. \}
139. 
140. rev->log = log;
141. wev->log = log;
142. 
143. /\*
144. \* TODO: MT: - ngx\_atomic\_fetch\_add()
145. \* or protection by critical section or light mutex
146. \*
147. \* TODO: MP: - allocated in a shared memory
148. \* - ngx\_atomic\_fetch\_add()
149. \* or protection by critical section or light mutex
150. \*/
151. 
152. c->number = ngx\_atomic\_fetch\_add(ngx\_connection\_counter, 1);
153. 
154. if (ngx\_add\_conn && (ngx\_event\_flags & NGX\_USE\_EPOLL\_EVENT) == 0) \{
155. if (ngx\_add\_conn(c) == NGX\_ERROR) \{
156. ngx\_close\_accepted\_connection(c);
157. return;
158. \}
159. \}
160. 
161. log->data = NULL;
162. log->handler = NULL;
163. 
164. /\*
165. 这里listen handler很重要，它将完成新连接的最后初始化工作，
166. 同时将accept到的新的连接放入epoll中；挂在这个handler上的函数，
167. 就是ngx\_http\_init\_connection 在之后http模块中在详细介绍
168. \*/
169. ls->handler(c);
170. 
171. if (ngx\_event\_flags & NGX\_USE\_KQUEUE\_EVENT) \{
172. ev->available--;
173. \}
174. 
175. \} while (ev->available);
176. \}

accpt事件的handler方法也就是如此了。之后就是每个连接的读写事件handler方法，这一部分会直接将我们引入http模块，我们还不急，还要学习下nginx经典模块epoll。

[http_blog.csdn.net_lengzijian_article_details_7601730]: http://blog.csdn.net/lengzijian/article/details/7601730
[1337925963_5996.png]: https://img-my.csdn.net/uploads/201205/25/1337925963_5996.png
[view plain]: https://www.cnblogs.com/h2-database/archive/2012/05/25/2583260.html#