流式讀寫文件

第一步先要弄清楚為什么需要壓縮和解壓文件，這是因?yàn)槲募罅?，我們需要將文件進(jìn)行壓縮，既然壓縮了。

后期就需要對(duì)其進(jìn)行解壓縮。我們要考慮最壞的打算，文件過(guò)于大，電腦內(nèi)存沒(méi)辦法一步獲取并且存儲(chǔ)這么大的文件，所以我們需要使用到流式的方法來(lái)處理文件。

首先來(lái)了解一下如何流式處理文件

知識(shí)預(yù)知

fs模塊里有Stream相關(guān)接口：

• createReadStream可以創(chuàng)建讀文件流，
• createWriteStream可以創(chuàng)建寫文件流，

pipe可以在兩個(gè)流之間創(chuàng)建一個(gè)管道，一部分一部分的將一個(gè)文件流里面的數(shù)據(jù)傳輸?shù)搅硪粋€(gè)文件流里

例子

舉個(gè)例子，來(lái)理解一下使用方法

let fs = require('fs');
let readerStream = fs.createReadStream('a.txt');
let writerStream = fs.createWriteStream('b.txt');
readerStream.pipe(writerStream);

這段代碼各位看客可以復(fù)制下來(lái)運(yùn)行一下，看看結(jié)果，當(dāng)然你至少要保證讀文件流里的路徑地址是真實(shí)存在的，即同級(jí)目錄下，你在創(chuàng)建一個(gè)a.txt文件，里面隨便寫上一些內(nèi)容，運(yùn)行后會(huì)在同級(jí)目錄下生成一個(gè)b.txt文件，這個(gè)文件里面的內(nèi)容就是通過(guò)文件流和管道方法，從a.txt文件里復(fù)制過(guò)來(lái)的內(nèi)容。

這段代碼創(chuàng)建了兩個(gè)文件流，一個(gè)是讀文件流，一個(gè)是寫文件流，如何通過(guò)pipe方法將兩個(gè)文件流相通，從讀文件流中讀數(shù)據(jù)傳入到寫文件流里面，這樣的方式傳輸數(shù)據(jù)不會(huì)占用太多空間，因?yàn)樵谶@個(gè)傳輸過(guò)程中，每次只有一小部分的數(shù)據(jù)進(jìn)入占有內(nèi)存。

壓縮解壓文件

知識(shí)預(yù)知

node.js里有個(gè)原生模塊庫(kù)zlib進(jìn)行文件的壓縮解壓處理

• createGzip方法壓縮文件
• createGunzip方法解壓文件

壓縮文件

fs.createReadStream('a.txt')
  .pipe(zlib.createGzip())
  .pipe(fs.createWriteStream('input.txt.gz'));

一行一行的來(lái)觀察這個(gè)三行代碼，第一行創(chuàng)建了讀文件流，讀取a.txt里面的文件，第二行通過(guò)zlib.createGzip()對(duì)數(shù)據(jù)進(jìn)行壓縮，第三行通過(guò)fs.createWriteStream(‘input.txt.gz’)將文件寫出到input.txt.gz文件里。

這三個(gè)部分通過(guò)pipe進(jìn)行連接，也就是說(shuō)處理的不是一個(gè)完整的文件，而是一部分一部分的處理文件，也就是通過(guò)流式的方式處理文件。

解壓文件

fs.createReadStream('input.txt.gz')
  .pipe(zlib.createGunzip())
  .pipe(fs.createWriteStream('c.txt'));

通過(guò)先前的壓縮文件的講解，詳細(xì)各位同學(xué)應(yīng)該也能看得懂解壓文件的各個(gè)部分做了什么事情，希望各位同學(xué)自己思考思考。

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

最新評(píng)論