node.js 利用流實(shí)現(xiàn)讀寫同步,邊讀邊寫的方法
如下所示:
//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)存不會(huì)被淹沒,讀一點(diǎn),寫一點(diǎn)
// 如果想看文件類容,使用readFile
rs.pipe(ws);
}
pipe('./1.txt','./4.txt')
直接將讀取的流操作到寫入流中,還是異步操作
以上這篇node.js 利用流實(shí)現(xiàn)讀寫同步,邊讀邊寫的方法就是小編分享給大家的全部內(nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
- node.js基于fs模塊對(duì)系統(tǒng)文件及目錄進(jìn)行讀寫操作的方法詳解
- Node.js 使用流實(shí)現(xiàn)讀寫同步邊讀邊寫功能
- 基于node.js的fs核心模塊讀寫文件操作(實(shí)例講解)
- Node.js Sequelize如何實(shí)現(xiàn)數(shù)據(jù)庫的讀寫分離
- Node.js的文件權(quán)限及讀寫flag詳解
- Node.js讀寫文件之批量替換圖片的實(shí)現(xiàn)方法
- Node.js Streams文件讀寫操作詳解
- 在Node.js應(yīng)用中讀寫Redis數(shù)據(jù)庫的簡單方法
- 詳解Node.js讀寫中文內(nèi)容文件操作
相關(guān)文章
xtemplate node.js 的使用方法實(shí)例解析
這篇文章主要介紹了xtemplate node.js 的使用方法實(shí)例說明,非常不錯(cuò),介紹的非常詳細(xì),具有參考借鑒價(jià)值,需要的朋友可以參考下2016-08-08
Node.js版本發(fā)布策略頻率與穩(wěn)定性的平衡
這篇文章主要為大家介紹了Node.js版本發(fā)布策略頻率與穩(wěn)定性的平衡,幫助大家大家更清晰了解node發(fā)展史,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-10-10
websocket結(jié)合node.js實(shí)現(xiàn)雙向通信的示例代碼
本文主要介紹了websocket結(jié)合node.js實(shí)現(xiàn)雙向通信的示例代碼,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-02-02
在Node.js中使用Express框架和Mongoose庫實(shí)現(xiàn)視頻評(píng)論功能
本文我們將詳細(xì)介紹如何在Node.js應(yīng)用中使用Express框架和Mongoose庫來實(shí)現(xiàn)一個(gè)視頻評(píng)論功能,這個(gè)功能允許用戶對(duì)視頻內(nèi)容添加評(píng)論,并將評(píng)論數(shù)實(shí)時(shí)更新,以下是逐步的實(shí)現(xiàn)過程,包括代碼示例和說明,需要的朋友可以參考下2024-04-04
nodeJs爬蟲獲取數(shù)據(jù)簡單實(shí)現(xiàn)代碼
這篇文章主要為大家詳細(xì)介紹了nodeJs爬蟲獲取數(shù)據(jù)簡單實(shí)現(xiàn)代碼,感興趣的小伙伴們可以參考一下2016-03-03
nodejs中express入門和基礎(chǔ)知識(shí)點(diǎn)學(xué)習(xí)
這篇文章給大家分享了關(guān)于學(xué)習(xí)nodejs中express入門和基礎(chǔ)知識(shí)點(diǎn)內(nèi)容,有興趣的朋友們參考下。2018-09-09

