NodeJS 中Stream 的基本使用

start: 0,
highWaterMark: 3
});
let flag1 = ws.write("1");
console.log(flag1);
let flag2 = ws.write("2");
console.log(flag2);
let flag3 = ws.write("3");
console.log(flag3);
// true
// true
// false

写入不存在的文件时会自动创建文件，如果 start 的值不是 0 ，在写入不存在的文件时默认找不到写入的位置。

3、可写流的 drain 事件

drain 意为 “吸干”，当前写入的内容已经大于等于了 highWaterMark ，会触发 drain 事件，当内容全部从缓存写入文件后，会执行回调函数。

let fs = require("fs");
let ws = fs.createWriteStream("2.txt", {
 start: 0,
 highWaterMark: 3
});
let flag1 = ws.write("1");
console.log(flag1);
let flag2 = ws.write("2");
console.log(flag2);
let flag3 = ws.write("3");
console.log(flag3);
ws.on("drain", () => {
 console.log("吸干");
});
// true
// true
// false

4、可写流的 end 方法

end 方法传入的参数为最后写入的内容， end 会将缓存未写入的内容清空写入文件，并关闭文件。

let fs = require("fs");
let ws = fs.createWriteStream("2.txt", {
 start: 0,
 highWaterMark: 3
});
let flag1 = ws.write("1");
console.log(flag1);
let flag2 = ws.write("2");
console.log(flag2);
let flag3 = ws.write("3");
console.log(flag3);
ws.on("drain", () => {
 console.log("吸干");
});
ws.end("写完了");
// true
// true
// false

在调用 end 方法后，即使再次写入的值超出了 highWaterMark 也不会再触发 drain 事件了，此时打开 2.txt 后发现文件中的内容为 “123写完了”。

let fs = require("fs");
let ws = fs.createWriteStream("2.txt", {
 start: 0,
 highWaterMark: 3
});
ws.write("1");
ws.end("写完了");
ws.write("2");
// Error [ERR_STREAM_WRITE_AFTER_END]: write after end...

在调用 end 方法后，不可以再调用 write 方法写入，否则会报一个很常见的错误 write after end ，文件原有内容会被清空，而且不会被写入新内容。

可写流与可读流混合使用

可写流和可读流一般配合来使用，读来的内容如果超出了可写流的 highWaterMark ，则调用可读流的 pause 暂停读取，等待内存中的内容写入文件，未写入的内容小于 highWaterMark 时，调用可写流的 resume 恢复读取，创建可写流返回值的 rs 上的 pipe 方法是专门用来连接可读流和可写流的，可以将一个文件读来的内容通过流写到另一个文件中。

let fs = require("pipe");
// 创建可读流和可写流								 
 4/5   首页 上一页 2 3 4 5 下一页 尾页