node的事件流
什么是流被因？流是一種抽象的數(shù)據(jù)結(jié)構(gòu)锻霎。想象水流蹈矮，當(dāng)在水管中流動時，就可以從某個地方（例如自來水廠）源源不斷地到達(dá)另一個地方（比如你家的洗手池）畜眨。我們也可以把數(shù)據(jù)看成是數(shù)據(jù)流昼牛，比如你敲鍵盤的時候，就可以把每個字符依次連起來康聂，看成字符流贰健。這個流是從鍵盤輸入到應(yīng)用程序，實際上它還對應(yīng)著一個名字：標(biāo)準(zhǔn)輸入流（stdin）恬汁。
如果應(yīng)用程序把字符一個一個輸出到顯示器上伶椿，這也可以看成是一個流，這個流也有名字：標(biāo)準(zhǔn)輸出流（stdout）氓侧。流的特點是數(shù)據(jù)是有序的脊另，而且必須依次讀取，或者依次寫入约巷，不能像Array那樣隨機(jī)定位偎痛。
有些流用來讀取數(shù)據(jù)，比如從文件讀取數(shù)據(jù)時独郎，可以打開一個文件流踩麦，然后從文件流中不斷地讀取數(shù)據(jù)枚赡。有些流用來寫入數(shù)據(jù)，比如向文件寫入數(shù)據(jù)時谓谦，只需要把數(shù)據(jù)不斷地往文件流中寫進(jìn)去就可以了贫橙。
在Node.js中，流也是一個對象反粥，我們只需要響應(yīng)流的事件就可以了：data事件表示流的數(shù)據(jù)已經(jīng)可以讀取了料皇，end事件表示這個流已經(jīng)到末尾了，沒有數(shù)據(jù)可以讀取了星压，error事件表示出錯了践剂。
'use strict';
var fs = require('fs');
// 打開一個流:
var rs = fs.createReadStream('sample.txt', 'utf-8');
rs.on('data', function (chunk) {
console.log('DATA:')
console.log(chunk);
});
rs.on('end', function () {
console.log('END');
});
rs.on('error', function (err) {
console.log('ERROR: ' + err);
});
要注意，data事件可能會有多次娜膘，每次傳遞的chunk是流的一部分?jǐn)?shù)據(jù)逊脯。
要以流的形式寫入文件，只需要不斷調(diào)用write()方法竣贪，最后end()結(jié)束：
'use strict';
var fs = require('fs');
var ws1 = fs.createWriteStream('output1.txt', 'utf-8');
ws1.write('使用Stream寫入文本數(shù)據(jù)...\n');
ws1.write('END.');
ws1.end();
var ws2 = fs.createWriteStream('output2.txt');
ws2.write(new Buffer('使用Stream寫入二進(jìn)制數(shù)據(jù)...\n', 'utf-8'));
ws2.write(new Buffer('END.', 'utf-8'));
ws2.end();
pipe是串聯(lián)兩個事件流
在Node.js中军洼，Readable流有一個pipe()方法，就是用來干這件事的演怎。
讓我們用pipe()把一個文件流和另一個文件流串起來匕争，這樣源文件的所有數(shù)據(jù)就自動寫入到目標(biāo)文件里了，所以爷耀，這實際上是一個復(fù)制文件的程序：
'use strict';
var fs = require('fs');
var rs = fs.createReadStream('sample.txt');
var ws = fs.createWriteStream('copied.txt');
rs.pipe(ws);
