揭秘 Node.js 中的可读流，带你玩转数据读取

前端

2023-09-12 00:44:51

一、认识 Node.js 中的可读流

Node.js 中的可读流是一种数据流，用于从一个源头读取数据。它支持两种模式：流模式和暂停模式。流模式允许连续读取数据，而暂停模式则允许在需要时暂停读取数据。

可读流具有 data、end、error、close 和 readable 等事件，可以通过监听这些事件来处理读取到的数据。Node.js 中的可读流广泛应用于网络通信、文件读取和数据处理等领域。

二、Node.js 中的可读流的两种模式

在任何时刻，可读流都处于流模式或暂停模式。流模式允许连续读取数据，而暂停模式则允许在需要时暂停读取数据。

流模式的实现非常简单，只要调用可读流的 resume() 方法即可。暂停模式的实现也比较简单，只要调用可读流的 pause() 方法即可。

三、Node.js 中的可读流的事件

Node.js 中的可读流具有 data、end、error、close 和 readable 等事件，可以通过监听这些事件来处理读取到的数据。

data 事件：当可读流中有数据可读时触发。
end 事件：当可读流中的所有数据都被读取完毕时触发。
error 事件：当可读流中发生错误时触发。
close 事件：当可读流被关闭时触发。
readable 事件：当可读流中有数据可读时触发，但与 data 事件不同的是，readable 事件不会传输任何数据。

四、如何使用 Node.js 中的可读流

使用 Node.js 中的可读流非常简单，只需创建一个可读流对象，然后监听其事件即可。

以下是一个使用可读流读取文件内容的示例：

const fs = require('fs');

const readableStream = fs.createReadStream('file.txt');

readableStream.on('data', (data) => {
  console.log(data.toString());
});

readableStream.on('end', () => {
  console.log('All data has been read.');
});

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