Node.js 流处理指南

什么是流？

流是数据的集合，可以分块处理而不是一次性加载到内存。

流的类型

Readable Stream

const fs = require("fs");
const readStream = fs.createReadStream("input.txt", { highWaterMark: 1024 });

readStream.on("data", (chunk) => {
  console.log("Received chunk:", chunk);
});

Writable Stream

const writeStream = fs.createWriteStream("output.txt");
writeStream.write("Hello World");
writeStream.end();

Transform Stream

const { Transform } = require("stream");

const upperCase = new Transform({
  transform(chunk, encoding, callback) {
    this.push(chunk.toString().toUpperCase());
    callback();
  }
});

Pipe 机制

readStream.pipe(upperCase).pipe(writeStream);

背压处理

当写入速度慢于读取速度时，流会自动调节。

实战场景

• 大文件处理
• HTTP 请求/响应
• 数据转换管道

流是 Node.js 处理大数据的核心机制，掌握它能显著提升性能。