如何实现并使用Node.js中可读流和可写流的流式数据处理？

本文共计2876个文字，预计阅读时间需要12分钟。

Node.js 中的 Stream 模块是处理流式数据的抽象接口。它允许程序以流的形式读写数据，而不是一次性加载整个数据集。以下是对 Stream 模块中可读流和可写流的简单介绍：

可读流可读流（Readable Streams）允许数据被逐块读取。使用可读流，你可以按需读取数据，而不是将整个数据集一次性加载到内存中。以下是一些常用的方法：

- `read()`: 读取数据。- `pipe()`: 将可读流连接到另一个可写流。- `on('data', callback)`: 当有数据可读时触发。

可写流可写流（Writable Streams）允许数据被逐块写入。使用可写流，你可以将数据分批次写入目标，而不是一次性写入整个数据集。以下是一些常用的方法：

- `write(chunk, encoding, callback)`: 写入数据。- `end()`: 结束数据流。

实例以下是一个简单的例子，演示了如何创建一个可读流并逐行读取数据：

javascriptconst { Readable }=require('stream');

const readStream=Readable.from(['Hello\n', 'World\n']);

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

readStream.on('end', ()=> { console.log('Stream ended');});

这个例子中，`Readable.from` 创建了一个可读流，它包含两行文本。