一、是什么

流(Stream)，是一种数据传输手段，是端到端信息交换的一种方式，是有顺序的，是逐块读取数据、处理内容，用于顺序读取输入或写入输出

在很多时候，流(Stream)是字节流(Byte Steram)的简称，也就是长长的一串字节

除了字节流，还可以有视频流、音频流、数据流

流的独特之处在于，它不像传统的程序那样一次将一个文件读入内存，而是逐块读取数据、处理其内容，而不是将其全部保存在内存中

流可以分成三部分：source、dest面试、pipe

在source和dest之间有一个连接的管道pipe,它的基本语法是source.pipe(dest)，source和dest就是通过pipe连接，让数据从source流向了dest，如下图所示：

二、种类

在NodeJS，几乎所有的地方都使用到了流的概念，分成四个种类：

可写流：可写入数据的流。例如 fs.createWriteStream() 可以使用流将数据写入文件

可读流：可读取数据的流。例如fs.createReadStream() 可以从官：文件读取内容 双工流：既可读又可写的流。例如 net.Socket 转换流：可以在数据写入和读取时修改或转换数据的流。例如，在文件压缩操作中，可以向文件写入压缩数据，并从文件中读取解压数据

在NodeJS中HTTP服务器模块中，request 是可读流，response 是可写流。还有fs 模块，能同时处理可读和可写文件流

可读流和可写流都是单向的，比较容易理解，而另外两个是双向的

双工流

之前了解过websocket通信，是一个全双工通信，发送方和接受方都是各自独立说说的方法，发送和接收都没有任何关系

如下图所示：

基本代码如下：

const { Duplex } = require('stream');  const myDuplex = new Duplex({   read(size) {    对 ; // ...   },   write(chunk, encoding, callback) {     // ...   } });  转换流

转换流的演示图如下所示：

比如一个 babel，把es6转换为es5，我们在No左边写入 es6，从右边读取 es5

基本代码如下所示：

const { Transform } = require('stream');  const myTransform = new Transform({   transform(chunk, encoding, caldelback) {     // ...   } });  三、应用场景

stream的应用场景主要就是处理IO操作，而http请求和文件操作都属于IO操作

思想一下，如果一次IO操作过大，硬件的开销就过大，而将此次大的IO操作进行分段操作，让数据像水管一样流动，知道流动完成

常见的场景有：

get请求返回文件给客户端 文件操作 一 中些打包工具的底层操作

get请求返回文件给客户端

使用stream流返回文件，res也是一个stream对象，通过pipe管道将文件数据返回

const server = http.createServer(function (req, res) {     const method = req.metho的 d; // 获取请求方法     if (method === 'GET') { // get 请求         const fileName = path.resolve(St__dirname, 'data.txt');         let stream = fs.createReadStream(fileName);         stream.pipe(res); //&nbresp;将 res 作为 stream 的 dest     } }); server.listen(8000);  文件操作

创建一个可读数据流readStream，一个可写数据流writeStream，通过pipe管道把数据流转过去

const fs = require('fs') amconst path = require('path')  // 两个文件名 const fileName1 = path.resolve(__dirname, 'data.txt') const fileName2 = path.resolve(__dirname, 'data-b 的ak.txt') // 读取文件的 stream 对象 const readStream = fs.createReadStream(fileName1) // 写入文件的 stream 对象 const writeStream = fs.createWriteStream(fileNam理解e2) // 通过 pipe执行拷贝，数据流转 readStream.pipe(writeStream) // 数据读取完成监听，即拷贝完成 readStream.on('end', function () {     console.log('拷贝完成') })  一些打包？应工具的底层操作

目前一些比较火的前端打包构建工具，都是通过node.js编写的，打包和构建的过程肯定是文件频繁操作的过程，离不开stream，如gulp

参考文献

https://xie.infoq.cn/article/1a9695020828460eb3c4ff1fa

https://juejin.cn/post/6844903891083984910

• ·标签: 死了么 Demumu 吕功琛 Life360
• ·人工智能和物联网-5个不断发展的用例
• ·OpenAI 紧急暂停 Sora生成马丁・路德・金形象，AI 视频生成引发热议！
• ·IonQ首席执行官Peter Chapman谈量子计算的采用,创新以及下一步发展
• ·标签: 电动汽车 电耗限值 国家标准 纯电动
• ·标签: 光大银行 2025年报 不良贷款率 财富管理
• ·标签: 豪车市场
• ·标签: 先登航天 XD-3火箭 PZ-130发动机 商业航天
• ·Uber与甲骨文达成7年云计算合作
• ·“马其诺防线”失效，如何做好容器云安全？
• ·亚马逊和两位女员工和解：解雇仗义执言者遭舆论炮轰
• ·微软前高管建议剥离Office和Windows 专攻云计算业务
• ·标签: 日产汽车 刘新宇 日产中国 东风日产
• ·我用Excel发现了数据分析的本质：回归分析
• ·标签: 小米汽车 SU7 雷军 小米电池工厂
• ·教机器人捏橡皮泥？MIT、IBM, UCSD等联合发布软体操作数据集