系统性Node.js——手写文件流手写文件流流主要分为「可读流」与「可

手写文件流流主要分为「可读流」与「可写流」，在 Node 中 stream 模块封装了流的基本操作。我们今天主要介绍的文件流也是继承 stream 模块来实现的。
文件流 针对文件操作而实现的流。当我们操作文件时，由于文件可能特别大，如果一次性操作文件的所有内容，性能跟内存消耗肯定会很高。所以我们可以像流水一样，一点一点的读取并操作文件，这样每次消耗的性能跟内存会很少， cpu 也会有时间去处理其它的任务。
文件可读流读取文件，将文件内容一点一点的读入内存当中。
使用方式我们先看一下基本的使用方式。
const fs = require('fs')const rs = fs.createReadStream('./w-test.js')rs.on('data', (chunk) => {console.log(chunk)})rs.on('close', () => {console.log('close')})如上代码所示，我们通过 fs.createStream() 创建了一个可读流，用来读取 w-test.js 文件。
当 on('data') 时，会自动的读取文件数据，每次默认读取 64kb 的内容，也可以通过 highWaterMark 参数来动态改变每次内容流程的阈值。
文件读取完毕后会自动触发 close 事件。
如下代码为 createReadStream 可以配置的参数
const rs = fs.createReadStream('./w-test.js', {flags: 'r', // 文件系统表示，这里是指以可读的形式操作文件encoding: null, // 编码方式autoClose: false, // 读取完毕时是否自动触发 close 事件start: 0, // 开始读取的位置end: 2, // 结束读取的位置highWaterMark: 2 // 每次读取的内容大小})「注意：」 start 跟 end 都是包含的，即 [start, end] 。
其实， fs.crateReadStream 就是返回一个 fs.ReadStream 类的实例，所以上述代码就等同于：
const rs = new fs.ReadStream('./w-test.js', {flags: 'r', // 文件系统表示，这里是指以可读的形式操作文件encoding: null, // 编码方式autoClose: false, // 读取完毕时是否自动触发 close 事件start: 0, // 开始读取的位置end: 2, // 结束读取的位置highWaterMark: 2 // 每次读取的内容大小})手写文件可读流了解完使用方式，那我们就应该尝试从原理上去搞定它，接下来，我们手写一个可读流。
初始化首先， ReadStream 是一个类，从表现上来看这个类可以监听事件即 on('data') ，所以我们应该让它继承自 EventEmitter ，如下代码：
class ReadStream extends EventEmitter {constructor() {super();}}然后我们初始化参数，并打开文件，如下代码（代码中会对关键代码作注释）：
class ReadStream extends EventEmitter {constructor(path, options = {}) {super()this.path = paththis.flags = options.flags ?? 'r'this.encoding = options.encoding ?? 'utf8'this.autoClose = options.autoClose ?? truethis.start = options.start ?? 0this.end = options.end ?? undefinedthis.highWaterMark = options.highWaterMark ?? 16 * 1024// 文件的偏移量this.offset = this.start// 是否处于流动状态，调用 pause 或 resume 方法时会用到，下文会讲到this.flowing = false// 打开文件this.open()// 当绑定新事件时会触发 newListener// 这里当绑定this.on('newListener', (type) => {if (type === 'data') {// 标记为开始流动this.flowing = true// 开始读取文件this.read()}})}}

系统性Node.js——手写文件流

推荐阅读

新华社|外媒：拉美是受“信息疫情”影响最严重的地区

向往4：《向往4》张子枫全力冲刺高考！大清早起来复习，做笔记方式太真实了

美食承教事业上的女强人，家庭中的顶梁柱，聪明能干的四大生肖女

东方网|东方快评丨门票减免并非万能，练好内功才是正途

情侣闹矛盾女子砸毁动车玻璃被处以行政拘留五日

锻炼肌肉的最佳年龄是多少？

詹姆斯|利拉德再次力挺詹皇拿MVP：他将湖人从乐透区带到西部榜首

怎么样有效提高泪点

「数码鲜蜂」源自5G的WiFi6，终于上市了

不拉屎的时候，痔疮会不会流血?

如何让HR更容易发现你？发求职邮件是门学问！

国务院国有资产监督管理委员会|国资委：央企上半年累计降低全社会运行成本超1200亿元

花钱不多吃的舒坦，买菜就到地利生鲜

特斯拉|车顶维权女车主曝光庭审内容：特斯拉想要和解被其拒绝

过往年少|国产操作系统日趋完善，佳能、爱普生等品牌加速完成兼容测试

可爱的小冉|新的希望，迎接新的机遇，早安，新的一天

珙桐花花语珙桐花传说

6G标准控制权争夺开始了？美、英等十国联合行动，网友：一盘散沙

第一线电竞|百万网友在线围观，无美颜无滤镜！孤影首次粉丝见面会强势来袭

楼市@美国印出来的楼市盛宴或将中道而止，高盛：1.2万亿美元将流入中国