您现在的位置是:首页 > 正文

nginx源码分析—reuseport的使用

2024-04-01 01:39:16阅读 2

本文主要介绍nginx中reuseport的使用,文中代码较多,阅读本文需要读者对nginx事件模块以及nginx配置过程有了解。

由于nginx比较复杂,且笔者对nginx的理解有限,文章难免存在疏忽之处,敬请指出,万分感谢!

一、reuseport的配置及解析

reuseport通过listen指令来配置,配置如下:

listen 443 reuseport;

listen指令由ngx_http_core_module模块的ngx_http_core_listen() 函数进行解析。
ngx_http_core_module.c的相关解析命令如下:

{ ngx_string("listen"),
      NGX_HTTP_SRV_CONF|NGX_CONF_1MORE, //listen指令只能配置在server块中,至少携带一个参数(443,reuseport等等)
      ngx_http_core_listen, //解析listen指令的函数
      NGX_HTTP_SRV_CONF_OFFSET, 
      0,
      NULL },

由于篇幅限制,下面仅介绍reuseport相关的解析,不完全介绍listen指令的解析。

// 解析listen指令携带的参数,从第二个参数开始(第一个参数为ip+port)
for (n = 2; n < cf->args->nelts; n++) {
	...
	if (ngx_strcmp(value[n].data, "bind") == 0) {
       lsopt.set = 1;
       lsopt.bind = 1; //强制对此ip+port进行bind操作,如不配置bind,可能会忽略此ip+port,后续会介绍忽略的情况
       continue;
    }
	
	//解析到reuseport配置,将reuseport标志置为1,同时将bind也置为1
	if (ngx_strcmp(value[n].data, "reuseport") == 0) {
        lsopt.reuseport = 1;
        lsopt.set = 1;
        lsopt.bind = 1;
        continue;
    }
	...
}

二、创建listening结构

master解析完http block之后会掉用ngx_http_optimize_servers()函数对配置的ip+port进行相应的处理,主要进行下面两个操作:

1、检查所有当前http block下的listen配置是否存在重复,即是否存在两个listen指令配置了相同的ip + port + server_name。如果存在重复的配置则会忽略靠后的ip+port+server_name的配置。检查由ngx_http_server_names()函数完成,此处并不详细介绍,有兴趣可自行查阅相应代码。

2、根据解析的配置创建listening结构,master后续监听的端口均由listening获得,每个listening结构对应一次bind + listening操作,此处重点介绍listening的创建。

首先ngx_http_optimize_servers()函数调用ngx_http_init_listening()函数,ngx_http_init_listening()代码如下:

static ngx_int_t
ngx_http_init_listening(ngx_conf_t *cf, ngx_http_conf_port_t *port)
{
    ngx_uint_t                 i, last, bind_wildcard;
    ngx_listening_t           *ls;
    ngx_http_port_t           *hport;
    ngx_http_conf_addr_t      *addr;

/*
以下是port的存储结构,一个port对应多个addrs(即port+ip),一个addr对应多个server(即server_name)
port - > addr1----|-----> server1
         addr2    |-----> server2
         addr3
    	  ...

*/

    addr = port->addrs.elts; //取出port的所有addr,一个port可能对应多个ip+port
    last = port->addrs.nelts; //port中addr的个数

	//每一个port的addr都已经排序了(插入排序),ip为通配符(INADDR_ANY)的addr在最后面,配置了bind的addr在前面
    if (addr[last - 1].opt.wildcard) {
        addr[last - 1].opt.bind = 1;
        bind_wildcard = 1;

    } else {
        bind_wildcard = 0;
    }

    i = 0;

    while (i < last) {
   
        //该port存在内容为INADDR_ANY+port的addr,若当前addr(ip+port)没有配置bind,则不需要显示地对当前ip+addr进行监听
        if (bind_wildcard && !addr[i].opt.bind) { 
            i++;
            continue;
        }

        ls = ngx_http_add_listening(cf, &addr[i]); //为当前ip+port创建一个listening结构,用于监听
        if (ls == NULL) {
            return NGX_ERROR;
        }

        hport = ngx_pcalloc(cf->pool, sizeof(ngx_http_port_t));
        if (hport == NULL) {
            return NGX_ERROR;
        }

       /*
       以下代码将上面提到的不需要监听的ip+port的相关配置存储到最后的addr(INADDR_ANY+port)中,便于收到连接请求时,可以找到正确的配置。
       但是存在一个问题,对于ip+port存在多个server的情况,在建立连接时ngx_http_init_connection()中只能取到ip+port的default_server。
       */
        ls->servers = hport;

        hport->naddrs = i + 1;

        switch (ls->sockaddr->sa_family) {

#if (NGX_HAVE_INET6)
        case AF_INET6:
            if (ngx_http_add_addrs6(cf, hport, addr) != NGX_OK) {
                return NGX_ERROR;
            }
            break;
#endif
    

网站文章

  • QNX中mmap_device_io() 和 mmap_device_memory()函数

    来源于QNX IDE 1、mmap_device_io() 1)函数定义 #include #include uintptr_t mmap_device_io( size_t len, uint64_t io ); len The number of bytes of device I/O memory that you want to access. It can&#39;..

    2024-04-01 01:39:08
  • 位运算的一些技巧

    位运算的一些技巧

    1. 两个数异或:相当于每一位相加,而不考虑进位; 2. 两个数相与,并左移一位:相当于求得进位; 3. 一个数n与其减一的数相与(即n&amp;(n-1)),等价于去掉最左边的1 如n=10二进制为1010,n&amp;(n-1)=1000 应用以上技巧可以解决一些算法题: 下面是剑指offer上的一道题: class Solution { public: int Add(int n...

    2024-04-01 01:39:00
  • 互联互通、电子病历、智慧服务、智慧管理、公立医院绩效考核的5项测评

    互联互通、电子病历、智慧服务、智慧管理、公立医院绩效考核的5项测评

    互联互通、电子病历、智慧服务、智慧管理、公立医院绩效考核的5项测评

    2024-04-01 01:38:35
  • C++ 笔记 shared_from_this()的原理与使用

    shared_from_this()的用途 enable_shared_from_this是一个模板类,定义于头文件,其原型为: template&lt; class T &gt; class enable_shared_from_this; std::enable_shared_from_this 能让一个对象(假设其名为 t ,且已被一个 st...

    2024-04-01 01:38:27
  • Windows10登录不上Micrsoft账户,解决办法

    Windows10登录不上Micrsoft账户,解决办法

    原文 1 问题 在登录Windows账户时,出现了以下错误: [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-GJIEFAWY-1641732153972)(https:...

    2024-04-01 01:38:16
  • HTML分组标签fieldset

    HTML分组标签fieldset

    1、标签: 2、作用: (1)可以将表单内的相关元素分组; (2)会在相关表单元素周围绘制边框; 3、语法 组的名字 内容 4、案例 个人信息: 姓名:

    2024-04-01 01:37:51
  • oracle adf取不到表中的控件,[导入]使用oracle adf 的一点经验(一)

    目前使用oracle adf 框架 10.1.3 版本1 adf 的源代码 (交付给apache 的)2. 其实我把 adf-faces-api adf-faces-impl.jar 用jad 解码出...

    2024-04-01 01:37:43
  • 关于不修改android:debuggable进行动态调试

    有时候手动修改导致程序再打包失败其他的方法又局限性,所以采用buildprop插件来完成https://repo.xposed.info/module/com.jecelyin.buildprop转载于:https://blog.51cto.com/13652962/2358860...

    2024-04-01 01:37:36
  • vue 路由守卫 解析

    路由跳转有两种方式1、方式,2、编程式跳转。路由守卫控制路由在符合某种条件下才能完成跳转。后置,在跳转之后判断,不管符不符合,路由都会跳转,浏览器地址栏都会变化,多用于跳转后修改页签标题等。中,亦或者...

    2024-04-01 01:37:11
  • k8s集群搭建EFK日志平台:ElasticSearch + Fluentd + Kibana

    k8s集群搭建EFK日志平台:ElasticSearch + Fluentd + Kibana

    k8s集群 kubectl get node EFK简介 ElasticSearch:分布式存储检索引擎,用来搜索、存储日志 Fluentd:日志采集 Kibana:读取es中数据进行可视化web界面...

    2024-04-01 01:37:04