node.js是異步和事件驅(qū)動(dòng)的。 利用Node.js流通過有效處理較小塊中的數(shù)據(jù)來大大簡(jiǎn)化這些任務(wù)。讓我們深入研究溪流的世界，看看它們?nèi)绾魏?jiǎn)化I/O。

密鑰概念：

通過處理可管理的部分中的數(shù)據(jù)，
• node.js流（異步和事件驅(qū)動(dòng)的）優(yōu)化I/O。
>流被歸類為可讀，可寫的或雙工的（既可以閱讀又可寫的）。 可讀的流從源獲取數(shù)據(jù)；可寫的流將數(shù)據(jù)發(fā)送到目的地。
• 功能是無價(jià)的，可以促進(jìn)源和目的地之間無縫的數(shù)據(jù)傳輸，而無需手動(dòng)流量管理。 pipe()>
，
• 和Readable.pause()的方法提供對(duì)數(shù)據(jù)流的顆粒狀控制，增強(qiáng)了流功能。Readable.resume() readable.unpipe()

>流類似于Unix管道，從而使數(shù)據(jù)傳輸從源到目的地毫無疑問。 本質(zhì)上，流是具有專門方法的流。 實(shí)現(xiàn)的方法確定流是可讀，可寫的還是雙工的。 可讀的流提供數(shù)據(jù)輸入；可寫的流處理數(shù)據(jù)輸出。

>您可能已經(jīng)在node.js中遇到了流。 在HTTP服務(wù)器中，該請(qǐng)求是可讀的流，并且響應(yīng)是可寫的流。 EventEmitter模塊提供可讀和可寫的文件流功能。>

fs

>可讀的流從源讀取數(shù)據(jù)（文件，內(nèi)存緩沖區(qū)或其他流）。 在 s時(shí)，它們會(huì)觸發(fā)各種事件。我們利用這些事件與流相互作用。

EventEmitter最常見的方法是聆聽

事件會(huì)觸發(fā)，執(zhí)行回調(diào)。

>事件偵聽器時(shí)流動(dòng)。 然后將數(shù)據(jù)塊傳遞給回調(diào)。 事件的頻率由流實(shí)現(xiàn)確定（例如，HTTP請(qǐng)求可能會(huì)散發(fā)出每幾個(gè)kb的事件，而文件流可能每行發(fā)射）。 datadata事件向數(shù)據(jù)結(jié)束發(fā)出信號(hào)。

const fs = require('fs');
const readableStream = fs.createReadStream('file.txt');
let data = '';
readableStream.on('data', (chunk) => { data += chunk; });
readableStream.on('end', () => { console.log(data); });

，直到讀取所有數(shù)據(jù)：>

const fs = require('fs');
const readableStream = fs.createReadStream('file.txt');
let data = '';
readableStream.on('data', (chunk) => { data += chunk; });
readableStream.on('end', () => { console.log(data); });

read()從內(nèi)部緩沖區(qū)檢索數(shù)據(jù)。 當(dāng)沒有數(shù)據(jù)保留時(shí)，它將返回null。 readable事件指示數(shù)據(jù)可用性。

>設(shè)置編碼：

>對(duì)象。 對(duì)于字符串，使用Buffer：Readable.setEncoding()>

const fs = require('fs');
const readableStream = fs.createReadStream('file.txt');
let data = '';
let chunk;
readableStream.on('readable', () => {
  while ((chunk = readableStream.read()) !== null) {
    data += chunk;
  }
});
readableStream.on('end', () => { console.log(data); });

const fs = require('fs');
const readableStream = fs.createReadStream('file.txt');
let data = '';
readableStream.setEncoding('utf8');
readableStream.on('data', (chunk) => { data += chunk; });
readableStream.on('end', () => { console.log(data); });

const fs = require('fs');
const readableStream = fs.createReadStream('file1.txt');
const writableStream = fs.createWriteStream('file2.txt');
readableStream.pipe(writableStream);

const fs = require('fs');
const zlib = require('zlib');
fs.createReadStream('input.txt.gz')
  .pipe(zlib.createGunzip())
  .pipe(fs.createWriteStream('output.txt'));