基于API响应实现NGINX动态proxy_pass的技术求助

核心问题分析 #

原方案无法运行的原因有两点：

1. ngx_http_js_module的js_set仅支持同步函数，无法处理async/await这类异步逻辑
2. 你的API返回的是纯文本格式（如127.0.0.1:43435），但JS代码错误使用res.json()解析，会直接导致解析失败

推荐解决方案：使用OpenResty的ngx_http_lua_module #

OpenResty基于NGINX扩展，提供完整的Lua协程支持，能在不阻塞Worker进程的前提下完成异步API调用，同时完美支持WebSockets代理。

步骤1：安装OpenResty

确保服务器安装OpenResty（可直接替代原生NGINX，或在原生NGINX中编译集成该模块）。

步骤2：NGINX配置示例

http {
    # 加载OpenResty Lua库路径（根据实际安装路径调整）
    lua_package_path "/usr/local/openresty/lualib/?.lua;;";

    server {
        listen 80;
        # 匹配任意用户自定义Host
        server_name ~^(?<user_host>.+)$;

        location / {
            # 在access阶段执行Lua逻辑，动态获取上游地址
            access_by_lua_block {
                local http = require "resty.http"
                local httpc = http.new()

                # 调用本地API获取目标主机地址
                local res, err = httpc:request_uri(
                    "http://localhost:5555/check?host=" .. ngx.var.server_name,
                    { method = "GET", keepalive_timeout = 60, keepalive_pool = 10 }
                )

                # 处理API调用失败或异常响应
                if not res or res.status ~= 200 then
                    ngx.log(ngx.ERR, "Failed to fetch upstream: ", err or res.status)
                    ngx.var.upstream = "https://example.com/"
                else
                    # 清理响应文本中的换行/空格，得到干净的IP:Port格式
                    local upstream_addr = string.gsub(res.body, "%s+", "")
                    ngx.log(ngx.INFO, "Upstream for ", ngx.var.server_name, ": ", upstream_addr)
                    ngx.var.upstream = upstream_addr
                end
            }

            # 核心代理配置，包含WebSockets支持
            proxy_pass http://$upstream;
            proxy_http_version 1.1;
            # 开启WebSockets升级支持
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection "upgrade";
            # 传递必要的请求头
            proxy_set_header Host $host;
            proxy_set_header X-Real-IP $remote_addr;
            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;

            # 上游不可用时跳转fallback地址
            proxy_intercept_errors on;
            error_page 502 503 504 = @fallback;
        }

        # 异常fallback地址
        location @fallback {
            proxy_pass https://example.com/;
        }
    }
}

方案优势 #

1. 异步无阻塞：Lua协程实现的HTTP请求不会阻塞NGINX Worker进程，高并发场景下性能更优
2. 完善的错误处理：覆盖API调用失败、响应异常、上游不可用等场景
3. 原生支持WebSockets：通过设置Upgrade和Connection头，解决之前的WebSockets限制问题
4. 动态路由适配：自动根据请求的Host匹配对应的后端容器地址

可选替代方案（原生NGINX） #

如果无法使用OpenResty，可尝试结合ngx_http_subrequest_module和共享内存存储，但实现复杂度高且性能不如Lua方案，不推荐在高并发场景下使用。

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