如何从Node.js的Stream.Writable中读取数据？

你可以通过自定义Writable流来收集数据，完全不用写入文件。下面是两种实用的实现方式：

方式一：自定义可写流收集数据 #

直接继承Stream.Writable，在内部维护一个缓冲区存储所有写入的chunk，等流结束后就能拿到完整数据：

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

// 自定义收集数据的可写流
class CollectStream extends Writable {
  constructor(options) {
    super(options);
    this.data = []; // 存储所有写入的chunk
  }

  _write(chunk, encoding, callback) {
    // 根据需求处理chunk：这里转成字符串，二进制数据可直接存Buffer
    this.data.push(chunk.toString());
    callback(); // 通知流可以继续接收下一个chunk
  }

  // 获取最终拼接好的结果
  getResult() {
    return this.data.join('');
  }
}

// 使用示例
const outputStream = new CollectStream();

// 模拟向流推送数据（替换成你的业务逻辑）
outputStream.write('第一段内容');
outputStream.write('第二段内容');
outputStream.end(); // 结束流，触发finish事件

// 流结束后读取数据
outputStream.on('finish', () => {
  const result = outputStream.getResult();
  console.log('收集到的完整数据：', result);
  // 这里就可以把result存入变量使用了
});

方式二：使用concat-stream模块（更简洁） #

如果不想自己写自定义流，可以用现成的concat-stream模块，它会自动帮你拼接所有chunk：

先安装模块：

npm install concat-stream

然后使用：

const concat = require('concat-stream');

const outputStream = concat((data) => {
  // data是拼接后的Buffer，转成字符串使用
  const result = data.toString();
  console.log('收集到的完整数据：', result);
});

// 模拟写入数据
outputStream.write('第一段内容');
outputStream.write('第二段内容');
outputStream.end();

注意事项 #

• 如果处理的是二进制数据，去掉toString()，直接使用Buffer即可。
• 必须调用end()或者让上游逻辑触发流的finish事件，才能确保所有数据都已收集完成。

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