如何在Next.js/Node中正确转发第三方API的成功与失败响应？

我来帮你解决这个问题——你当前的代码只是简单地把axios响应或错误对象传给res.send()，但这样并没有正确提取并转发第三方API的状态码、响应头和完整响应体。下面是改进后的实现，能完美处理成功和失败场景下的所有响应细节：

// pages/api/my-endpoint.js
import axios from 'axios';

export default async (req, res) => {
  try {
    // 从客户端请求中获取要转发的数据（根据请求方法调整，POST用req.body，GET用req.query）
    const requestData = req.method === 'GET' ? req.query : req.body;

    // 发起请求到第三方API，配置validateStatus避免axios自动抛出非2xx错误
    const thirdPartyResponse = await axios({
      method: req.method,
      url: 'some-url',
      data: requestData,
      headers: {
        // 这里可以添加第三方API需要的认证头，比如密钥（从环境变量读取，安全不暴露给客户端）
        // Authorization: `Bearer ${process.env.THIRD_PARTY_API_KEY}`
      },
      validateStatus: () => true, // 接受所有状态码，我们自己处理响应
      responseType: 'stream' // 用流式传输更高效，支持大文件/大响应体
    });

    // 1. 转发所有第三方API的响应头
    Object.entries(thirdPartyResponse.headers).forEach(([headerKey, headerValue]) => {
      res.setHeader(headerKey, headerValue);
    });

    // 2. 设置和第三方API一致的响应状态码
    res.status(thirdPartyResponse.status);

    // 3. 流式转发响应体（比手动读取后send更高效）
    thirdPartyResponse.data.pipe(res);
  } catch (error) {
    // 处理请求失败的情况：分两种场景
    if (error.response) {
      // 场景1：第三方API返回了错误响应（有状态码、头和响应体）
      Object.entries(error.response.headers).forEach(([headerKey, headerValue]) => {
        res.setHeader(headerKey, headerValue);
      });
      res.status(error.response.status).send(error.response.data);
    } else {
      // 场景2：请求根本没到达第三方API（比如网络超时、DNS失败）
      res.status(503).json({ error: 'Failed to connect to the third-party service' });
    }
  }
};

关键细节说明： #

• 获取客户端请求数据：根据请求方法（GET/POST/PUT等）从req.query或req.body读取要转发给第三方API的数据，原来的代码里data变量未定义，这是一个潜在问题。
• Axios配置validateStatus：默认Axios会把非2xx的状态码当成错误抛出，设置validateStatus: () => true后，我们可以自己处理所有状态的响应，包括4xx、5xx，确保这些状态码能正确转发给客户端。
• 转发响应头：遍历第三方API的所有响应头，用res.setHeader设置到Next.js的响应中，这样MIME类型、缓存头、认证相关头都能完整传递。
• 流式响应体：用pipe方法直接把第三方API的响应数据流传给Next.js的res对象，比手动读取response.data后再res.send()更高效，尤其适合处理大文件或大量数据的场景。如果只处理JSON响应，也可以用res.send(thirdPartyResponse.data)，但流式方案更通用。
• 错误处理细分：
  • 当error.response存在时，说明第三方API已经返回了错误响应，我们同样转发它的状态码、头和响应体。
  • 当error.response不存在时，说明是请求层面的错误（比如网络问题），返回503服务不可用状态码和自定义错误信息。

额外注意事项： #

• CORS配置：如果你的Next.js API端点需要接受跨域请求，可以手动设置res.setHeader('Access-Control-Allow-Origin', '*')（或指定允许的域名），或者使用cors包简化配置。
• 请求方法支持：上面的代码通过req.method动态匹配第三方API的请求方法，支持GET、POST、PUT等所有HTTP方法，比硬编码axios.post更灵活。
• 敏感信息保护：把第三方API的密钥、认证信息放在Next.js的环境变量（.env.local）中，在API端点里使用，避免暴露给客户端，这也是用Next.js做代理的核心安全价值。

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