node.js 利用流实现读写同步,边读边写的方法

前端之家收集整理的这篇文章主要介绍了node.js 利用流实现读写同步,边读边写的方法前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

如下所示:

回复读取 //监听读取文件完毕后,关闭读取rs.on('end')

let rs=fs.createReadStream(source,{highWaterMark:4});
let ws=fs.createWriteStream(target,{highWaterMark:1});

rs.on('data',function (chunk) { //chunk是buffer类型

if(ws.write(chunk)===false){
  //写不下,停止读取
  rs.pause()
}

});
ws.on('drain',function () {
//每次写的内存干了就恢复读取
console.log("111");
rs.resume() //恢复读取
});
rs.on('end',function (chunk) {
ws.end();
})

}
pipe('./1.txt','./3.txt')

上面这种写法比较繁琐,大家看完后,忘记就行

node.js提供给我们内置方法pipe

let rs=fs.createReadStream(source,{highWaterMark:1});
//可读流到可写流,异步操作,可以保证内存不会被淹没,读一点,写一点
// 如果想看文件类容,使用readFile

rs.pipe(ws);
}
pipe('./1.txt','./4.txt')

直接将读取的流操作到写入流中,还是异步操作

以上这篇node.js 利用流实现读写同步,边读边写的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持编程之家。

原文链接:https://www.f2er.com/nodejs/36519.html

猜你在找的Node.js相关文章