Node.js 流

Node.js 中的流（stream）是处理输入和输出的强大抽象概念。它们可以用于读取和写入文件、网络通信和各种其他 I/O 操作。流让程序能够逐块处理数据，而无需一次性加载整个数据块到内存中。

什么是流

流是一种数据处理方式，即连续的数据序列。数据从源（例如文件、网络或其他程序）流向目标（例如文件、网络或控制台）。

在 Node.js 中，有四种基本的流类型：

1. 可读流（Readable）
2. 可写流（Writable）
3. 双工流（Duplex）
4. 转换流（Transform）

可读流用于从源读取数据，可写流用于向目标写入数据，双工流既可以读取数据也可以写入数据，转换流兼具了双工流和可变换数据的功能。

使用流的好处

使用流的主要好处之一是内存效率。由于数据是以块的方式处理，而不是一次性加载到内存中，所以无论数据量有多大，流都可以处理。

另一个好处是它们提供了更好的响应性能。在数据到达时立即处理数据，而不是等待所有数据都加载完毕。这对于处理大型文件或网络传输非常重要。

流还提供了可连接性，这意味着它们可以被链接在一起以创建复杂的数据流管道。这样可以实现更高级的数据处理和转换，使得代码更可读、可维护。

示例代码

下面是使用 Node.js 流的示例代码：

const fs = require('fs');
const zlib = require('zlib');

// 创建可读流
const readableStream = fs.createReadStream('input.txt');

// 创建可写流
const writableStream = fs.createWriteStream('output.txt');

// 管道操作：将可读流的数据写入可写流
readableStream.pipe(writableStream);

// 创建转换流，同时压缩文件
const gzip = zlib.createGzip();

// 创建压缩文件的可读流
const compressedReadableStream = fs.createReadStream('output.txt');

// 创建压缩文件的可写流
const compressedWritableStream = fs.createWriteStream('output.txt.gz');

// 管道操作：将可读流的数据通过转换流写入可写流
compressedReadableStream.pipe(gzip).pipe(compressedWritableStream);

在上述示例中，我们首先创建了一个可读流来读取文件 input.txt，然后创建一个可写流来写入文件 output.txt。通过管道操作 pipe，可以将可读流的数据直接写入可写流，以实现数据的传输。

接着，我们使用 zlib 模块创建了一个转换流 gzip，并创建了压缩文件的可读流和可写流。通过多重管道操作，将可读流的数据通过转换流压缩后再写入可写流 output.txt.gz。

以上就是使用 Node.js 流的简单示例，流的强大功能可以帮助程序员更高效地处理数据，并实现各种复杂的数据处理任务。

参考文档：Node.js Stream API 文档