Node.js 使用流實現(xiàn)讀寫同步邊讀邊寫功能
更新時間:2017年09月11日 08:39:35 作者:八bug哥哥
本文通過代碼給大家介紹了Node.js 使用流實現(xiàn)讀寫同步邊讀邊寫功能,非常不錯,具有參考借鑒價值,需要的額朋友參考下吧
廢話不多說了,直接給大家貼代碼了,具體代碼如下所示:
//10個數(shù) 10個字節(jié),每次讀4b,寫1b let fs=require("fs"); function pipe(source,target) { //先創(chuàng)建可讀流,再創(chuàng)建可寫流 //先讀一次,rs.on(data) //將讀到的類容寫入目標中 ,返回布爾值,如果是ture,繼續(xù)寫,默認情況應該是false,暫停讀取 //ws.on('drain'),抽干后,回復讀取 //監(jiā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)存干了就恢復讀取 console.log("111"); rs.resume() //恢復讀取 }); 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')
直接將讀取的流操作到寫入流中,還是異步操作
總結
以上所述是小編給大家介紹的Node.js 使用流實現(xiàn)讀寫同步邊讀邊寫功能,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持!
相關文章
基于node實現(xiàn)websocket協(xié)議
這篇文章主要介紹了基于node實現(xiàn)websocket協(xié)議的相關資料,需要的朋友可以參考下2016-04-04Nodejs在局域網(wǎng)配置https訪問的實現(xiàn)方法
做一個局域網(wǎng)WebRTC視頻聊天系統(tǒng),需要用到HTTPS。因此,配置Node.js使其支持HTTPS訪問。這篇文章主要介紹了Nodejs在局域網(wǎng)配置https訪問的實現(xiàn)方法,需要的朋友可以參考下2020-10-10Node.js中使用計時器定時執(zhí)行函數(shù)詳解
這篇文章主要介紹了Node.js中使用計時器定時執(zhí)行函數(shù)詳解,本文使用了Node.js中的setTimeout和setInterval函數(shù),需要的朋友可以參考下2014-08-08React+react-dropzone+node.js實現(xiàn)圖片上傳的示例代碼
本篇文章主要介紹了React+react-dropzone+node.js實現(xiàn)圖片上傳的示例代碼,非常具有實用價值,需要的朋友可以參考下2017-08-08nodemon實現(xiàn)Typescript項目熱更新的示例代碼
這篇文章主要介紹了nodemon實現(xiàn)Typescript項目熱更新的示例代碼,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2019-11-11