您好,登錄后才能下訂單哦!
node.js中怎么利用流實(shí)現(xiàn)讀寫同步,針對(duì)這個(gè)問題,這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答,希望可以幫助更多想解決這個(gè)問題的小伙伴找到更簡單易行的方法。
如下所示:
//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')
關(guān)于node.js中怎么利用流實(shí)現(xiàn)讀寫同步問題的解答就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。