Node.js 流掌握流畅与暂停，揭开推拉模式的神秘面纱

2023-09-11 14:32:11

前言

在 Node.js 中，流（stream）是一种强大的工具，它允许我们处理连续不断的数据流。可读流（Readable Stream）是一种特殊的流，它可以让我们从数据源中读取数据。在系列一中，我们已经学习了可读流的基本使用。在系列二中，我们将深入讲解可读流的两种模式：流动模式（flowing）和暂停模式（paused）。

流动模式与暂停模式

流动模式和暂停模式，对应的是推模型（push mode）和拉模型（pull mode）。在流动模式下，数据源会主动将数据推送给可读流，而可读流会不断地读取这些数据并将其传递给下游。这种模式适合于数据源产生数据速度很快的情况，因为可读流可以快速地处理这些数据，而不会造成数据的堆积。

在暂停模式下，可读流会主动向数据源请求数据。只有当可读流需要更多数据时，数据源才会将数据推送给可读流。这种模式适合于数据源产生数据速度较慢的情况，因为可读流可以控制数据流速，避免数据的堆积。

如何控制流的模式

我们可以通过调用可读流的 pause() 方法和 resume() 方法来控制流的模式。调用 pause() 方法会将流置于暂停模式，而调用 resume() 方法会将流置于流动模式。

const readableStream = new ReadableStream();

// 将流置于暂停模式
readableStream.pause();

// 将流置于流动模式
readableStream.resume();

何时使用流动模式或暂停模式

在实际应用中，我们可以根据具体情况来选择使用流动模式还是暂停模式。一般来说，如果数据源产生数据速度很快，并且下游可以快速地处理这些数据，那么可以使用流动模式。如果数据源产生数据速度较慢，或者下游处理数据的速度较慢，那么可以使用暂停模式。

举个例子

我们来看一个具体的例子。假设我们有一个文件读取流，它可以从一个文件中读取数据。如果我们想将这个文件的内容输出到控制台，那么我们可以使用流动模式。因为控制台可以快速地处理数据，所以不会造成数据的堆积。

const fs = require('fs');

const readableStream = fs.createReadStream('file.txt');

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

如果我们想将这个文件的内容存储到另一个文件中，那么我们可以使用暂停模式。因为写入文件的速度通常比读取文件的速度慢，所以使用暂停模式可以避免数据的堆积。

const fs = require('fs');

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

readableStream.on('data', (chunk) => {
  // 将数据暂停
  readableStream.pause();

  // 将数据写入文件
  writableStream.write(chunk, () => {
    // 继续读取数据
    readableStream.resume();
  });
});