模塊概覽
nodejs的核心模塊乳附，基本上都是stream的的實(shí)例内地，比如process.stdout、http.clientRequest赋除。
對(duì)于大部分的nodejs開(kāi)發(fā)者來(lái)說(shuō)阱缓，平常并不會(huì)直接用到stream模塊，只需要了解stream的運(yùn)行機(jī)制即可（非常重要）举农。
而對(duì)于想要實(shí)現(xiàn)自定義stream實(shí)例的開(kāi)發(fā)者來(lái)說(shuō)荆针，就得好好研究stream的擴(kuò)展API了，比如gulp的內(nèi)部實(shí)現(xiàn)就大量用到了自定義的stream類(lèi)型。
來(lái)個(gè)簡(jiǎn)單的例子鎮(zhèn)樓航背，幾行代碼就實(shí)現(xiàn)了讀取文件內(nèi)容喉悴，并打印到控制臺(tái)：
constfs =require('fs');fs.createReadStream('./sample.txt').pipe(process.stdout);
Stream分類(lèi)
在nodejs中，有四種stream類(lèi)型：
Readable：用來(lái)讀取數(shù)據(jù)沃粗，比如fs.createReadStream()粥惧。
Writable：用來(lái)寫(xiě)數(shù)據(jù)，比如fs.createWriteStream()最盅。
Duplex：可讀+可寫(xiě)突雪，比如net.Socket()。
Transform：在讀寫(xiě)的過(guò)程中涡贱，可以對(duì)數(shù)據(jù)進(jìn)行修改咏删，比如zlib.createDeflate()（數(shù)據(jù)壓縮/解壓）。
Readable Stream
以下都是nodejs中常見(jiàn)的Readable Stream问词，當(dāng)然還有其他的督函，可自行查看文檔。
http.IncomingRequest
fs.createReadStream()
process.stdin
其他
例子一：
varfs =require('fs');
fs.readFile('./sample.txt','utf8',function(err, content){// 文件讀取完成激挪，文件內(nèi)容是 [你好辰狡，我是程序猿小卡]console.log('文件讀取完成，文件內(nèi)容是 [%s]', content);});
例子三：
這里使用了.pipe(dest)垄分，好處在于宛篇，如果文件
varfs =require('fs');fs.createReadStream('./sample.txt').pipe(process.stdout);
注意：這里只是原封不動(dòng)的將內(nèi)容輸出到控制臺(tái)，所以實(shí)際上跟前兩個(gè)例子有細(xì)微差異薄湿〗斜叮可以稍做修改，達(dá)到上面同樣的效果
varfs =require('fs');varonEnd =function(){ process.stdout.write(']'); };varfileStream = fs.createReadStream('./sample.txt');fileStream.on('end', onEnd)fileStream.pipe(process.stdout);process.stdout.write('文件讀取完成豺瘤，文件內(nèi)容是[');// 文件讀取完成吆倦，文件內(nèi)容是[你好，我是程序猿小卡]
Writable Stream
同樣以寫(xiě)文件為例子坐求，比如想將hello world寫(xiě)到sample.txt里蚕泽。
例子一：
varfs =require('fs');varcontent ='hello world';varfilepath ='./sample.txt';fs.writeFile(filepath, content);
例子二：
varfs =require('fs');varcontent ='hello world';varfilepath ='./sample.txt';varwriteStram = fs.createWriteStream(filepath);writeStram.write(content);writeStram.end();
Duplex Stream
最常見(jiàn)的Duplex stream應(yīng)該就是net.Socket實(shí)例了，在前面的文章里有接觸過(guò)瞻赶，這里就直接上代碼了赛糟，這里包含服務(wù)端代碼、客戶(hù)端代碼砸逊。
服務(wù)端代碼：
varnet =require('net');varopt = {host:'127.0.0.1',port:'3000'};varclient = net.connect(opt,function(){? ? client.write('msg from client');// 可寫(xiě)});// 可讀client.on('data',function(data){// server: msg from client [msg from client]console.log('client: got reply from server [%s]', data);? ? client.end();});
客戶(hù)端代碼：
varnet =require('net');varopt = {host:'127.0.0.1',port:'3000'};varclient = net.connect(opt,function(){? ? client.write('msg from client');// 可寫(xiě)});// 可讀client.on('data',function(data){// lient: got reply from server [reply from server]console.log('client: got reply from server [%s]', data);? ? client.end();});
Transform Stream
Transform stream是Duplex stream的特例璧南，也就是說(shuō)，Transform stream也同時(shí)可讀可寫(xiě)师逸。跟Duplex stream的區(qū)別點(diǎn)在于司倚，Transform stream的輸出與輸入是存在相關(guān)性的。
常見(jiàn)的Transform stream包括zlib、crypto动知，這里舉個(gè)簡(jiǎn)單例子：文件的gzip壓縮皿伺。
varfs =require('fs');varzlib =require('zlib');vargzip = zlib.createGzip();varinFile = fs.createReadStream('./extra/fileForCompress.txt');varout = fs.createWriteStream('./extra/fileForCompress.txt.gz');inFile.pipe(gzip).pipe(out);
