如何从Node的IncomingMessage中获取ReadableStream传递给node-fetch

核心结论 #

Node.js 原生的 IncomingMessage 本身就是 stream.Readable 的子类，而你使用的 node-fetch v2.x（Node v14 兼容的官方稳定版本）明确支持传入 Node.js 可读流作为 body 参数，因此无需额外编写转换函数，直接传入即可实现零内存拷贝的流式转发，完全满足你最小化内存消耗的需求。

完整实现代码 #

const fetch = require('node-fetch');
const { createServer } = require('http');

const server = createServer(async (req, res) => {
  // 过滤GET、HEAD这类无请求体的方法
  const hasBody = !['GET', 'HEAD'].includes(req.method.toUpperCase());
  try {
    const downstreamRes = await fetch('http://example.com', {
      method: req.method,
      body: hasBody ? req : null,
      headers: {
        // 透传请求体相关的必要头，保证下游能正确解析内容
        'content-type': req.headers['content-type'],
        'content-length': req.headers['content-length'],
        // 其他需要透传的请求头可自行添加
      }
    });
    // 下游响应也用流式回传，进一步降低内存占用
    res.writeHead(downstreamRes.status, Object.fromEntries(downstreamRes.headers.entries()));
    downstreamRes.body.pipe(res);
  } catch (err) {
    res.writeHead(503);
    res.end('Proxy failed: ' + err.message);
  }
});

server.listen(3000);

特殊场景适配：转Web标准ReadableStream #

如果你使用的是 node-fetch v3+ 版本，要求传入Web标准的ReadableStream，可以使用Node v14.18及以上内置的转换方法：

const { Readable } = require('stream');

function toReadableStream(req) {
  // 将Node原生可读流转换为Web标准ReadableStream
  return Readable.toWeb(req);
}

注意事项 #

• 禁止在转发前使用body-parser这类请求体解析中间件，这类中间件会提前消费完IncomingMessage的流内容，导致转发的body为空。
• 如果原始请求携带content-encoding压缩头，要么直接透传该头，要么先对请求体做解压处理，避免下游无法识别内容。
• 生产环境使用建议添加流错误监听和超时逻辑，避免异常请求占用连接资源。

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