浅谈Node.js：理解stream

什么是stream

stream（流）在 Node.js 中是处理流式数据的抽象接口，stream 基于事件机制工作，数据在写入和读取时以块（chunk）或流（flow）的方式进行传递。

stream 的类型

在 Node.js 中，stream 可以分为四种类型：

• Readable（可读流）：用于从数据源中读取数据。比如文件读取和网络请求等。
• Writable（可写流）：用于将数据写入目标位置。比如文件写入和网络请求等。
• Duplex（双工流）：同时实现了可读流和可写流。
• Transform（转换流）：是一种特殊的双工流，可以将可读流通过某种方式转换为可写流输出。比如压缩流和加密流等。

stream 的优势

stream 相比传统的处理方式，有以下几个优势：

• 低内存占用：stream 的数据不需要一次性全部读入内存中，而是以块或流的形式进行读写，降低了内存的占用。
• 高效性：stream 可以在数据传输的各个环节进行优化，比如压缩、加密、分片等操作，使得数据传输更加高效。
• 链式处理：stream 可以被链式处理，保证了代码的清晰可读性。

如何使用 stream

使用 stream 的一般步骤如下：

1. 创建 stream 对象
2. 通过事件监听方式处理数据流
3. 调用 stream 的方法进行数据传输

示例

读取文件流并输出

const fs = require('fs');

const rs = fs.createReadStream('./test.txt');

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

rs.on('end', () => {
  console.log('文件读取完成');
});

以上代码中，通过 fs 模块创建了一个可读流 rs，通过调用 rs.on() 方法，绑定了 'data' 和 'end' 事件的处理函数。当可读流 rs 从文件中读取到数据时，就会触发 'data' 事件，事件处理函数中的 chunk 就是读取到的数据块，当所有数据读取完成时，会触发 'end' 事件，事件处理函数中提示文件读取完成。

写入数据流到文件

const fs = require('fs');

const ws = fs.createWriteStream('./test.txt');

ws.write('Hello, Node.js!', 'utf-8');

ws.end();

ws.on('finish', () => {
  console.log('文件写入完成');
});

以上代码中，通过 fs 模块创建了一个可写流 ws，通过调用 ws.write() 方法，将 'Hello, Node.js!' 写入到文件中，调用 ws.end() 方法，表示输入完成，当所有数据输出完成时，会触发 'finish' 事件，事件处理函数中提示文件写入完成。

总结

stream 是 Node.js 提供的一种高效的数据处理方式，可以大大优化数据传输的效率和内存占用，同时也可以链式处理，使得代码更加清晰易读。在日常开发中，可以根据实际情况选择使用 stream 进行数据处理。