Node.js Stream

Node.js Stream

Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境，它允许开发者使用 JavaScript 编写服务器端代码。Node.js 的一个核心特性是其对流（Stream）的处理能力。流是一种在 Node.js 中处理读/写文件、网络通信或任何端到端信息交换的方式。它们提供了一种高效的数据处理方式，特别是在处理大量数据时。

什么是流？

在计算机科学中，流是一个有序、可访问的序列，通常用于数据传输。在 Node.js 中，流是一种对象，它允许数据以小块的形式读取或写入，而不是一次性全部加载到内存中。这大大提高了应用程序处理大数据的效率和性能。

流的类型

Node.js 中有四种基本的流类型：

1. Readable: 可读流，用于从数据源读取数据。
2. Writable: 可写流，用于向目的地写入数据。
3. Duplex: 双工流，既可读又可写。
4. Transform: 转换流，是双工流的特殊类型，可以在数据写入和读取时修改或转换数据。

为什么使用流？

使用流的主要原因包括：

• 内存效率: 流允许你逐块处理数据，而不是一次性加载整个数据集，这样可以减少内存使用。
• 时间效率: 流可以立即开始处理数据，而不需要等待整个数据集准备好。
• 模块化: 流可以很容易地被组合和重用，允许开发者创建复杂的管道来处理数据。

如何使用流？

创建一个可读流

const fs = require('fs');
const readableStream = fs.createReadStream('input.txt', {
  encoding: 'utf8',
  highWaterMark: 64 * 1024 // 64KB
});

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

readableStream.on('end', () => {
  console.log('No more data');
});
1
2
3
4
5
6
7
8
9
10
11
12
13

创建一个可写流

const fs = require('fs');
const writableStream = fs.createWriteStream('output.txt');

writableStream.write('Hello, ');
writableStream.write('world!\n');
writableStream.end('Goodbye, world!\n');
1
2
3
4
5
6

管道流

管道是一种将数据从一个流传输到另一个流的机制。

readableStream.pipe(writableStream);
1

错误处理

流在发生错误时触发 'error' 事件。

readableStream.on('error', (err) => {
  console.error('Error:', err);
});
1
2
3

结论

流是 Node.js 中处理 I/O 操作的一种强大而高效的方式。它们允许开发者以块的形式处理数据，减少内存使用，提高应用程序的性能。通过理解和使用流，开发者可以构建更高效、更可扩展的 Node.js 应用程序。