Node.js中Readable和Writable流分别用于数据读取与写入，通过实现_read()和_write()方法控制数据流动，结合pipe()实现高效管道传输。
在Node.js中，流式处理是一种高效处理数据的方式，特别适用于大文件或网络请求场景。核心在于Readable和Writable两种基础流类型，它们分别代表可读数据源和可写目标。理解并掌握这两种流的实现方式，能帮助我们更好地控制数据流动，提升性能与内存使用效率。
Readable流：按需提供数据
Readable流用于产生数据，可以是文件读取、HTTP响应等来源。它支持两种模式：流动模式（flowing）和暂停模式（paused）。通过实现_read()方法来定义如何获取数据。
关键点：
- _read() 方法不直接返回数据，而是调用 this.push(chunk) 将数据推入内部缓冲区
- 当 push(null) 被调用时，表示数据源已结束
- 每次 push 后，系统可能自动再次触发 _read，无需手动循环
示例：创建一个生成递增数字的可读流
const { Readable } = require('stream');class Counter extends Readable {
constructor(max) {
super();
this.max = max;
this.current = 0;
}
_read() {
if (this.current >= this.max) {
this.push(null); // 结束流
} else {
this.current++;
this.push(this.current + ''); // 推送字符串数据
}
}
}
Writable流：接收并处理数据
Writable流用于消费数据，比如写入文件、发送网络请求。开发者需要实现_write()方法来定义如何处理传入的数据块。
注意要点：
- _write(chunk, encoding, callback) 中 chunk 是数据块，callback 必须被调用以通知处理完成
- 若处理出错，可传入错误对象给 callback(err)
- 流会在所有写入完成后自动触发 'finish' 事件
例子：构建一个将数据打印到控制台的可写流
const { Writable } = require('stream');class Logger extends Writable {
_write(chunk, encoding, callback) {
console.log('收到:', chunk.toString());
callback(); // 标记本次写入完成
}
}
连接流实现数据管道
Readable和Writable流可通过 pipe() 方法连接，形成高效的数据传输链路。这种方式避免了中间缓存过大，实现背压（backpressure）自动管理。
典型用法：
- source.pipe(destination) 自动监听 data 和 end 事件
- 可叠加多个中间流进行转换（如压缩、加密）
- 出错时建议监听 error 事件防止崩溃
运行上面的例子：
const counter = new Counter(5);const logger = new Logger();
counter.pipe(logger);
// 输出: 收到: 1 → 收到: 2 → ... → 收到: 5
基本上就这些。掌握 Readable 和 Writable 流的核心机制，就能灵活构建高效的流式处理逻辑。关键是理解 _read 和 _write 的触发时机以及正确使用 push 和 callback。不复杂但容易忽略细节。
