Stream 是一個(gè)抽象接口公给，Node 中有很多對象實(shí)現(xiàn)了這個(gè)接口姚糊。例如遏弱，對http 服務(wù)器發(fā)起請求的request 對象就是一個(gè) Stream蜒灰，還有stdout（標(biāo)準(zhǔn)輸出）弦蹂。
圖片.png
- <h1>從流中讀取數(shù)據(jù)
var fs=require('fs');
var data='';
//創(chuàng)建可讀流
var readerStream=fs.createReadStream('input.txt');
//設(shè)置編碼為utf-8
readerStream.setEncoding('UTF-8');
//處理流事件-->data,end,and error
readerStream.on('data',function(chunk){
data+=chunk;
});
readerStream.on('end',function(){
console.log(data);
});
readerStream.on('error',function(err){
console.log(err.stack);
});
console.log("程序執(zhí)行完畢");
運(yùn)行結(jié)果：
程序執(zhí)行完畢
菜鳥教程官網(wǎng)地址：www.runoob.com
- <h1>寫入流
var fs = require("fs");
var data = '菜鳥教程官網(wǎng)地址：www.runoob.com';
// 創(chuàng)建一個(gè)可以寫入的流，寫入到文件 output.txt 中
var writerStream = fs.createWriteStream('output.txt');
// 使用 utf8 編碼寫入數(shù)據(jù)
writerStream.write(data,'UTF8');
// 標(biāo)記文件末尾
writerStream.end();
// 處理流事件 --> data, end, and error
writerStream.on('finish', function() {
console.log("寫入完成强窖。");
});
writerStream.on('error', function(err){
console.log(err.stack);
});
console.log("程序執(zhí)行完畢");
- <h1>管道流
圖片.png
如上面的圖片所示凸椿，我們把文件比作裝水的桶，而水就是文件里的內(nèi)容翅溺，我們用一根管子(pipe)連接兩個(gè)桶使得水從一個(gè)桶流入另一個(gè)桶脑漫，這樣就慢慢的實(shí)現(xiàn)了大文件的復(fù)制過程。
以下實(shí)例我們通過讀取一個(gè)文件內(nèi)容并將內(nèi)容寫入到另外一個(gè)文件中咙崎。
var fs = require("fs");
// 創(chuàng)建一個(gè)可讀流
var readerStream = fs.createReadStream('input.txt');
// 創(chuàng)建一個(gè)可寫流
var writerStream = fs.createWriteStream('output.txt');
// 管道讀寫操作
// 讀取 input.txt 文件內(nèi)容优幸，并將內(nèi)容寫入到 output.txt 文件中
readerStream.pipe(writerStream);
console.log("程序執(zhí)行完畢");
- <h1>鏈?zhǔn)搅?/li>
鏈?zhǔn)绞峭ㄟ^連接輸出流到另外一個(gè)流并創(chuàng)建多個(gè)對個(gè)流操作鏈的機(jī)制。鏈?zhǔn)搅饕话阌糜诠艿啦僮鳌?/p>
接下來我們就是用管道和鏈?zhǔn)絹韷嚎s和解壓文件叙凡。
創(chuàng)建 compress.js 文件, 代碼如下
var fs = require("fs");
var zlib = require('zlib');
// 壓縮 input.txt 文件為 input.txt.gz
fs.createReadStream('input.txt')
.pipe(zlib.createGzip())
.pipe(fs.createWriteStream('input.txt.gz'));
console.log("文件壓縮完成劈伴。");
執(zhí)行完以上操作后，我們可以看到當(dāng)前目錄下生成了 input.txt 的壓縮文件 input.txt.gz握爷。
接下來跛璧，讓我們來解壓該文件，創(chuàng)建 decompress.js 文件新啼，代碼如下：
var fs = require("fs");
var zlib = require('zlib');
// 解壓 input.txt.gz 文件為 input.txt
fs.createReadStream('input.txt.gz')
.pipe(zlib.createGunzip())
.pipe(fs.createWriteStream('input.txt'));
console.log("文件解壓完成追城。");
