nginx如何根据报文里字段转发至不同地址_https

nginx接收到post请求.请求报文里是一个json字符串，字符串里有个字段id。
根据id不同，转发到不同地址。
如果id=aaa,转发到www.aaa.com.test
如果id=bbb,转发到www.bbb.com.test
如何配置,请提供一个nginx.conf

要在 nginx 中根据 post 请求的 json 负载中的 id 字段的值进行转发，你可以使用 nginx 的 ngx_http_lua_module 模块，这个模块允许你在 nginx 配置中使用 lua 脚本。下面是一个示例配置，它展示了如何根据 post 请求的 json 负载中的 id 字段的值来转发请求。

首先，确保你的 nginx 已经安装了 lua-nginx-module 和 lua-resty-http 库。这些可以通过 openresty 来安装，openresty 是一个集成了常用模块的 nginx 发行版。

安装 openresty

你可以通过以下命令安装 openresty（假设你使用的是基于 debian 的系统，如 ubuntu）：

sudo apt-get update
sudo apt-get install -y curl gnupg2 ca-certificates lsb-release ubuntu-keyring
curl -o https://openresty.org/package/pubkey.gpg
sudo apt-key add pubkey.gpg
sudo apt-get install -y apt-transport-https
echo "deb https://openresty.org/package/debian $(lsb_release -sc) openresty" | sudo tee /etc/apt/sources.list.d/openresty.list
sudo apt-get update
sudo apt-get install -y openresty

nginx 配置 (nginx.conf)

下面是一个示例的 nginx.conf 配置，它使用 lua 脚本来解析 post 请求的 json 负载，并根据 id 字段的值转发请求。

http {
    lua_package_path "/usr/local/openresty/luajit/share/lua/5.1/?.lua;;";
    lua_shared_dict my_cache 10m;
    server {
        listen 80;
        location / {
            content_by_lua_block {
                -- 读取 post 请求体
                ngx.req.read_body()
                local data = ngx.req.get_body_data()
                if not data then
                    ngx.status = ngx.http_bad_request
                    ngx.say("no request body found")
                    return ngx.exit(ngx.http_bad_request)
                end
                -- 解析 json
                local cjson = require "cjson.safe"
                local json_data = cjson.decode(data)
                if not json_data or not json_data.id then
                    ngx.status = ngx.http_bad_request
                    ngx.say("invalid json or missing 'id' field")
                    return ngx.exit(ngx.http_bad_request)
                end
                local id = json_data.id
                local target_url
                if id == "aaa" then
                    target_url = "http://www.aaa.com.test"
                elseif id == "bbb" then
                    target_url = "http://www.bbb.com.test"
                else
                    ngx.status = ngx.http_not_found
                    ngx.say("unknown 'id' value")
                    return ngx.exit(ngx.http_not_found)
                end
                -- 创建 http 客户端并转发请求
                local http = require "resty.http"
                local httpc = http.new()
                local res, err = httpc:request_uri(target_url, {
                    method = ngx.var.request_method,
                    body = data,
                    headers = ngx.req.get_headers(),
                    keepalive = false,
                })
                if not res then
                    ngx.status = ngx.http_internal_server_error
                    ngx.say("failed to forward request: ", err)
                    return ngx.exit(ngx.http_internal_server_error)
                end
                -- 设置响应头
                for k, v in pairs(res.headers) do
                    ngx.header[k] = v
                end
                -- 发送响应体
                ngx.status = res.status
                ngx.print(res.body)
                -- 关闭 http 客户端
                httpc:close()
            }
        }
    }
}

解释