微信公衆號:鄭爾多斯
關注可瞭解更多的Nginx知識。任何問題或建議,請公衆號留言;
關注公衆號,有趣有內涵的文章第一時間送達!nginx
本篇文章主要是分析配置文件解析完畢以後對listen
的進一步優化。這一部分主要完成了端口的初始化以及打開操做。數組
在ngx_http_block()
中有下面的一部分代碼,以下:微信
1 /* optimize the lists of ports, addresses and server names */
2
3if (ngx_http_optimize_servers(cf, cmcf, cmcf->ports) != NGX_OK) {
4 return NGX_CONF_ERROR;
5}
複製代碼
從上面的代碼註釋中能夠看出來,ngx_http_optimize_servers()
函數的做用就是對咱們監聽的端口,address以及server name進行優化處理的,下面咱們結合本身的例子分析一下這個方法。
先把咱們解析完http
指令以後的內存結構圖放出來:
app
先看一下源碼,以下:函數
1static ngx_int_t
2ngx_http_optimize_servers(ngx_conf_t *cf, ngx_http_core_main_conf_t *cmcf, ngx_array_t *ports)
3{
4 ngx_uint_t p, a;
5 ngx_http_conf_port_t *port;
6 ngx_http_conf_addr_t *addr;
7
8 if (ports == NULL) {
9 return NGX_OK;
10 }
11
12 port = ports->elts;
13//遍歷全部的ports數組
14 for (p = 0; p < ports->nelts; p++) {
15// 對每一個port下的全部addr進行排序
16 ngx_sort(port[p].addrs.elts, (size_t) port[p].addrs.nelts,
17 sizeof(ngx_http_conf_addr_t), ngx_http_cmp_conf_addrs);
18
19 /*
20 * check whether all name-based servers have the same
21 * configuration as a default server for given address:port
22 */
23
24 addr = port[p].addrs.elts;
25 for (a = 0; a < port[p].addrs.nelts; a++) {
26
27 if (addr[a].servers.nelts > 1
28#if (NGX_PCRE)
29 || addr[a].default_server->captures
30#endif
31 )
32 {
33 if (ngx_http_server_names(cf, cmcf, &addr[a]) != NGX_OK) {
34 return NGX_ERROR;
35 }
36 }
37 }
38
39 if (ngx_http_init_listening(cf, &port[p]) != NGX_OK) {
40 return NGX_ERROR;
41 }
42 }
43
44 return NGX_OK;
45}
複製代碼
從上面的代碼中能夠看到,nginx會遍歷全部的port,而後對每一個遍歷到的port調用ngx_sort()
進行排序,使用的排序函數爲ngx_http_cmp_conf_addrs()
,該函數以下:優化
1ngx_http_cmp_conf_addrs(const void *one, const void *two)
2{
3 ngx_http_conf_addr_t *first, *second;
4
5 first = (ngx_http_conf_addr_t *) one;
6 second = (ngx_http_conf_addr_t *) two;
7
8 if (first->opt.wildcard) {
9 /* a wildcard address must be the last resort, shift it to the end */
10 return 1;
11 }
12
13 if (second->opt.wildcard) {
14 /* a wildcard address must be the last resort, shift it to the end */
15 return -1;
16 }
17
18 if (first->opt.bind && !second->opt.bind) {
19 /* shift explicit bind()ed addresses to the start */
20 return -1;
21 }
22
23 if (!first->opt.bind && second->opt.bind) {
24 /* shift explicit bind()ed addresses to the start */
25 return 1;
26 }
27
28 /* do not sort by default */
29
30 return 0;
31}
複製代碼
從代碼中能夠看到排序規則:ui
- 若是first addr是wildcard,那麼這個addr排在後面second的後面,這一句就說明wildcard 屬性要排在全部的地址的後面。
- 若是first addr不是wildcard,可是second 是wildcard,那麼first排在second的前面,也就是說wildcard類型的要排在 非wildcard後面
- 若是 first和second 都不是wildcard,可是first有bind屬性,而second沒有bind屬性,那麼first排在second的前面,這個規則說明bind屬性要排在非bind的前面。
- 若是first和second都不是wildcard,可是first沒有bind屬性,而second有bind屬性,那麼frist排在second的後面,也是爲了說明bind要排在前面。
- 其餘狀況的排序規則不變
上圖是排序以後的樣式,不過因爲咱們只有一個addr,因此這裏並無這麼麻煩。spa
咱們真正要關心的是這個函數,它對我麼監聽的端口進行了處理:code
1static ngx_int_t
2ngx_http_init_listening(ngx_conf_t *cf, ngx_http_conf_port_t *port)
3{
4 ngx_uint_t i, last, bind_wildcard;
5 ngx_listening_t *ls;
6 ngx_http_port_t *hport;
7 ngx_http_conf_addr_t *addr;
8
9 addr = port->addrs.elts;
10// 在本例子中last = 1
11 last = port->addrs.nelts;
12
13 /*
14 * If there is a binding to an "*:port" then we need to bind() to
15 * the "*:port" only and ignore other implicit bindings. The bindings
16 * have been already sorted: explicit bindings are on the start, then
17 * implicit bindings go, and wildcard binding is in the end.
18 */
19
20 if (addr[last - 1].opt.wildcard) {
21 addr[last - 1].opt.bind = 1;
22 bind_wildcard = 1;
23
24 } else {
25 bind_wildcard = 0;
26 }
27
28 i = 0;
29
30 while (i < last) {
31
32 if (bind_wildcard && !addr[i].opt.bind) {
33 i++;
34 continue;
35 }
36
37 ls = ngx_http_add_listening(cf, &addr[i]);
38 if (ls == NULL) {
39 return NGX_ERROR;
40 }
41
42 hport = ngx_pcalloc(cf->pool, sizeof(ngx_http_port_t));
43 if (hport == NULL) {
44 return NGX_ERROR;
45 }
46
47 ls->servers = hport;
48
49 hport->naddrs = i + 1;
50
51 switch (ls->sockaddr->sa_family) {
52
53#if (NGX_HAVE_INET6)
54 case AF_INET6:
55 if (ngx_http_add_addrs6(cf, hport, addr) != NGX_OK) {
56 return NGX_ERROR;
57 }
58 break;
59#endif
60 default: /* AF_INET */
61 if (ngx_http_add_addrs(cf, hport, addr) != NGX_OK) {
62 return NGX_ERROR;
63 }
64 break;
65 }
66
67 if (ngx_clone_listening(cf, ls) != NGX_OK) {
68 return NGX_ERROR;
69 }
70
71 addr++;
72 last--;
73 }
74
75 return NGX_OK;
76}
複製代碼
預知後事如何,且聽下文分解orm
喜歡本文的朋友們,歡迎長按下圖關注訂閱號鄭爾多斯,更多精彩內容第一時間送達