浅谈手写浅谈手写node可读流之流动模式可读流之流动模式
node的可读流基于事件的可读流基于事件
可读流之流动模式,这种流动模式会有一个”开关”,每次当”开关”开启的时候,流动模式起作用,如果将这个”开关”设置成暂停
的话,那么,这个可读流将不会去读取文件,直到将这个”开关”重新置为流动。
读取文件流程读取文件流程
读取文件内容的流程,主要为:
打开文件,打开文件成功,将触发open事件,如果打开失败,触发error事件和close事件,将文件关闭。
开始读取文件中的内容,监听data事件,数据处于流动状态,可通过修改开关的状态来暂停读取。
每次读取到的内容放入缓存中,并通过data事件将数据发布出去。
当文件中的内容读取完毕之后,将文件关闭。
这一系列动作都是基于事件来进行操作的,而node中的事件我们都知道是一种发布订阅模式来实现的。
下面我们来看一看,node是如何使用可读流来读取文件中的内容?
node 可读流参数可读流参数
首先我们通过fs模块来创建一个可读流,可读流接受两个参数:
第一个参数是要读取的文件地址,在这里指明你要读取哪个文件。
第二个参数是可选项,这个参数是一个对象,用来指定可读流的一些具体的参数。
如下几个参数我们来一一说明:
highWaterMark:设置高水位线,这个参数主要用于在读取文件时,可读流会将文件中的内容读取到缓存当中,而这里我们需
要创建一个buffer来缓存这些数据,所以这个参数是用来设置buffer的大小,如果不对这个参数进行设置的话,可读流默认的
配置64k。
flags:这个参数主要用于设置文件的执行模式,比如说我们具体的操作适用于读取文件还是写入文件等这些操作。如果是写入
文件的话那我们,使用的是w。如果是读取文件的话那这个操作符就应该是r。
下面这张表格就说明了不同的符号代表不同含义:
符号符号 含义含义
r 读文件,文件不存在报错
r+ 读取并写入,文件不存在报错
rs 同步读取文件并忽略缓存
w 写入文件,不存在则创建,存在则清空
wx
排它写入文件
w+ 读取并写入文件,不存在则创建,存在则清空
wx+ 和w+类似,排他方式打开
a 追加写入
ax 与a类似,排他方式写入
a+ 读取并追加写入,不存在则创建
ax+ 作用与a+类似,但是以排他方式打开文件
autoClose:这个参数主要用于,对文件的关闭的一些控制。如果文件再打开的过程或者其他操作的过程中出现了错误的情况
下,需要将文件进行关闭。那这个参数是设置文件是否自动关闭的功能。
encoding:node中用buffer来读取文件操作的东西二进制数据。这些数据展现出来的话我们是一堆乱码,所以需要,要我们对
这个数据指定一个具体的编码格式。然后将会对这些数据进行编码转化,这样转化出来的数据就是我们能看懂的数据。
starts:这个参数主要用于指定从什么位置开始读取文件中的内容,默认的话是从零开始。
ends:这个参数主要用于指定定具体要读取文件多长的数据,这里需要说明一下,这个参数是包括本身的位置,也就是所谓的
包前和包后。
下面我们来看看可读流具体例子:
let fs = require("fs");
let rs = fs.createReadStream("./a.js", {
highWaterMark: 3,
encoding: "utf8",
autoClose: true,
start: 0,
end: 9