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 的生命周期和错误处理，就能稳妥地处理各类大数据场景。
