突破传统束缚：可读可写流的奇妙世界【附demo源码】

前端

2023-10-26 21:13:13

初识流处理

流处理是一种基于流的数据传输机制，它允许在数据源和数据接收器之间建立一种持续的数据传输通道，从而实现数据的高效、连续传输。流处理的本质是异步处理，它不会等待数据全部传输完毕再进行处理，而是边传输边处理，大大提高了数据的处理效率。

可读可写流的登场

在Node.js中，可读流和可写流是流处理的两个重要组成部分。可读流用于读取数据，而可写流用于写入数据。它们之间的交互形成了一个完整的数据传输过程。

可读流

可读流是一种可以从外部读取数据的流，它提供了多种方法来读取数据，包括：

read()：读取指定长度的数据。
on('data', callback)：在接收到数据时触发回调函数。
on('end', callback)：在流结束时触发回调函数。

可写流

可写流是一种可以向外部写入数据的流，它提供了多种方法来写入数据，包括：

write(data)：写入数据。
end(data)：写入数据并结束流。
on('drain', callback)：在流可以继续写入数据时触发回调函数。

可读可写流的应用场景

可读可写流在实际应用中有着广泛的应用场景，以下是一些典型的例子：

文件处理：读取文件数据，写入文件数据。
网络通信：从网络读取数据，向网络写入数据。
数据转换：将数据从一种格式转换为另一种格式。
数据管道：将数据从一个流传输到另一个流。

可读可写流的实现

可读可写流的实现并不复杂，我们可以使用Node.js提供的内置模块来轻松实现。以下是一个简单的可读可写流的示例代码：

const {Readable, Writable} = require('stream');

// 创建可读流
const readableStream = new Readable({
  read() {
    // 读取数据并推送到流中
    this.push('Hello, world!');
    this.push(null); // 结束流
  }
});

// 创建可写流
const writableStream = new Writable({
  write(data, encoding, callback) {
    // 处理数据
    console.log(data.toString());

    // 告诉可写流继续写入数据
    callback();
  }
});

// 将可读流与可写流连接起来
readableStream.pipe(writableStream);