快捷導(dǎo)航

Node.js 使用流實(shí)現(xiàn)讀寫同步邊讀邊寫功能

更新時(shí)間：2017年09月11日 08:39:35 作者：八bug哥哥

本文通過代碼給大家介紹了Node.js 使用流實(shí)現(xiàn)讀寫同步邊讀邊寫功能，非常不錯(cuò)，具有參考借鑒價(jià)值，需要的額朋友參考下吧

廢話不多說了，直接給大家貼代碼了，具體代碼如下所示：

//10個(gè)數(shù) 10個(gè)字節(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個(gè)數(shù) 10個(gè)字節(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)存不會被淹沒，讀一點(diǎn)，寫一點(diǎn)
  // 如果想看文件類容，使用readFile

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

直接將讀取的流操作到寫入流中，還是異步操作

總結(jié)

以上所述是小編給大家介紹的Node.js 使用流實(shí)現(xiàn)讀寫同步邊讀邊寫功能，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時(shí)回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！

您可能感興趣的文章:

相關(guān)文章

Nodejs中獲取當(dāng)前函數(shù)被調(diào)用的行數(shù)及文件名詳解
這篇文章主要給大家介紹了關(guān)于Nodejs中獲取當(dāng)前函數(shù)被調(diào)用的行數(shù)及文件名的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2018-12-12
使用node.js中的Buffer類處理二進(jìn)制數(shù)據(jù)的方法
大家應(yīng)該都知道在客戶端JavaScript腳本代碼中，對二進(jìn)制數(shù)據(jù)并沒有提供一個(gè)很好的支持。然而，在處理TCP流或文件流時(shí)，必須要處理二進(jìn)制數(shù)據(jù)。因此，下面通過這篇文章來一起看看利用node.js中的Buffer類處理二進(jìn)制數(shù)據(jù)的方法，有需要的朋友們可以參考借鑒。
2016-11-11
利用node.js如何搭建一個(gè)簡易的即時(shí)響應(yīng)服務(wù)器
這篇文章主要介紹了利用node.js如何搭建一個(gè)簡易的即時(shí)響應(yīng)服務(wù)器的相關(guān)資料，文中介紹的非常詳細(xì)，對大家具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面跟著小編一起來學(xué)習(xí)學(xué)習(xí)吧。
2017-05-05
node.js微信小程序配置消息推送的實(shí)現(xiàn)
這篇文章主要介紹了node.js微信小程序配置消息推送的實(shí)現(xiàn)，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧
2019-02-02
關(guān)于Yarn的使用及說明
這篇文章主要介紹了關(guān)于Yarn的使用及說明,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
2023-11-11
NodeJS實(shí)現(xiàn)客戶端js加密
本文主要介紹了NodeJS實(shí)現(xiàn)客戶端js加密的思路與方法，具有一定的參考價(jià)值，下面跟著小編一起來看下吧
2017-01-01
切換到淘寶最新npm鏡像源的全面指南(支持 Windows、macOS 和多種 Linux
在開發(fā)過程中,npm 是前端開發(fā)者不可或缺的工具,但對于國內(nèi)的開發(fā)者來說,npm 官方源在下載速度上存在一定的瓶頸,本文將詳細(xì)介紹如何在 Windows、macOS 以及各類 Linux 發(fā)行版上切換到淘寶的 npm 鏡像源,需要的朋友可以參考下
2025-03-03
淺談Node的內(nèi)存泄露
隨著node、react同構(gòu)等技術(shù)越來越廣泛地使用, 內(nèi)存泄漏的事情時(shí)有發(fā)生,應(yīng)當(dāng)引起足夠的重視，本文主要介紹了Node的內(nèi)存泄露，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2022-05-05
Koa2微信公眾號開發(fā)之消息管理
這篇文章主要介紹了Koa2微信公眾號開發(fā)之消息管理，這一節(jié)我們就來看看公眾號的消息管理。并實(shí)現(xiàn)一個(gè)自動(dòng)回復(fù)功能，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2018-05-05
詳解從NodeJS搭建中間層再談前后端分離
這篇文章主要介紹了詳解從NodeJS搭建中間層再談前后端分離，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧
2018-11-11