如何在中间件中读取流并保证后续中间件仍可读取该流

你的问题很典型——当你直接在前置中间件里监听data和end事件消费请求流后，后续的代理中间件就没法再读取这个流了，因为Node.js的可读流是单向消费的，一旦被读取（或者说绑定了data事件），流就会进入流动模式，数据被耗尽后就无法再被其他消费者读取。

下面给你两种可行的解决方案，分别适用于不同的场景：

方案1：使用PassThrough复制流（通用场景） #

stream.PassThrough是Node.js内置的流工具，它可以创建一个“直通”流，把输入的内容原封不动地输出。我们可以用它复制一份请求流，让前置中间件处理副本，原始流完整保留给代理中间件使用。

代码示例： #

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

// 前置中间件：读取流副本获取信息，不影响原始流
function preMiddleware(req, res, next) {
  // 创建流副本
  const streamCopy = new PassThrough();
  // 把原始流的内容导向副本（原始流依然保持可读状态）
  req.pipe(streamCopy);

  // 处理副本流，获取需要的信息
  let rawBody = '';
  streamCopy.on('data', (chunk) => {
    rawBody += chunk.toString();
    // 这里可以根据需要解析multipart的部分内容，比如匹配特定字段
    // 注意：如果是大文件，不建议把整个流存到内存，推荐用方案2的busboy解析
  });

  streamCopy.on('end', () => {
    req.rawBody = rawBody;
    console.log('前置中间件已获取流内容片段');
    next(); // 继续执行后续代理中间件
  });
}

// 代理中间件示例（以http-proxy-middleware为例）
const { createProxyMiddleware } = require('http-proxy-middleware');
const proxyMiddleware = createProxyMiddleware({
  target: 'https://your-target-endpoint.com',
  changeOrigin: true,
  onProxyReq: (proxyReq, req) => {
    // 确保原始流被正确转发给目标端点
    if (!req.readableEnded) {
      req.pipe(proxyReq);
    }
  }
});

方案2：用busboy解析Multipart特定字段（更高效） #

如果你的需求只是提取Multipart中的某个字段（比如表单字段、文件名等），而不是读取整个流，那么用专门的Multipart解析库busboy会更高效，它可以在不消耗整个流的情况下提取你需要的信息（通过处理流副本）。

代码示例： #

const { PassThrough } = require('stream');
const Busboy = require('busboy');

// 前置中间件：解析Multipart特定字段
function preMiddleware(req, res, next) {
  const streamCopy = new PassThrough();
  req.pipe(streamCopy);

  const busboy = Busboy({ headers: req.headers });

  // 监听Multipart字段事件，提取需要的信息
  busboy.on('field', (fieldName, fieldValue) => {
    if (fieldName === 'user_id') { // 替换成你要提取的字段名
      req.userId = fieldValue;
      console.log(`提取到用户ID：${fieldValue}`);
    }
  });

  // 如果有文件字段，不需要处理的话直接跳过（避免内存占用）
  busboy.on('file', (fieldName, fileStream) => {
    fileStream.resume(); // 直接让文件流结束，不处理内容
  });

  // 解析完成后继续执行后续中间件
  busboy.on('finish', () => {
    next();
  });

  // 把流副本传给busboy解析
  streamCopy.pipe(busboy);
}

// 代理中间件和方案1一致，无需额外修改

关键注意点 #

• 绝对不要直接消费原始请求流（比如直接在req上绑定data/end事件），否则后续代理中间件会因为流已耗尽而无法转发数据。
• 处理大文件时，优先用busboy的分块解析，避免把整个文件读到内存中导致内存溢出。

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