node.js利用流实现读写同步,边读边写的功能

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了node.js利用流实现读写同步,边读边写的功能，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1490字，纯文字阅读大概需要3分钟。

内容图文

下面为大家带来一篇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')

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

以上就是本文的全部内容，希望对大家的学习有所帮助，更多相关内容请关注PHP中文网！

相关推荐：

关于nodejs socket服务端和客户端的简单通信功能

angular2和nodejs实现图片上传的的的功能

以上就是node.js 利用流实现读写同步,边读边写的功能的详细内容，更多请关注Gxl网其它相关文章！

内容总结

以上是互联网集市为您收集整理的node.js利用流实现读写同步,边读边写的功能全部内容，希望文章能够帮你解决node.js利用流实现读写同步,边读边写的功能所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---