Node.js 中的流 - 教程 - 第 7 部分

了解 Node.js 中的流

Node.js 中的流是有效處理 I/O 操作的強大方法，尤其是在處理大量資料時。流允許我們分塊處理數據，而不是一次性讀取和寫入數據，從而提高效能並減少記憶體消耗。

流類型

Node.js 提供四種類型的流：

Stream Type	Description	Example
Readable Streams	Used for reading data	Reading from a file
Writable Streams	Used for writing data	Writing to a file
Duplex Streams	Both readable and writable	Sockets
Transform Streams	A type of duplex stream where data can be modified as it is read or written	Compression

流類型

描述

範例 標題>

可讀流

用於讀取資料 從文件中讀取

可寫流

用於寫入資料 寫入檔案 雙工流 可讀可寫 套接字 轉換流

一種雙工流，可以在讀取或寫入資料時修改資料 壓縮 表> 流如何運作

流對事件進行操作，這表示它們依賴偵聽器在資料可用、準備寫入或發生錯誤時做出回應。常見事件包括：

data：當有資料塊可用時發出。

end

：當沒有更多資料可消耗時發出。

const fs = require('fs');

const readableStream = fs.createReadStream('example.txt', { encoding: 'utf8' });

readableStream.on('data', (chunk) => {
  console.log('Received chunk:', chunk);
});

readableStream.on('end', () => {
  console.log('No more data.');
});

readableStream.on('error', (err) => {
  console.error('Error:', err);
});

error：如果在流處理過程中發生任何錯誤，則發出。

可讀流範例

const fs = require('fs');

const writableStream = fs.createWriteStream('output.txt');

writableStream.write('Hello, Node.js streams!\n');
writableStream.end(); // Close the stream

writableStream.on('finish', () => {
  console.log('Finished writing.');
});

writableStream.on('error', (err) => {
  console.error('Error:', err);
});

讓我們來看一個使用可讀流讀取檔案的範例：

可寫入流範例

以下是使用可寫入流寫入檔案的方法：

為什麼要使用流？

readableStream.pipe(writableStream);

流有助於有效地處理大量資料。例如，在處理文件時，流可以讓您避免將整個文件載入到記憶體中。這在處理媒體檔案、大數據集或來自 HTTP 請求的資料時特別有用。

---

最後的提示

始終使用錯誤事件處理流錯誤以避免崩潰。 使用管道輕鬆地將可讀流連接到可寫流。 串流非常適合處理 I/O 密集型應用程序，並且在處理大型資料集時可以更輕鬆地管理記憶體。 感謝您的閱讀，祝您編碼愉快！ ？

以上是Node.js 中的流 - 教程 - 第 7 部分的詳細內容。更多資訊請關注PHP中文網其他相關文章！