Node.js怎么使用流實現邊讀邊寫功能

這篇“Node.js怎么使用流實現邊讀邊寫功能”文章的知識點大部分人都不太理解，所以小編給大家總結了以下內容，內容詳細，步驟清晰，具有一定的借鑒價值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“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怎么使用流實現邊讀邊寫功能”這篇文章的內容，相信大家都有了一定的了解，希望小編分享的內容對大家有幫助，若想了解更多相關的知識內容，請關注億速云行業資訊頻道。