Node.js 中的 Stream 模块使用详解-JavaScript中文网-JavaScript教程资源分享门户

在 Node.js 中，Stream 是一个非常重要的模块，它可以帮助我们高效地处理数据流。Stream 模块提供了一种抽象的数据流接口，可以将数据分成一系列小块，然后逐个处理这些小块，以减少内存占用和提高性能。本文将详细介绍 Node.js 中的 Stream 模块的使用方法，包括流的类型、流的操作、流的事件等。

流的类型

在 Node.js 中，有四种类型的流：可读流、可写流、双工流和转换流。

可读流

可读流用于从数据源中读取数据。它提供了一种流式读取数据的方式，可以逐个读取数据块，而不是一次性读取整个数据源。可读流可以是文件、网络套接字、管道、HTTP 请求等。

可写流

可写流用于向目标写入数据。它提供了一种流式写入数据的方式，可以逐个写入数据块，而不是一次性写入整个目标。可写流可以是文件、网络套接字、管道、HTTP 响应等。

双工流

双工流可以同时读取和写入数据。它提供了一种流式读写数据的方式。双工流可以是网络套接字、管道等。

转换流

转换流是一种特殊的双工流，它可以将数据从一个格式转换成另一个格式。转换流可以是压缩流、加密流等。

流的操作

在 Node.js 中，我们可以对流进行一些操作，以便更好地处理数据。

管道

管道是将可读流和可写流连接起来的一种方式。数据从可读流中读取，然后通过管道传输到可写流中。这种方式可以有效地减少内存占用和提高性能。

const fs = require('fs');

const readableStream = fs.createReadStream('input.txt');
const writableStream = fs.createWriteStream('output.txt');

readableStream.pipe(writableStream);

上面的代码中，我们使用 fs 模块创建了一个可读流和一个可写流，然后使用 pipe 方法将它们连接起来。数据从 input.txt 文件中读取，然后通过管道传输到 output.txt 文件中。

缓冲

流的操作中还有一个重要的概念，就是缓冲。缓冲是指流中的数据块，每个数据块都有一定的大小。在读取数据时，可以一次性读取一个或多个数据块，然后将它们缓存起来。在写入数据时，可以一次性写入一个或多个数据块，然后将它们缓存起来。缓冲可以减少 I/O 操作的次数，提高性能。

流的事件

在 Node.js 中，流还提供了一些事件，可以让我们更好地处理数据。

data 事件

当有数据块可读时，会触发 data 事件。在这个事件中，我们可以处理数据块。

const fs = require('fs');

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

readableStream.on('data', (chunk) => {
  console.log(`Received ${chunk.length} bytes of data.`);
});

上面的代码中，我们创建了一个可读流，并监听了 data 事件。当有数据块可读时，会触发 data 事件，并输出数据块的大小。

end 事件

当可读流结束时，会触发 end 事件。

const fs = require('fs');

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

readableStream.on('end', () => {
  console.log('Read stream ended.');
});

上面的代码中，我们创建了一个可读流，并监听了 end 事件。当可读流结束时，会触发 end 事件，并输出一条信息。

error 事件

当出现错误时，会触发 error 事件。

const fs = require('fs');

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

readableStream.on('error', (err) => {
  console.error(err);
});

上面的代码中，我们创建了一个可读流，并监听了 error 事件。当出现错误时，会触发 error 事件，并输出错误信息。

示例代码

下面是一个完整的示例代码，演示了如何使用流读取和写入文件。

// www.javascriptcn.com code example
const fs = require('fs');

const readableStream = fs.createReadStream('input.txt');
const writableStream = fs.createWriteStream('output.txt');

readableStream.on('data', (chunk) => {
  console.log(`Received ${chunk.length} bytes of data.`);
  writableStream.write(chunk);
});

readableStream.on('end', () => {
  console.log('Read stream ended.');
  writableStream.end();
});

readableStream.on('error', (err) => {
  console.error(err);
});

writableStream.on('finish', () => {
  console.log('Write stream finished.');
});

writableStream.on('error', (err) => {
  console.error(err);
});

上面的代码中，我们创建了一个可读流和一个可写流，并监听了它们的事件。当有数据块可读时，会触发 data 事件，并将数据块写入可写流中。当可读流结束时，会触发 end 事件，并关闭可写流。当可读流或可写流出现错误时，会触发 error 事件，并输出错误信息。当可写流完成写入时，会触发 finish 事件，并输出一条信息。

来源：JavaScript中文网，转载请注明来源 https://www.javascriptcn.com/post/67d5684aa941bf7134a14154

Node.js 中的 Stream 模块使用详解