Node.js Stream
Node.js 是一個基于 Chrome V8 引擎的 JavaScript 運行環境，它允許開發者使用 JavaScript 編寫服務器端代碼。Node.js 的一個核心特性是其對流（Stream）的處理能力。流是一種在 Node.js 中處理讀/寫文件、網絡通信或任何端到端信息交換的方式。它們提供了一種高效的數據處理方式，特別是在處理大量數據時。
什么是流？
在計算機科學中，流是一個有序、可訪問的序列，通常用于數據傳輸。在 Node.js 中，流是一種對象，它允許數據以小塊的形式讀取或寫入，而不是一次性全部加載到內存中。這大大提高了應用程序處理大數據的效率和性能。
流的類型
Node.js 中有四種基本的流類型：
- Readable: 可讀流，用于從數據源讀取數據。
- Writable: 可寫流，用于向目的地寫入數據。
- Duplex: 雙工流，既可讀又可寫。
- Transform: 轉換流，是雙工流的特殊類型，可以在數據寫入和讀取時修改或轉換數據。
為什么使用流？
使用流的主要原因包括：
- 內存效率: 流允許你逐塊處理數據，而不是一次性加載整個數據集，這樣可以減少內存使用。
- 時間效率: 流可以立即開始處理數據，而不需要等待整個數據集準備好。
- 模塊化: 流可以很容易地被組合和重用，允許開發者創建復雜的管道來處理數據。
如何使用流？
創建一個可讀流
const fs = require('fs');
const readableStream = fs.createReadStream('input.txt', {encoding: 'utf8',highWaterMark: 64 * 1024 // 64KB
});readableStream.on('data', (chunk) => {console.log(chunk);
});readableStream.on('end', () => {console.log('No more data');
});
創建一個可寫流
const fs = require('fs');
const writableStream = fs.createWriteStream('output.txt');writableStream.write('Hello, ');
writableStream.write('world!\n');
writableStream.end('Goodbye, world!\n');
管道流
管道是一種將數據從一個流傳輸到另一個流的機制。
readableStream.pipe(writableStream);
錯誤處理
流在發生錯誤時觸發 'error' 事件。
readableStream.on('error', (err) => {console.error('Error:', err);
});
結論
流是 Node.js 中處理 I/O 操作的一種強大而高效的方式。它們允許開發者以塊的形式處理數據，減少內存使用，提高應用程序的性能。通過理解和使用流，開發者可以構建更高效、更可擴展的 Node.js 應用程序。
)
