流式处理：Readable与Writable流实现_石家庄创泽智能科技有限公司

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

流式处理：Readable与Writable流实现

2025-11-20

浏览次数：次

返回列表

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

注意要点：

eSiteGroup站群管理系统1.0.4

eSiteGroup站群管理系统是基于eFramework低代码开发平台构建，是一款高度灵活、可扩展的智能化站群管理解决方案，全面支持SQL Server、SQLite、MySQL、Oracle等主流数据库，适配企业级高并发、轻量级本地化、云端分布式等多种部署场景。通过可视化建模与模块化设计，系统可实现多站点的快速搭建、跨平台协同管理及数据智能分析，满足政府、企业、教育机构等组织对多站点统一管控的

0 查看详情 eSiteGroup站群管理系统1.0.4

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