node.js中怎么利用流實現(xiàn)讀寫同步，針對這個問題，這篇文章詳細(xì)介紹了相對應(yīng)的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

創(chuàng)新互聯(lián)建站長期為1000+客戶提供的網(wǎng)站建設(shè)服務(wù)，團隊從業(yè)經(jīng)驗10年，關(guān)注不同地域、不同群體，并針對不同對象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺，與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為巴彥淖爾企業(yè)提供專業(yè)的做網(wǎng)站、網(wǎng)站制作，巴彥淖爾網(wǎng)站改版等技術(shù)服務(wù)。擁有十余年豐富建站經(jīng)驗和眾多成功案例,為您定制開發(fā)。

如下所示：

//10個數(shù) 10個字節(jié)，每次讀4b,寫1b
let fs=require("fs");
function pipe(source,target) {
  //先創(chuàng)建可讀流，再創(chuàng)建可寫流
  //先讀一次，rs.on(data)
  //將讀到的類容寫入目標(biāo)中 ，返回布爾值，如果是ture,繼續(xù)寫，默認(rèn)情況應(yīng)該是false,暫停讀取
  //ws.on('drain'),抽干后，回復(fù)讀取
  //監(jiān)聽讀取文件完畢后，關(guān)閉讀取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 () {
    //每次寫的內(nèi)存干了就恢復(fù)讀取
    console.log("111");
    rs.resume() //恢復(fù)讀取
  });
  rs.on('end',function (chunk) {
    ws.end();
  })

}
pipe('./1.txt','./3.txt')

上面這種寫法比較繁瑣，大家看完后，忘記就行

node.js提供給我們內(nèi)置方法pipe

//10個數(shù) 10個字節(jié)，每次讀4b,寫1b
let fs=require("fs");
function pipe(source,target) {

  let rs=fs.createReadStream(source,{highWaterMark:4});
  let ws=fs.createWriteStream(target,{highWaterMark:1});
  //可讀流到可寫流,異步操作，可以保證內(nèi)存不會被淹沒，讀一點，寫一點
  // 如果想看文件類容，使用readFile

  rs.pipe(ws);
}
pipe('./1.txt','./4.txt')

關(guān)于node.js中怎么利用流實現(xiàn)讀寫同步問題的解答就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識。