上一节实现了文件拷贝功能，其中的读和写的操作都耦合在一起了，能不能实现一个方法，可以用一行搞定，这里涉及到流里的 pipe
流
流是有方向的，先读出来再写，node 中实现了流的模块（stream）
文件也想实现流，所以内部文件系统继承了 stream 模块
createReadStream 创建一个可读流（返回一个可读流对象），这个方法默认并不会读取内容：
const fs = require("fs"); const path = require("path"); // createReadStream(path: fs.PathLike, options?: BufferEncoding | ReadStreamOptions | undefined): fs.ReadStream // 内部的实现原理还是：fs.open fs.read fs.close let rs = fs.createReadStream(path.resolve(__dirname, "./name.txt"), { flags: "r", // r 代表读取 encoding: null, // 默认 null，就是 buffer 类型的 mode: 0o666, // 模式：可读可写 autoClose: true, // fs.close start: 0, // 0 - 8 包前又包后 end: 8, highWaterMark: 3 // 每次读取的个数 }); console.log(rs);
为了多个异步方法可以解耦，可以采用发布订阅模式
可读流继承了 events 模块，这里的名字必须要叫 data，源码里写的就是 rs.emit("data")，如果监听了 data，内部会拼命读取文件的内容，触发对应的回调，默认会直到文件读取完毕
下面新建 name.txt 文件，里面添加：
凯小默的博客
在添加下面的事件监听
const fs = require("fs"); const path = require("path"); let rs = fs.createReadStream(path.resolve(__dirname, "./name.txt"), { flags: "r", // r 代表读取 encoding: null, // 默认 null，就是 buffer 类型的 mode: 0o666, // 模式：可读可写 autoClose: true, // fs.close start: 0, // 0 - 8 包前又包后 end: 8, highWaterMark: 3 // 每次读取的个数 }); let bufferArr = []; // 监听 open（文件流特殊的事件，普通流没有） rs.on("open", (fd) => { console.log("open---->", fd); }); // 监听 data rs.on("data", (data) => { console.log("data---->", data); bufferArr.push(data); // rs.pause 可以让可读流暂停触发 data 事件 rs.pause(); console.log("pause---->暂停"); // 再次触发 data 事件，可以使用 rs.resume setTimeout(() => { console.log("过 2s 再次触发 data 事件"); rs.resume(); }, 2000); }); // 监听 end rs.on("end", () => { console.log("end---->", Buffer.concat(bufferArr).toString()); }); // 监听 error rs.on("error", (err) => { console.log("err---->", err); }); // 监听 close （文件流特殊的事件，普通流没有） rs.on("close", () => { console.log("close---->"); });
