如何在Express路由中转发REST请求响应或拦截处理？

你遇到的问题其实很常见——当使用node-rest-client-promise的getPromise方法时，这个库会自动帮你读取并解析响应体（比如转成JSON或者字符串），这时候响应流已经被消费完毕了，再用response.pipe(res)自然就没内容了；而且状态码没同步，是因为你没手动把外部响应的状态码同步到Express的res对象上。

下面给你两种清晰的解决思路：

一、修复node-rest-client-promise的使用方式 #

如果你坚持用这个库，需要改用它的原始回调模式，避免提前消费响应流，同时手动同步状态码和响应头：

import { Client } from 'node-rest-client-promise';
app.get('/', (req, res, next) => {
  const client = new Client();
  // 改用原始get方法，不要用getPromise，避免自动解析响应体
  client.get(url, { requestConfig: { encoding: null } }, (data, response) => {
    switch (response.statusCode) {
      case 404:
        res.status(200).send('Other results');
        break;
      default:
        // 先同步外部响应的状态码
        res.status(response.statusCode);
        // 同步响应头（跳过Express自动处理的头，避免冲突）
        Object.keys(response.headers).forEach(header => {
          const lowerHeader = header.toLowerCase();
          if (!['transfer-encoding', 'connection', 'content-length'].includes(lowerHeader)) {
            res.setHeader(header, response.headers[header]);
          }
        });
        // 直接将原始响应体（Buffer）发送，或者用流管道
        res.send(data);
        // 也可以尝试response.pipe(res)，但需确保流未被消费
        // response.pipe(res);
        break;
    }
  }).on('error', next); // 务必处理请求错误，避免请求挂起
});

不过说实话，node-rest-client-promise的设计更偏向于快速获取解析后的响应，不是很适合做流代理。如果想要更顺畅的流处理，推荐用下面的方案。

二、改用node-fetch（推荐） #

node-fetch支持直接获取未被消费的响应流，完美适配Express的res对象，代码也更简洁：

import fetch from 'node-fetch';
app.get('/', async (req, res, next) => {
  try {
    const externalRes = await fetch(url);
    if (externalRes.status === 404) {
      res.status(200).send('Other results');
      return;
    }
    // 同步状态码
    res.status(externalRes.status);
    // 同步响应头
    externalRes.headers.forEach((value, key) => {
      const lowerKey = key.toLowerCase();
      if (!['connection', 'transfer-encoding'].includes(lowerKey)) {
        res.setHeader(key, value);
      }
    });
    // 直接管道传输响应流，无需手动处理响应体
    externalRes.body.pipe(res);
  } catch (err) {
    next(err); // 传递错误给Express内置错误处理器
  }
});

这个方案的优势很明显：

• node-fetch的响应对象是标准可读流，未被提前消费，pipe能正常工作
• 响应头和状态码的同步逻辑更直观
• 异步/await语法可读性更强

三、用Axios的流模式（备选） #

如果你习惯用Axios，也可以开启流模式实现相同效果：

import axios from 'axios';
app.get('/', async (req, res, next) => {
  try {
    const externalRes = await axios({
      method: 'get',
      url: url,
      responseType: 'stream' // 关键：设置响应类型为流
    });
    if (externalRes.status === 404) {
      res.status(200).send('Other results');
      return;
    }
    res.status(externalRes.status);
    // 同步响应头
    Object.keys(externalRes.headers).forEach(key => {
      const lowerKey = key.toLowerCase();
      if (!['connection', 'transfer-encoding'].includes(lowerKey)) {
        res.setHeader(key, externalRes.headers[key]);
      }
    });
    externalRes.data.pipe(res);
  } catch (err) {
    next(err);
  }
});

关键注意事项 #

• 同步响应头时，要跳过Connection、Transfer-Encoding这类Express自动管理的头，避免出现响应冲突
• 确保外部响应的流未被提前消费，这是pipe能正常传输内容的核心
• 一定要处理请求错误，把错误传递给Express的错误处理器（next(err)），防止请求挂起导致资源泄漏

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