Node.js中如何读取http.IncomingMessage（ReadableStream）内容且不消耗流？

要解决读取http.IncomingMessage内容后仍能转发请求的问题，核心是将已读取的请求数据重新注入到一个新的可读流中，同时保留原请求的所有元数据（如headers、method等）。以下是具体实现：

步骤1：编写读取并重置流的函数 #

这个函数会收集请求的原始Buffer数据，转换为可读字符串后，返回内容和一个包含已读数据的新请求流：

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

async function getRequestContent(req) {
  return new Promise((resolve, reject) => {
    const bufferChunks = [];

    // 收集所有请求数据的Buffer块
    req.on('data', (chunk) => bufferChunks.push(chunk));
    // 流结束时处理数据并生成新的请求流
    req.on('end', () => {
      // 将Buffer数组拼接为完整内容字符串
      const content = Buffer.concat(bufferChunks).toString('utf8');
      // 创建新的可读流，注入已收集的Buffer数据
      const resetReq = Readable.from(bufferChunks);
      // 复制原请求的所有属性到新流（保留请求元数据）
      Object.assign(resetReq, req);
      
      resolve({ content, req: resetReq });
    });
    // 处理流读取错误
    req.on('error', (err) => reject(err));
  });
}

步骤2：修改代理代码使用新函数 #

在代理逻辑中，使用上述函数获取内容后，用新生成的请求流进行转发：

const http = require('http');
const httpProxy = require('http-proxy');

const proxy = httpProxy.createProxyServer({
  target: 'http://127.0.0.1:7545'
});

const server = http.createServer(async (req, res) => {
  try {
    const { content, req: resetReq } = await getRequestContent(req);
    
    console.log(`${content} - processing request!`);
    // 使用重置后的请求流执行转发
    proxy.web(resetReq, res);
  } catch (err) {
    console.error('读取请求内容失败:', err);
    res.writeHead(500);
    res.end('Internal Server Error');
  }
});

// 启动代理服务器，监听3000端口
server.listen(3000, () => {
  console.log('代理服务器运行在 http://localhost:3000');
});

关键原理说明 #

• 原问题中直接消费流后无法转发，是因为http.IncomingMessage是一次性可读流，数据被读取后就会被清空。
• 通过收集原始Buffer并创建新的可读流，我们相当于把已读取的数据"回放"了一遍，同时保留了原请求的所有属性，确保http-proxy能正常识别请求的方法、路径、头等信息。
• 使用Buffer而不是直接转字符串，能避免编码丢失问题，保证后续转发的数据和原始请求完全一致。

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