導(dǎo)言:nodejs中所有與文件相關(guān)的操作都在fs模塊中,而讀寫(xiě)操作又是我們會(huì)經(jīng)常用到的操作,nodejs的fs模塊針對(duì)讀操作為我們提供了readFile,read, createReadStream三個(gè)方法,針對(duì)寫(xiě)操作為我們提供了writeFile,write, createWriteStream三個(gè)方法,下面分析一下它們的區(qū)別:
東麗網(wǎng)站制作公司哪家好,找創(chuàng)新互聯(lián)公司!從網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開(kāi)發(fā)、APP開(kāi)發(fā)、響應(yīng)式網(wǎng)站等網(wǎng)站項(xiàng)目制作,到程序開(kāi)發(fā),運(yùn)營(yíng)維護(hù)。創(chuàng)新互聯(lián)公司公司2013年成立到現(xiàn)在10年的時(shí)間,我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn),來(lái)保證我們的工作的順利進(jìn)行。專(zhuān)注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)公司。
一、readFile和writeFile
1、readFile方法是將要讀取的文件內(nèi)容完整讀入緩存區(qū),再?gòu)脑摼彺鎱^(qū)中讀取文件內(nèi)容,具體操作如下:
fs.readFile('./test.txt', 'utf8', function(err, data){ console.log(data); });
與其對(duì)應(yīng)的同步方法為:
var data = fs.readFileSync('./test.txt', 'utf8'); console.log(data);
同步方法和異步方法的區(qū)別是:在使用同步方法執(zhí)行的操作結(jié)束之前,不能執(zhí)行后續(xù)代碼的執(zhí)行;而異步方法將操作結(jié)果作為回調(diào)函數(shù)的參數(shù)進(jìn)行返回,方法調(diào)用之后,就可以立即執(zhí)行后續(xù)的代碼,讀取完畢后會(huì)調(diào)用對(duì)應(yīng)的回調(diào)函數(shù)。
2、writeFile方法是將要寫(xiě)入的文件內(nèi)容完整的讀入緩存區(qū),然后一次性的將緩存區(qū)中的內(nèi)容寫(xiě)入都文件中,其同步和異步具體操作如下:
//異步方法 fs.writeFile('./message.txt', '這是第一行',function(err){ if(err) console.log('寫(xiě)文件操作失敗'); else console.log('寫(xiě)文件操作成功'); }); //同步方法 fs.writeFileSync('./message.txt','這是第一行');
以上的讀寫(xiě)操作,Node.js將文件內(nèi)容視為一個(gè)整體,為其分配緩存區(qū)并且一次性將文件內(nèi)容讀取到緩存區(qū)中,在這個(gè)期間,Node.js將不能執(zhí)行任何其他處理。所以當(dāng)讀寫(xiě)大文件的時(shí)候,有可能造成緩存區(qū)“爆倉(cāng)”。
二、read和write
1、read或readSync方法讀取文件內(nèi)容是不斷地將文件中的一小塊內(nèi)容讀入緩存區(qū),最后從該緩存區(qū)中讀取文件內(nèi)容,具體操作如下:
var fs = require('fs'); fs.open('./message.txt','r',function(err,fd){ var buf = new Buffer(225); //讀取fd文件內(nèi)容到buf緩存區(qū) fs.read(fd,buf,0,9,3,function(err,bytesRead,buffer){ console.log(buf.slice(0,bytesRead).toString()); }); var buff = new Buffer(225); //位置設(shè)置為null會(huì)默認(rèn)從文件當(dāng)前位置讀取 fs.read(fd,buff,0,3,null,function(err,bytesRead,buffer){ console.log(buff.slice(0,bytesRead).toString()); }); var buffer = new Buffer(225); //同步方法讀取文件 var bytesRead = fs.readFileSync(fd,buffer,0,9,3); console.log(bytesRead); console.log(buffer.slice(0,bytesRead).toString()); });
2、write或writeSync方法寫(xiě)入內(nèi)容時(shí),node.js執(zhí)行以下過(guò)程:1將需要寫(xiě)入的數(shù)據(jù)寫(xiě)入到一個(gè)內(nèi)存緩存區(qū);2待緩存區(qū)寫(xiě)滿后再將緩存區(qū)中的內(nèi)容寫(xiě)入到文件中;3重復(fù)執(zhí)行步驟1和步驟2,知道數(shù)據(jù)全部寫(xiě)入文件為止。具體操作如下:
var fs = require('fs'); var buf = new Buffer('我喜愛(ài)編程'); fs.open('./mess.txt','w',function(err,fd){ fs.write(fd,buf,3,9,0,function(err,written,buffer){ fs.write(fd,buf,12,3,null,function(err,written,buffer){ if(err) console.log('寫(xiě)文件操作失敗'); console.log('寫(xiě)文件操作成功'); }); }); //同步寫(xiě)入 fs.writeSync(fd,buf,3,9,0); });
以上讀寫(xiě)操作,node.js會(huì)將文件分成一塊一塊逐步操作,在讀寫(xiě)文件過(guò)程中允許執(zhí)行其他操作。
但有的時(shí)候我們并不關(guān)心整個(gè)文件的內(nèi)容,而只關(guān)注從文件中讀取到的某些數(shù)據(jù),以及讀取到數(shù)據(jù)時(shí)需要執(zhí)行的處理,這時(shí)我們可以使用文件流來(lái)處理。
三、createReadStream和createWriteStream
1、createReadStream方法創(chuàng)建一個(gè)將文件內(nèi)容讀取為流數(shù)據(jù)的ReadStream對(duì)象,方法如下所示:
var fs = require('fs'); var readStream = fs.createReadStream('./message.txt',{start:3,end:12}); readStream.on('open',function(fd){ console.log('開(kāi)始讀取文件'); }); readStream.on('data',function(data){ console.log('讀取到數(shù)據(jù):'); console.log(data); }); readStream.on('end',function(){ console.log('文件已全部讀取完畢'); }); readStream.on('close',function(){ console.log('文件被關(guān)閉'); }); readStream.on('error',function(err){ console.log('讀取文件失敗'); });
2、createWriteStream方法創(chuàng)建一個(gè)將流數(shù)據(jù)寫(xiě)入文件中的WriteStream對(duì)象,方法如下所示:
var fs = require('fs'); var file = fs.createReadStream('./message.txt'); var out = fs.createWriteStream('./anotherMessage.txt'); file.on('data',function(data){ out.write(data); }); out.on('open',function(fd){ console.log('需要被寫(xiě)入的文件已打開(kāi)'); }); file.on('end',function(){ //將操作系統(tǒng)緩存區(qū)中的數(shù)據(jù)全部寫(xiě)入文件 out.end('再見(jiàn)',function(){ console.log('文件全部寫(xiě)入完畢'); console.log('共寫(xiě)入'+out.bytesWritten+'數(shù)據(jù)'); }); });
以上方法可以對(duì)讀寫(xiě)文件的過(guò)程中進(jìn)行監(jiān)聽(tīng),并定義相關(guān)的方法pause和resume暫停或恢復(fù)文件的讀取操作,可以監(jiān)聽(tīng)寫(xiě)入時(shí)緩存區(qū)數(shù)據(jù)是否已滿或者是否已全部輸出,如下所示:
//監(jiān)聽(tīng)writeStream對(duì)象的drain事件 var fs = require('fs'); var out = fs.createWriteStream('./test1.txt'); for(var i=0;i<10000;i++){ //返回true或false true代表緩存區(qū)已滿 var flag = out.write(i.toString()); console.log(flag); } out.on('drain',function(){ console.log('操作系統(tǒng)緩存區(qū)中的數(shù)據(jù)已全部輸出'); var out = fs.createWriteStream('./test2.txt'); for(var i=0;i<10;i++){ var flag = out.write(i.toString()); console.log(flag); } out.on('drain',function(){ console.log('操作系統(tǒng)緩存區(qū)中的數(shù)據(jù)已全部輸出'); }); });
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持創(chuàng)新互聯(lián)。