Node中的streams流的具体使用

使用 Node.js 的 streams（流）是一种有效处理数据的方式。它们基于 EventEmitter API，因此可以轻松实现任意类型的自定义流和链式流水线。

1. 什么是流？

流是 Node.js 提供的处理流式数据的抽象接口。它们可以用于读取文件，处理 HTTP 请求，压缩和解压缩数据，以及许多其他用途。

流是可读的、可写的或可读可写的。数据能够按块（chunk）分开处理，而不必全部加载到内存中。在读取大型文件或请求时，这种方法会节省内存空间并避免阻塞进程。

2. 创建一个可读流

可以使用 fs 模块将文件读入内存，但会受到文件大小的限制。相反，可以使用可读流来执行此操作。

以下示例是打印一个文件的内容：

const fs = require('fs');

const inputStream = fs.createReadStream('test.txt', 'utf8');

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

inputStream.on('end', () => {
  console.log('读完了');
});

inputStream.on('error', error => {
  console.error(`发生错误: ${error}`);
});

首先，使用 fs 模块创建一个可读流。fs.createReadStream 接受两个参数：文件路径和编码方案。在本例中，我们使用 utf8。

我们发现，控制台中输出了文件的内容。我们定义了在数据（块）可用时应如何处理它的回调函数，该回调函数在 'data' 事件上触发。对于文件流，数据块默认为 64KB。该回调就是每当读取到数据块时将其打印到控制台。

在数据流读取完毕时（触发 'end' 事件），我们输出一条消息表明读取已完成。如果出现错误，则通过 'error' 事件来处理。

3. 创建一个可写流

通过可写流，可以将输出直接写入文件。

const fs = require('fs');

const outputStream = fs.createWriteStream('output.txt');

outputStream.write('第一行\n');
outputStream.write('第二行\n');

outputStream.end(() => {
  console.log('写完了');
});

我们使用 fs.createWriteStream 创建一个可写的文件流，并将其定向到 output.txt。

使用 outputStream.write 写入文件流时，我们打印“第一行”和“第二行”，并在最后调用 outputStream.end 来结束写入流并在完成时运行回调。

在这个例子中，'output.txt' 会被自动创建，如果不存在的话。如果已经存在，文件会被覆盖。

4. 使用管道（pipe）连接流

必须写出包装可读流和可写流的代码来写出所有的内容，但是这会很麻烦，尤其是当使用复杂的代码时。为了解决这个问题，Node.js 中提供了管道（pipe）方法来连接多个流。

以下是读取文件并将其压缩后写入另一个文件的示例：

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

const inputStream = fs.createReadStream('test.txt');
const gzipStream = zlib.createGzip();
const outputStream = fs.createWriteStream('test.txt.gz');

inputStream.pipe(gzipStream).pipe(outputStream);

我们首先创建三个流：可读流 inputStream，gzip 压缩流 gzipStream，和可写流 outputStream。

我们调用 inputStream.pipe(gzipStream).pipe(outputStream) 将这三个流连接到一起。这样，当 inputStream 从文件中读取数据时，该数据会被压缩，然后被写到 outputStream 中。

如果我们不使用管道，那么我们将需要手动编写回调函数，及其非常繁琐。使用管道，可以轻松地将多个流串联在一起，而无需编写太多代码。

总结

这是有关 Node.js 中的流的简单介绍。通过使用流，可以轻松地处理流式数据，并以最小的成本和最高的效率进行操作。如果您正在编写大型 Node.js 项目，学习使用流可能会显著提高您的代码效率。