如何在Nginx中拦截proxy_pass返回的响应并根据响应体错误码修改HTTP状态码？

当然可以做到！你提到的njs模块其实就是解决这个问题的最佳方案之一，大概率是之前配置的时候没找对正确的姿势。我来给你详细拆解具体的实现步骤：

第一步：确保Nginx已启用njs模块 #

如果是通过包管理器安装的Nginx，比如Debian/Ubuntu可以安装nginx-module-njs，RHEL/CentOS则是nginx-mod-njs；如果是源码编译，要加上--add-module=path/to/njs/nginx编译参数。

第二步：编写njs响应处理脚本 #

创建一个比如response-modifier.js的脚本文件，放在Nginx能访问的路径下，内容如下：

function modifyResponse(r) {
    // 逐步收集完整的响应体数据
    let responseBody = '';
    r.on('body', (chunk) => {
        responseBody += chunk.toString();
    });

    // 响应体收集完成后处理
    r.on('end', () => {
        try {
            // 解析API返回的JSON响应
            const apiResponse = JSON.parse(responseBody);
            // 这里要根据实际API的JSON结构调整字段路径
            // 比如假设错误码在 apiResponse.error.code 字段
            const errorStatusCode = apiResponse.error?.code;

            // 如果提取到了4xx/5xx级别的错误码，修改HTTP状态码
            if (errorStatusCode && errorStatusCode >= 400) {
                r.status = errorStatusCode;
            }

            // 将处理后的响应返回给客户端
            r.sendHeader();
            r.send(responseBody);
            r.finish();
        } catch (err) {
            // 如果JSON解析失败（比如响应不是合法JSON），直接返回原响应
            r.sendHeader();
            r.send(responseBody);
            r.finish();
        }
    });
}

export default {modifyResponse};

第三步：配置Nginx引用脚本并拦截响应 #

在Nginx的http块中导入刚才的脚本：

js_import /etc/nginx/response-modifier.js; # 替换成你的实际脚本路径

然后在对应的proxy_pass location块中添加响应拦截配置：

location /your-proxy-path {
    proxy_pass https://third-party-api.example.com;

    # 使用njs脚本处理响应体
    js_body_filter response-modifier.modifyResponse;

    # 可选但建议：清除原响应的Content-Length，避免状态码修改后出现长度不匹配问题
    proxy_set_header Accept-Encoding "";
    proxy_hide_header Content-Length;
}

关键注意事项 #

• 适配API的JSON结构：一定要根据第三方API实际返回的JSON字段调整脚本里的错误码提取逻辑，比如如果错误码在apiResponse.status里，就把apiResponse.error?.code改成对应的路径。
• 响应体收集逻辑：因为Nginx的响应体是分块传输的，必须在end事件里处理完整的响应体，不能直接在body事件里解析，否则会因为JSON不完整报错。
• 备选方案：OpenResty + Lua：如果你使用OpenResty（Nginx的扩展发行版），也可以用lua-nginx-module实现类似逻辑，灵活性更高，但njs是Nginx官方模块，不需要额外安装OpenResty，更轻量化。

你之前尝试njs没成功，可能是没正确使用js_body_filter指令，或者脚本里的JSON解析路径不对，按照上面的步骤调整应该就能解决问题啦。

备注：内容来源于stack exchange，提问作者Dan F.