Node.js中的流（Stream）介绍

Node.js中的流（Stream）介绍

在 Node.js 中，Stream 是一种处理流式数据的接口。Stream 的本质是数据读写的一种抽象，它们能够以类似将大型数据块分解成小块的方式处理数据。这种数据处理方式允许我们逐块处理数据，而无需等待整个数据文件从磁盘中读取完毕。这在处理大型文件或网络传输中非常有用。

可读流（Readable Stream）

可读流是指可以从可读流对象中读取数据的流。在 Node.js 中，我们可以使用 fs.createReadStream() 方法来创建可读流。以下是一个读取本地文件中的数据的示例代码：

const fs = require('fs');

const readStream = fs.createReadStream('example.txt');

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

readStream.on('end', () => {
  console.log('读取完成');
});

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

在这个示例中，我们使用 fs.createReadStream() 方法创建了一个可读流对象，并将其赋值给变量 readStream。然后我们为 readStream 注册了三个事件监听器：

• data 事件：当从文件中读取数据时，该事件会被触发，然后我们将读取的数据输出到命令行；
• end 事件：当读取完成时，该事件会被触发，我们在该事件处理程序中输出读取完成的提示；
• error 事件：如果在读取数据时发生了错误，该事件会被触发，我们在该事件处理程序中输出错误信息。

可写流（Writable Stream）

可写流是指可以将数据写入可写流对象的流。在 Node.js 中，我们可以使用 fs.createWriteStream() 方法来创建可写流。以下是一个将数据写入本地文件的示例代码：

const fs = require('fs');

const writeStream = fs.createWriteStream('example.txt');

writeStream.write('hello ');
writeStream.write('world');
writeStream.end();

writeStream.on('finish', () => {
  console.log('数据写入完成');
});

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

在这个示例中，我们使用 fs.createWriteStream() 方法创建了一个可写流对象，并将其赋值给变量 writeStream。我们使用 writeStream.write() 方法将数据写入文件，并在最后调用 writeStream.end() 方法结束写入操作。然后我们为 writeStream 注册了两个事件监听器：

• finish 事件：当写入完成时，该事件会被触发，我们在该事件处理程序中输出写入完成的提示；
• error 事件：如果在写入数据时发生了错误，该事件会被触发，我们在该事件处理程序中输出错误信息。

Transform Stream

Transform Stream 是指可以将输入的数据进行转换后输出的流，可以理解为是可读流和可写流的结合体。在 Node.js 中，我们可以使用 stream.Transform 类自定义 Transform Stream。以下是一个将输入的英文字符串转换为大写字母后输出的示例代码：

const { Transform } = require('stream');

class UpperCaseTransform extends Transform {
  _transform(chunk, encoding, callback) {
    this.push(chunk.toString().toUpperCase());
    callback();
  }
}

const upperCaseTransform = new UpperCaseTransform();

process.stdin.pipe(upperCaseTransform).pipe(process.stdout);

在这个示例中，我们自定义了一个 UpperCaseTransform 类，继承自 stream.Transform 类，并实现了 _transform() 方法用于将输入的英文字符串转换为大写字母后输出。然后我们创建了一个 upperCaseTransform 实例，并通过管道连接了标准输入流、upperCaseTransform 实例和标准输出流，实现输入的英文字符串被转换为大写字母输出的功能。

小结

本文介绍了 Node.js 中的流（Stream）的概念和基本使用方法，包括可读流（Readable Stream）、可写流（Writable Stream）和 Transform Stream。通过使用流，我们可以有效地处理大型数据文件或网络传输中的数据。