Node.js的流（Stream）：革新异步编程体验

2023-11-30 08:15:07

Node.js流（Stream）：革新异步编程体验

在Node.js的世界里，流（Stream）是一种处理流式数据的机制，它能够持续不断地将数据从一个源头传递到另一个目的地。流非常适合处理大量数据，因为它们可以避免将所有数据都加载到内存中，从而节省内存空间。此外，流还支持异步操作，因此不会阻塞应用程序。

流的分类

Node.js流分为可读流（Readable Stream）、可写流（Writable Stream）和双工流（Duplex Stream）三种类型。

可读流 ：顾名思义，可读流允许您从流中读取数据。您可以使用流的read()方法来读取数据，该方法会返回一个包含数据的Buffer对象。
可写流 ：可写流允许您将数据写入流中。您可以使用流的write()方法来写入数据，该方法接受一个Buffer对象作为参数。
双工流 ：双工流既可以读又可以写。您可以使用双工流的read()和write()方法来分别读取和写入数据。

流的管道

流可以连接在一起形成管道，这样数据就可以从一个流流向另一个流。您可以使用流的pipe()方法来连接两个流。例如，以下代码将一个可读流连接到一个可写流：

const readableStream = fs.createReadStream('file.txt');
const writableStream = fs.createWriteStream('output.txt');
readableStream.pipe(writableStream);

当您调用pipe()方法时，可读流会开始将数据流向可写流。可写流会将接收到的数据写入到文件中。

转换流

转换流是特殊类型的流，它可以将一种格式的数据转换为另一种格式。例如，您可以使用转换流将JSON数据转换为CSV数据。您可以使用流的Transform()构造函数来创建转换流。例如，以下代码创建一个将JSON数据转换为CSV数据的转换流：

const transformStream = new Transform({
  objectMode: true,
  transform: function(chunk, encoding, callback) {
    const data = JSON.parse(chunk.toString());
    const csvData = `${data.name},${data.age},${data.city}`;
    callback(null, csvData);
  }
});