NodeJS 中Stream 的基本使用

在 NodeJS 中，我们对文件的操作需要依赖核心模块 fs ， fs 中有很基本 API 可以帮助我们读写占用内存较小的文件，如果是大文件或内存不确定也可以通过 open 、 read 、 write 、 close 等方法对文件进行操作，但是这样操作文件每一个步骤都要关心，非常繁琐， fs 中提供了可读流和可写流，让我们通过流来操作文件，方便我们对文件的读取和写入。
可读流

1、createReadStream 创建可读流

createReadStream 方法有两个参数，第一个参数是读取文件的路径，第二个参数为 options 选项，其中有八个参数：

rnullnull0o666true64 * 1024

createReadStream 的返回值为 fs.ReadStream 对象，读取文件的数据在不指定 encoding 时，默认为 Buffer。

let fs = require("fs");// 创建可读流，读取 1.txt 文件let rs = fs.creatReadStream("1.txt", { start: 0, end: 3, highWaterMark: 2});

在创建可读流后默认是不会读取文件内容的，读取文件时，可读流有两种状态，暂停状态和流动状态。

注意：本篇的可写流为流动模式，流动模式中有暂停状态和流动状态，而不是暂停模式，暂停模式是另一种可读流 readable 。

2、流动状态

流动状态的意思是，一旦开始读取文件，会按照 highWaterMark 的值一次一次读取，直到读完为止，就像一个打开的水龙头，水不断的流出，直到流干，需要通过监听 data 事件触发。

假如现在 1.txt 文件中的内容为 0~9 十个数字，我们现在创建可读流并用流动状态读取。

let fs = require("fs");let rs = fs.createReadStream("1.txt", { start: 0, end: 3, highWaterMark: 2});// 读取文件rs.on("data", data => { console.log(data);});// 监听读取结束rs.on("end", () => { console.log("读完了");});// <Buffer 30 31>// <Buffer 32 33>// 读完了

在上面代码中，返回的 rs 对象监听了两个事件：

data：每次读取 highWaterMark 个字节，触发一次 data 事件，直到读取完成，回调的参数为每次读取的 Buffer；

end：当读取完成时触发并执行回调函数。

我们希望最后读到的结果是完整的，所以我们需要把每一次读到的结果在 data 事件触发时进行拼接，以前我们可能使用下面这种方式。

let fs = require("fs");let rs = fs.createReadStream("1.txt", { start: 0, end: 3, highWaterMark: 2});let str = "";rs.on("data", data => { str += data;});rs.on("end", () => { console.log(str);});// 0123

在上面代码中如果读取的文件内容是中文，每次读取的 highWaterMark 为两个字节，不能组成一个完整的汉字，在每次读取时进行 += 操作会默认调用 toString 方法，这样会导致最后读取的结果是乱码。