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.js stream.Readable 不兼容，不能混用
基本上就这些。Stream 的核心是“按需、分块、可控”，理解好 readable/writable 的生命周期和错误处理，就能稳妥地处理各类大数据场景。
以上就是什么是stream api_javascript中如何读取数据流？的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1542156.html
微信扫一扫 
支付宝扫一扫 
