这篇文章主要为大家展示了“node.js如何使用流实现读写同步边读边写功能”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“node.js如何使用流实现读写同步边读
这篇文章主要为大家展示了“node.js如何使用流实现读写同步边读边写功能”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“node.js如何使用流实现读写同步边读边写功能”这篇文章吧。
具体代码如下所示:
//10个数 10个字节,每次读4b,写1b
let fs=require("fs");
function pipe(source,target) {
//先创建可读流,再创建可写流
//先读一次,rs.on(data)
//将读到的类容写入目标中 ,返回布尔值,如果是ture,继续写,默认情况应该是false,暂停读取
//ws.on('drain'),抽干后,回复读取
//监听读取文件完毕后,关闭读取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
//10个数 10个字节,每次读4b,写1b
let fs=require("fs");
function pipe(source,target) {
let rs=fs.createReadStream(source,{highWaterMark:4});
let ws=fs.createWriteStream(target,{highWaterMark:1});
//可读流到可写流,异步操作,可以保证内存不会被淹没,读一点,写一点
// 如果想看文件类容,使用readFile
rs.pipe(ws);
}
pipe('./1.txt','./4.txt')
直接将读取的流操作到写入流中,还是异步操作
以上是“Node.js如何使用流实现读写同步边读边写功能”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注编程网VUE频道!
--结束END--
本文标题: Node.js如何使用流实现读写同步边读边写功能
本文链接: https://www.lsjlt.com/news/72644.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0