node.js中 stream使用教程

下面是“node.js中 stream使用教程”的完整攻略。

什么是Stream

Stream（流）是Node.js中处理流式数据的抽象接口。Stream 的各种实现在 Node.js 中广泛使用，它们提供了构建实时数据处理系统的基础。常见的 Stream 类型包括：

• Readable: 可读流
• Writable: 可写流
• Duplex: 双工流，即可读可写流
• Transform: 转换流，双工流中数据的修改

Stream的特点

Stream 有以下特点：

1. 内存效率高
   Stream 一次只处理一小块数据，避免内存占用过高。因此，即使在处理大量数据时，Stream 也可以保持良好的内存效率。

2. 时间效率高
   Stream 处理数据的速度远高于常规 I/O 操作，可以处理每秒数百 MB 的数据。

3. 数据处理过程灵活
   可以通过连接多个 Stream 形成管道，更灵活地处理数据。这可以有效地提高代码的可读性和可维护性。

Stream的使用

在 Node.js 中，Stream 是通过使用标准库提供的 Readable 和 Writable 类实现的。使用 Stream 可以避免一次性将所有数据加载到内存中，并可以实现数据按块处理，同时可以使用流事件机制来处理数据。

可读流

可读流（Readable Stream）表示数据流的输入端，可以连续发出数据块，最终将数据传递到可写流或转换流。

通过 fs.createReadStream(path) 创建可读流对象，并使用 stream.on(eventName, callback) 方法注册事件处理程序对可读流进行监听。

以下代码示例演示了如何从文件中读取数据并将其打印到控制台：

const fs = require('fs');
const rs = fs.createReadStream('/path/to/file');

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

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

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

可写流

可写流（Writable Stream）表示数据流的输出端，可以接收数据块并将其写入目标位置。

通过 fs.createWriteStream(path) 创建可写流对象，并使用 stream.on(eventName, callback) 方法注册事件监听器对可写流进行监听。

以下示例演示了如何将数据写入文件：

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

ws.write('Hello World!');
ws.end();

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

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

结束语

以上是“node.js中 Stream 使用教程”的完整攻略。Stream 是 Node.js 中一个非常强大的概念，可以使您更有效地处理数据和提高代码可读性。