什么是stream api_javascript中如何读取数据流？-js教程-PHP中文网

什么是stream api_javascript中如何读取数据流？

夢幻星辰

发布： 2025-12-14 09:18:08

原创

503人浏览过

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

什么是stream api_javascript中如何读取数据流？

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免费学习笔记（深入）”；

千鹿Pr助手

智能Pr插件，融入众多AI功能和海量素材

128

查看详情

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);
}

登录后复制