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

10次阅读

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 免费学习笔记(深入)”;

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() 响应体、MediaStreamStreams 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 的生命周期和错误处理,就能稳妥地处理各类大数据场景。

以上就是什么是

星耀云
版权声明:本站原创文章,由 星耀云 2025-12-13发表,共计1598字。
转载说明:转载本网站任何内容,请按照转载方式正确书写本站原文地址。本站提供的一切软件、教程和内容信息仅限用于学习和研究目的;不得将上述内容用于商业或者非法用途,否则,一切后果请用户自负。本站信息来自网络,版权争议与本站无关。
text=ZqhQzanResources