如何在OpenResty中实现每次调用上游时解析AWS ELB的IP

这个问题确实是OpenResty/Nginx在对接AWS ELB时的常见痛点——因为ELB的IP是动态变化的，默认的启动时解析缓存完全跟不上节奏。下面给你几个可行的解决方案，从简单到灵活排序：

方法1：使用resolver指令+变量实现自动DNS刷新 #

这是最轻量化的方案，利用Nginx核心模块的resolver功能，配合变量触发每次请求的DNS解析（并设置合理的缓存过期时间）。

配置示例：

http {
    # 配置DNS服务器，可选用Google公共DNS、AWS Route 53或内部DNS
    resolver 8.8.8.8 valid=30s; 
    # 定义ELB域名变量
    set $elb_domain "your-elb-endpoint.amazonaws.com";

    server {
        listen 80;

        location / {
            # 用变量作为上游地址，触发动态解析
            proxy_pass http://$elb_domain;
            # 必须设置Host头为ELB域名，否则ELB可能无法正确路由
            proxy_set_header Host $elb_domain;
            
            # 其他常规proxy配置（按需添加）
            proxy_connect_timeout 5s;
            proxy_send_timeout 10s;
            proxy_read_timeout 10s;
        }
    }
}

关键说明：

• valid=30s表示DNS解析结果的缓存时间，可根据ELB IP变更频率调整（建议15s到1分钟之间）
• 使用变量$elb_domain代替固定的server指令，会让Nginx在每次请求时检查DNS缓存是否过期，过期则自动重新解析

方法2：用OpenResty Lua模块手动控制DNS解析 #

如果需要更精细化的控制（比如自定义解析失败重试、缓存逻辑），可以用resty.dns.resolver模块在Lua代码中主动解析ELB域名。

配置示例：

http {
    resolver 8.8.8.8;

    server {
        listen 80;

        location / {
            content_by_lua_block {
                local resolver = require "resty.dns.resolver"
                -- 初始化DNS解析器
                local dns_resolver, err = resolver:new{
                    nameservers = {"8.8.8.8", "8.8.4.4"},
                    retrans = 2,  -- DNS请求重试次数
                    timeout = 500, -- 单次请求超时（毫秒）
                }

                if not dns_resolver then
                    ngx.log(ngx.ERR, "DNS解析器初始化失败: ", err)
                    return ngx.exit(500)
                end

                -- 解析ELB域名的A记录
                local dns_answers, err = dns_resolver:query("your-elb-endpoint.amazonaws.com", {qtype = dns_resolver.TYPE_A})
                if not dns_answers or dns_answers.errcode then
                    local err_msg = err or string.format("DNS错误码: %s, 原因: %s", dns_answers.errcode, dns_answers.errstr)
                    ngx.log(ngx.ERR, "ELB域名解析失败: ", err_msg)
                    return ngx.exit(500)
                end

                -- 取第一个有效IP（ELB通常会返回多个IP）
                local elb_ip = dns_answers[1].address
                -- 构造上游请求地址
                local upstream_url = "http://" .. elb_ip .. ngx.var.request_uri

                -- 转发请求到ELB IP
                local proxy_res, err = ngx.location.capture(upstream_url)
                if not proxy_res then
                    ngx.log(ngx.ERR, "请求转发失败: ", err)
                    return ngx.exit(500)
                end

                -- 回写响应状态、头和内容
                ngx.status = proxy_res.status
                for k, v in pairs(proxy_res.header) do
                    ngx.header[k] = v
                end
                ngx.say(proxy_res.body)
            }
        }
    }
}

关键说明：

• 这种方式可以完全自定义解析逻辑，比如把解析结果缓存到ngx.shared.DICT中，自己控制缓存过期时间
• 如果ELB返回多个IP，还可以实现简单的负载均衡逻辑（比如随机选取）

方法3：用动态上游管理库实现定时刷新 #

如果需要管理多个ELB IP并实现负载均衡，可以用lua-resty-upstream库配合定时任务，定期刷新上游服务器池。

步骤概要： #

1. 安装lua-resty-upstream（可通过OpenResty的包管理器opm安装，或手动下载源码到OpenResty的Lua库路径）
2. 配置共享字典存储上游信息
3. 编写定时任务，定期解析ELB域名并更新上游池
4. 请求时从上游池中选取IP转发

配置示例：

http {
    # 定义共享字典，用于存储上游服务器信息
    lua_shared_dict upstream_cache 1m;

    # 初始化上游对象
    init_by_lua_block {
        local upstream = require "resty.upstream"
        local elb_upstream = upstream:new("elb_upstream")
        ngx.shared.upstream_cache:set("elb_upstream", elb_upstream)
    }

    # 启动定时任务，每30秒刷新一次ELB IP
    init_worker_by_lua_block {
        local resolver = require "resty.dns.resolver"
        local upstream = require "resty.upstream"

        local refresh_interval = 30 -- 刷新间隔（秒）
        local elb_domain = "your-elb-endpoint.amazonaws.com"

        local ok, err = ngx.timer.every(refresh_interval, function(premature)
            if premature then return end

            -- 初始化DNS解析器
            local dns_resolver, err = resolver:new{
                nameservers = {"8.8.8.8"},
                timeout = 500,
            }
            if not dns_resolver then
                ngx.log(ngx.ERR, "DNS解析器初始化失败: ", err)
                return
            end

            -- 解析ELB域名
            local dns_answers, err = dns_resolver:query(elb_domain, {qtype = dns_resolver.TYPE_A})
            if not dns_answers or dns_answers.errcode then
                local err_msg = err or string.format("DNS错误码: %s, 原因: %s", dns_answers.errcode, dns_answers.errstr)
                ngx.log(ngx.ERR, "ELB域名解析失败: ", err_msg)
                return
            end

            -- 获取上游对象并更新服务器池
            local elb_upstream = ngx.shared.upstream_cache:get("elb_upstream")
            elb_upstream:clear() -- 清空旧IP

            -- 添加所有解析到的ELB IP到上游池
            for _, ans in ipairs(dns_answers) do
                if ans.address then
                    elb_upstream:add_server(ans.address .. ":80", 10) -- 权重设为10
                end
            end
        })

        if not ok then
            ngx.log(ngx.ERR, "定时任务创建失败: ", err)
        end
    }

    server {
        listen 80;

        location / {
            content_by_lua_block {
                local upstream = require "resty.upstream"
                local elb_upstream = ngx.shared.upstream_cache:get("elb_upstream")

                -- 用轮询策略选取上游服务器
                local server, err = elb_upstream:get_round_robin_server()
                if not server then
                    ngx.log(ngx.ERR, "获取上游服务器失败: ", err)
                    return ngx.exit(500)
                end

                -- 转发请求
                local upstream_url = "http://" .. server.address .. ngx.var.request_uri
                local proxy_res, err = ngx.location.capture(upstream_url)
                if not proxy_res then
                    ngx.log(ngx.ERR, "请求转发失败: ", err)
                    return ngx.exit(500)
                end

                -- 回写响应
                ngx.status = proxy_res.status
                for k, v in pairs(proxy_res.header) do
                    ngx.header[k] = v
                end
                ngx.say(proxy_res.body)
            }
        }
    }
}

关键说明：

• 这种方式适合ELB返回多个IP的场景，能实现负载均衡，同时保证上游池始终是最新的IP
• 定时任务的刷新间隔可以根据实际需求调整

总结 #

• 如果你只需要简单解决动态IP问题，方法1是最优选择，配置简单且不需要额外依赖
• 如果需要自定义解析或缓存逻辑，方法2更灵活
• 如果需要负载均衡多个ELB IP，方法3是最合适的方案

内容的提问来源于stack exchange，提问作者Bilal Ahmad