Node.js Stream 可读.unpipe() 方法

Node.js 作为一种流行的服务器端开发技术，提供了一系列流（stream）API。其中，可读流（readable stream）和可写流（writable stream）是最常用的类型。可读流用于从文件、网络或另一个流中读取数据，而可写流用于将数据写入到文件、网络或另一个流中。在某些情况下，我们需要中断两个流之间的数据流动，这就需要使用 Node.js Stream 可读.unpipe() 方法。

什么是 Node.js Stream 可读.unpipe() 方法？

Node.js Stream 可读.unpipe() 方法用于中断可读流与可写流之间的数据流通。当一个可读流通过管道（pipe）方法连接到一个可写流时，数据将自动从可读流流向可写流，直到该过程被取消。

使用 Node.js Stream 可读.unpipe() 方法可以取消已经建立的管道，并阻止继续流动数据。这样，我们就可以在需要时中断流，以及控制数据的流动。

使用 Node.js Stream 可读.unpipe() 方法

Node.js Stream 可读.unpipe() 方法有两种使用方式：未指定参数和指定参数。

• 未指定参数

当 Node.js Stream 可读.unpipe() 方法未指定参数时，默认将可读流与已经连接的所有可写流之间的管道取消。下面的代码片段演示了如何使用未指定参数的 Node.js Stream 可读.unpipe() 方法：

const fs = require('fs');
const stream = fs.createReadStream('./input.txt');
const writer1 = fs.createWriteStream('./output1.txt');
const writer2 = fs.createWriteStream('./output2.txt');
const writer3 = fs.createWriteStream('./output3.txt');

stream.pipe(writer1);
stream.pipe(writer2);
stream.pipe(writer3);

setTimeout(() => {
  stream.unpipe();
}, 2000);

在这个示例中，我们创建了一个可读流 stream，并将其通过管道连接到三个可写流 writer1、writer2、writer3 中。在 2s 后，我们调用 Node.js Stream 可读.unpipe() 方法，将 stream 与所有可写流之间的管道取消。这个方法未指定参数，因此默认将已经连接的所有可写流的管道都取消。

• 指定参数

当 Node.js Stream 可读.unpipe() 方法指定参数时，仅取消指定的可写流与可读流之间的管道。下面的代码片段演示了如何使用指定参数的 Node.js Stream 可读.unpipe() 方法：

const fs = require('fs');
const stream = fs.createReadStream('./input.txt');
const writer1 = fs.createWriteStream('./output1.txt');
const writer2 = fs.createWriteStream('./output2.txt');
const writer3 = fs.createWriteStream('./output3.txt');

stream.pipe(writer1);
stream.pipe(writer2);
stream.pipe(writer3);

setTimeout(() => {
  stream.unpipe(writer1);
}, 2000);

在这个示例中，我们创建了一个可读流 stream，并将其通过管道连接到三个可写流 writer1、writer2、writer3 中。在 2s 后，我们调用指定参数的 Node.js Stream 可读.unpipe() 方法，只取消了 stream 与 writer1 之间的管道。这个方法的参数是指定要取消管道的可写流。