本篇内容主要讲解“Nodejs中可写流write的实现方法”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Nodejs中可写流write的实现方法”吧!
牟平网站建设公司成都创新互联公司,牟平网站设计制作，有大型网站制作公司丰富经验。已为牟平成百上千家提供企业网站建设服务。企业网站搭建\外贸网站制作要多少钱，请找那个售后服务好的牟平做网站的公司定做！
可写流-Writable
fs.createWriteStream调用例子
const fs = require("fs");
const path = require("path");
const bPath = path.join(__dirname, "b.txt");
let ws = fs.createWriteStream(bPath, {
flags: "w",
encoding: "utf-8",
autoClose: true,
start: 0,
highWaterMark: 3,
});
ws.on("open", function (fd) {
console.log("open", fd);
});
ws.on("close", function () {
console.log("close");
});
//string 或者buffer，ws.write 还有一个boolea的返回值
ws.write("1");
//flag 表示 当前要写的值是直接是否直接写入文件，不能超出了单次最大写入值highWaterMark
let flag = ws.write("1");
console.log({ flag });//true
flag = ws.write("1");
console.log({ flag });//false
flag = ws.write("1");
console.log({ flag });//false
flag = ws.write("14444444");
console.log({ flag });//false
ws.end(); //write+close,没有调用 end 是不会调用 触发close的，看到这里的小伙伴可以尝试注释end() 看看close的console是否有打印
自定义可写流initWriteStream
继承EventEmitter发布订阅
const EventEmitter = require("events");
const fs = require("fs");
class WriteStream extends EventEmitter {}
module.exports = WriteStream;链表生成队列做文件读取的缓存
链表&队列的实现
https://juejin.cn/post/6973847774752145445
// 用链表 生成队列 对 文件缓存区的读取 进行优化
const Queue = require("./queue");初始化实例默认数据constructor()
constructor(path, options = {}) {
super();
this.path = path;
this.flags = options.flags || "w";
this.encoding = options.encoding || "utf8";
this.mode = options.mode || 0o666; //默认8进制 ，6 6 6 三组分别的权限是 可读可写
this.autoClose = options.start || 0;
this.highWaterMark = options.highWaterMark || 16 * 1024; //默认一次读取16个字节的数据
this.len = 0; //用于维持有多少数据还没有被写入文件中
//是否根据等待当前读取的最大文数据 排空后再写入
this.needDrain = false; //
// 缓存队列 用于存放 非第一次的文件读取 到的数据，因为第一次读取 直接塞入目标文件中
// 除第一次 的文件读取数据的都存放再缓存中
// this.cache = [];
// 队列做缓存
this.cache = new Queue();
// 标记是否是第一次写入目标文件的标识
this.writing = false;
this.start = options.start || 0;
this.offset = this.start; //偏移量
this.open();
}open()
open() {
fs.open(this.path, this.flags, this.mode, (err, fd) => {
this.fd = fd;
this.emit("open", fd);
});
}write()
转化实例传入的需要写入的文件数据格式为buffer
判断写入数据长度是否大于highWaterMark，如果达到预期后，文件读取到的数据存放再缓存里 不直接写入目标文件（这里要排除是否是第一次读取文件）
执行实例write 传入的cb 并调用clearBuffer 清空缓存
判断 是否是第一次读取，第一次读取 直接写入调用 _write(待实现)
缓存队列尾部offer 当前读取到的数据等待写入目标文件
write(chunk, encoding = this.encoding, cb = () => {}) {
// 将数据全部转换成buffer
chunk = Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk);
this.len += chunk.length;
// console.log({chunk},this.len )
let returnValue = this.len < this.highWaterMark;
//当数据写入后，需要在手动的将this.len--
this.needDrain = !returnValue; //如果达到预期 后 的文件读取 到数据存放再缓存里 不直接写入目标文件
//清空缓存 对用户传入的回调 进行二次包装
let userCb = cb;
cb = () => {
userCb();
//清空buffer
this.clearBuffer();//马上实现
};
//此时需要判断 是否是第一次读取，第一次读取 直接写入调用 _write
if (!this.writing) {
// 第一次||缓存队列已清空完毕
this.writing = true;
// console.log("first write");
this._write(chunk, encoding, cb);//马上实现
} else {
//缓存队列尾部offer 当前读取到的数据等待写入目标文件
this.cache.offer({
chunk,
encoding,
cb,
});
}
return returnValue;
}clearBuffer()依次清空缓存队列
队列执行顺序，先进先出原则
this.cache.poll() 依次拿取头部数据执行this._write写入目标文件
缓存队列poll出来的data如果不存在，则说明是第一次写入的行为||缓存队列已清空。this.writing = false; 下次的文件读取可以直接写入目标文件
如果this.needDrain又达到预期，文件读取到数据存放再缓存里 不直接写入目标文件
clearBuffer() {
//写入成功后 调用 clearBuffer--》写入缓存第一个，第一个完成后，再继续 第二个
let data = this.cache.poll();
// console.log('this.cache',this.cache)
if (data) {
//有值 写入文件
this._write(data.chunk, data.encoding, data.cb);
} else {
this.writing = false;
if (this.needDrain) {
// 如果是缓存，触发drain
this.emit("drain");
}
}
}_write()
fs.open()是异步的，成功读取后fd会是一个number类型
根据fd的type 决定是否订阅一次open，并回调自己（直到fd类型为number）
fd类型为number：调用fs.write，写入当前的chunk，
_write(chunk, encoding, cb) {
if (typeof this.fd !== "number") {
return this.once("open", () => this._write(chunk, encoding, cb));
}
fs.write(this.fd, chunk, 0, chunk.length, this.offset, (err, written) => {
this.offset += written; //维护偏移量
this.len -= written; //把缓存的个数减少
cb(); //写入成功
// console.log(this.cache);
});
}测试自定义的Writable
const WriteStream = require("./initWriteStream");
let ws = new WriteStream(bPath, {
highWaterMark: 3,
});
let i = 0;
function write() {
//写入0-9个
let flag = true;
while (i < 10 && flag) {
flag = ws.write(i++ + "");
console.log(flag);
}
}
ws.on("drain", function () {
// 只有当我们写入的数据达到预期，并且数据被清空后才会触发drain ⌚️
console.log("写完了");
write();
});
write();
到此，相信大家对“Nodejs中可写流write的实现方法”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！
当前名称：Nodejs中可写流write的实现方法
文章位置：
http://cdkjz.cn/article/pooepe.html
