node.js implémente la fonction de synchronisation en lecture et en écriture

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

La façon d'écrire ci-dessus est plutôt lourde. Une fois que tout le monde l'a lu, oubliez-la

. node.js nous fournit la méthode pipe intégrée

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

Opérez directement le flux de lecture dans le flux d'écriture ou opérez de manière asynchrone

Je pense que vous maîtrisez la méthode après avoir lu le cas dans cet article. Pour des informations plus intéressantes, veuillez prêter attention aux autres articles connexes sur le chinois PHP. site web!

Lecture recommandée :

Étapes d'installation détaillées de JSONBuddy

Comment Vuejs opère la régionalisation des pages

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!