流式处理：Readable与Writable流实现-js教程-PHP中文网

流式处理：Readable与Writable流实现

夜晨

发布： 2025-11-20 21:29:02

原创

460人浏览过

Node.js中Readable和Writable流分别用于数据读取与写入，通过实现_read()和_write()方法控制数据流动，结合pipe()实现高效管道传输。

流式处理：readable与writable流实现

在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()方法来定义如何处理传入的数据块。

注意要点：

Booltool

常用AI图片图像处理工具箱

140

查看详情

_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(); // 标记本次写入完成
  }
}