Node.js怎么使用流实现读写同步边读边写功能

本篇内容主要讲解"Node.js怎么使用流实现读写同步边读边写功能"，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习"Node.js怎么使用流实现读写同步边读边写功能"吧!

具体代码如下所示：

//10个数 10个字节，每次读4b,写1blet 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,写1blet 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怎么使用流实现读写同步边读边写功能"有了更深的了解，不妨来实际操作一番吧！这里是网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！