node.js uses streams to achieve synchronization of reading and writing, and the function of reading and writing at the same time

The following will bring you an article about how node.js uses streams to achieve synchronization of reading and writing, and how to write while reading. The content is quite good, so I will share it with you now and give it as a reference.

is as follows:

//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')

The above writing method is more complicated, please see After finishing, forget about it

node.js provides us with the built-in method 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')

Directly operate the read stream into the write stream , or asynchronous operation

The above is the entire content of this article. I hope it will be helpful to everyone's learning. For more related content, please pay attention to the PHP Chinese website!

Related recommendations:

About the simple communication function between nodejs socket server and client

angular2 and nodejs implement image upload The function

The above is the detailed content of node.js uses streams to achieve synchronization of reading and writing, and the function of reading and writing at the same time. For more information, please follow other related articles on the PHP Chinese website!