JavaScript 中的 Stream API 用于分块处理大量或持续数据以节省内存,Node.js 提供 Readable、Writable、Transform 和 Duplex 四类流;推荐用 for await…of 读取可读流;浏览器支持 Web Streams API(如 fetch().body)。

JavaScript 中的 Stream API 主要用于处理大量或持续产生的数据,比如文件读写、网络请求响应、实时音视频流等。它不是一次性加载全部数据到内存,而是分块(chunk)按需读取和处理,节省内存、提升响应速度。
Stream 是什么?
Stream(流)是 Node.js 的核心模块之一,代表一个随时间推移而连续传输的数据序列。它有四种基本类型:
- Readable:可读流,如
fs.createReadStream()、http.IncomingMessage - Writable:可写流,如
fs.createWriteStream()、process.stdout - Transform:转换流,既可读又可写,常用于数据加工(如压缩、编码)
- Duplex:双工流,独立的读写通道(如
net.Socket)
如何读取可读流(Readable Stream)?
读取数据流主要有两种模式:流动模式(flowing mode)和暂停模式(paused mode),推荐使用基于事件或 Promise 的现代方式。
- 用
.on('data', callback)监听数据块(旧式,适合简单场景) - 用
.on('end')捕获流结束信号 - 更推荐用
for await……of(Node.js ≥10.0,需流为异步迭代器) - 也可用
stream.pipeline()或stream.pipe()将流对接到其他流(如从文件读 → 转换 → 写入新文件)
示例:用 for await 读取文件流
立即学习“Java 免费学习笔记(深入)”;
import {createReadStream} from 'fs'; const stream = createReadStream('./data.txt', { encoding: 'utf8'}); for await (const chunk of stream) {console.log('收到数据块:', chunk); } // 自动处理 end、error,无需手动监听
浏览器 中能用 Stream API 吗?
可以,但范围有限。现代浏览器支持 ReadableStream(Web Streams API),主要用于 fetch() 响应体、MediaStream、Streams API 工具 类等。
-
response.body是一个ReadableStream - getReader() 获取阅读器,逐块读取;或用
response.text()/response.json()一键读完(内部已封装流逻辑)
示例:浏览器中读取 fetch 响应流
const response = await fetch('/large-file.json'); const reader = response.body.getReader(); while (true) {const { done, value} = await reader.read(); if (done) break; console.log('接收到字节:', value.length); }
常见注意事项
- 流一旦消费(如调用了
pipe()或for await),就不能重复读取 - 务必监听
'error'事件,否则错误可能被静默丢弃 - Node.js 中的流默认不支持
async/await直接等待,需包装成 Promise 或用pipeline() - 浏览器
ReadableStream和 Node.jsstream.Readable不兼容,不能混用
基本上就这些。Stream 的核心是“按需、分块、可控”,理解好 readable/writable 的生命周期和错误处理,就能稳妥地处理各类大数据场景。
以上就是什么是