这篇“Node.js怎么使用流实现边读边写功能”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“Node.js怎么使用流实现边读边写功能”文章吧。
成都创新互联是一家专业提供右玉企业网站建设,专注与网站设计制作、成都网站建设、html5、小程序制作等业务。10年已为右玉众多企业、政府机构等服务。创新互联专业网站制作公司优惠进行中。
具体代码如下所示：
//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怎么使用流实现边读边写功能”这篇文章的内容，相信大家都有了一定的了解，希望小编分享的内容对大家有帮助，若想了解更多相关的知识内容，请关注创新互联行业资讯频道。
