在 Node.js 中，流（Stream）是用于处理数据的抽象接口，可以在读取和写入数据时以逐块（chunk）的方式进行操作。流可以分为可读流和可写流两种类型。

可读流（Readable Stream） 用于从数据源（比如文件、网络请求、标准输入等）读取 数据，可以以可控的方式一次读取一小块数据，而不是一次性读取整个文件或数据流。这样可以有效地节省内存，特别适用于处理大型数据。

可写流（Writable Stream） 用于将数据 写入 目标位置（比如文件、网络响应、标准输出等），也是逐块写入的方式，可以分多次写入数据。

通过使用流，可以在数据处理过程中进行实时读取、实时写入，不需要等到准备好整个数据。

管道（Pipe） 是一种 连接可读流和可写流 的机制。通过创建一个管道，可以将数据从一个可读流传输到一个可写流，从而实现数据的传输和转换。在管道中，数据会以流式的方式通过数据管道，直到全部数据被传输完毕。

管道可以通过pipe()方法来建立，将可读流作为参数传递给目标可写流，从而将数据从源流传输到目标流。

下面是一个使用管道的例子：

const fs = require("fs");

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

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

// 将可读流的数据通过管道传输到可写流
readableStream.pipe(writableStream);

在上面的例子中，我们通过createReadStream和createWriteStream分别创建了一个可读流readableStream和一个可写流writableStream。然后，我们通过pipe()方法将可读流的数据传输到可写流中，实现了数据的复制和传输。

通过使用流和管道，我们可以实现高效的数据处理和传输，特别适用于处理大型文件或网络请求。

更新日志

2025/8/24 08:17

查看所有更新日志

• e7112-1于 2025/8/24