Node.js（Hapi.js）中如何读取IncomingMessage数据而不消耗流

嘿，这个问题其实是Node.js流操作里的常见痛点——毕竟流的设计就是单向消费的，原生确实没有直接“预览”数据又不消耗的方法。不过针对你的Hapi.js场景，有两个靠谱的解决方案：

方案1：缓存数据后创建新流复用 #

你可以先把所有流数据收集起来，然后用这些缓存的数据生成一个新的PassThrough流（它同时支持读和写），之后把这个新流替换掉原来的请求流，这样后续逻辑就能正常读取了：

const { PassThrough } = require('stream');
const server = Hapi.server({ port: 3000, host: 'localhost' });

server.route({
  method: 'POST',
  path: '/',
  async handler(request, h) {
    const req = request.raw.req;
    // 收集所有chunk到数组
    const chunks = [];
    for await (const chunk of req) {
      chunks.push(chunk);
    }
    const fullBody = Buffer.concat(chunks);
    
    // 打印请求体内容
    console.log(fullBody.toString());

    // 创建新的PassThrough流，把缓存的数据写入
    const reusableStream = new PassThrough();
    reusableStream.end(fullBody);
    
    // 替换原始请求流，供后续逻辑使用
    request.raw.req = reusableStream;

    return 'Hello, world!';
  }
});

server.start();

方案2：直接用Hapi.js内置的请求体处理 #

其实你完全不用手动去碰原始流——Hapi.js已经帮你封装好了请求体解析。直接通过request.payload就能拿到解析后的内容，默认支持JSON、表单等格式，既省心又不会有流消耗的问题：

const server = Hapi.server({ port: 3000, host: 'localhost' });

server.route({
  method: 'POST',
  path: '/',
  handler(request, h) {
    // 直接获取解析后的请求体
    console.log('请求体内容:', request.payload);
    
    // 如果需要原始Buffer，也可以配置后获取
    return 'Hello, world!';
  }
});

server.start();

如果需要更定制化的处理（比如获取原始Buffer、限制大小等），可以在服务器配置里调整routes.payload：

const server = Hapi.server({
  port: 3000,
  host: 'localhost',
  routes: {
    payload: {
      output: 'data', // 返回Buffer或解析后的对象
      parse: true, // 自动解析JSON/表单
      allow: ['application/json', 'multipart/form-data'] // 允许的内容类型
    }
  }
});

补充：为什么不能直接把数据放回原流？ #

Node.js的stream.unshift()方法看起来能把数据放回，但它只适合处理少量数据，而且如果流已经触发了end事件，这个方法就没法恢复流的状态了，很容易出问题。所以缓存后创建新流是最稳妥的方式。

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