node.js是異步和事件驅動的。 利用Node.js流通過有效處理較小塊中的數(shù)據(jù)來大大簡化這些任務。讓我們深入研究溪流的世界，看看它們如何簡化I/O。

密鑰概念：

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

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

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

fs

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

EventEmitter最常見的方法是聆聽

事件會觸發(fā)，執(zhí)行回調。

>事件偵聽器時流動。 然後將數(shù)據(jù)塊傳遞給回調。 事件的頻率由流實現(xiàn)確定（例如，HTTP請求可能會散發(fā)出每幾個kb的事件，而文件流可能每行發(fā)射）。 datadata事件向數(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); });

，直到讀取所有數(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()從內部緩衝區(qū)檢索數(shù)據(jù)。 當沒有數(shù)據(jù)保留時，它將返回null。 readable事件指示數(shù)據(jù)可用性。

>設置編碼：

>對象。 對於字符串，使用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'));