首页 > 文章 > 前端

流式处理：Readable与Writable流解析

时间：2025-12-13 22:36:39 497浏览收藏

推广推荐

支持 PC / 移动端，安全直达

在文章实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《流式处理：Readable与Writable流详解》，聊聊，希望可以帮助到正在努力赚钱的你。

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

注意要点：

_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。不复杂但容易忽略细节。

今天带大家了解了的相关知识，希望对你有所帮助；关于文章的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~