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 利用流实现读写同步,边读边写的方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。

# node.js # 流实现读写同步 # node.js基于fs模块对系统文件及目录进行读写操作的方法详解 # Node.js 使用流实现读写同步边读边写功能 # 基于node.js的fs核心模块读写文件操作(实例讲解) # Node.js Sequelize如何实现数据库的读写分离 # Node.js的文件权限及读写flag详解 # Node.js读写文件之批量替换图片的实现方法 # Node.js Streams文件读写操作详解 # 在Node.js应用中读写Redis数据库的简单方法 # 详解Node.js读写中文内容文件操作 # 给大家 # 给我们 # 就行 # 希望能 # 看完 # 想看 # 所示 # 这篇 # 干了 # 小编 # 读到 # 大家多多 # 流到 # 续写 # 应该是 # 完毕后 # 布尔值 # function # pipe # require

返回目录在线咨询

上一篇：如何撰写引人注目的短视频描述_SEO优化教程
下一篇：网站速度与SEO的关系_SEO优化教程

您的项目需求

*请认真填写需求信息，我们会在24小时内与您取得联系。

全网整合营销服务商

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

您的项目需求