说说node中的可读流和可写流的区别

开篇

走进Node.js的世界，不得不提的就是流。当我们说起流，总会联想到长沙网络推广分享的精彩内容。今天，让我们一起跟随长沙网络推广的脚步，深入Node中的可读流和可写流，看看它们究竟有何魅力。

一、流的前世今生

在Node.js的世界里，流扮演着重要的角色。它们分为缓冲模式和对象模式，前者处理buffer或字符串，后者处理JS对象。在这之中，我们主要关注的是可读流和可写流。它们作为流的基础类型，为开发者提供了强大的数据流处理能力。

二、说说可读流

可读流犹如一个源源不断的数据源泉。它有两种模式：流动模式和暂停模式。在流动模式下，数据自动读取并尽快通过事件提供给应用。而在暂停模式下，我们需要显式调用stream.read()方法来读取数据片段。两种模式之间可以随时切换，我们可以通过监听可读流的事件来灵活操作它。

从流动模式切换到暂停模式的API包括：在不存在管道目标时调用stream.pause()方法，或者存在管道目标时取消'data'事件监听。而从暂停模式切换到流动模式的API则包括：监听“data”事件，调用stream.resume()方法，或者调用stream.pipe()方法将数据发送到可写流。可读流涉及的事件包括'data'、'readable'、'error'、'close'和'end'。

三、聊聊可写流

相对于可读流，可写流显得更加简洁。我们依然可以通过监听事件来操作它。涉及的事件包括'close'、'drain'、'error'、'finish'、'pipe'和'unpipe'。举个例子，我们要读取一个文件并写入到另一个文件，这就是一个典型的流应用场景。在这个过程中，我们可以根据需要对数据进行精确控制。比如选择流动模式进行高效的数据处理，或者选择暂停模式进行更精细的控制。官方建议我们尽量使用pipe方法来进行操作。无论选择哪种方式读取文件中的数据，我们都可以创建一个可写流并通过调用可写流的write方法来写入数据。写入数据时，如果当前写入还在进行而你再次调用write方法，Node会将你要写入的数据缓存在缓存区中等待处理。write方法还有一个布尔型的返回值来表示是否可以继续写入数据。这就是关于可读流和可写流的简单介绍。在这个神奇的流的世界里还有许多值得我们的奥秘等待着我们去发现。让我们继续深入Node.js的流世界，发现更多精彩吧！在数据处理的海洋中，流（Streams）是航行的重要工具。当我们谈论文件读写流时，我们实际上是在讨论如何在内存和硬盘之间高效转移大量数据。当我们深入这个领域时，需要密切关注缓存区的情况，避免内存消耗过多。接下来，让我们一起跟随代码的脚步，深入理解何时应该停止读取数据。

想象一下，我们有一个装满数据的河流——可读流，它源源不断地向我们输送数据。这些数据可能是从一个大文件中读取的。我们还有一个接收数据的河流——可写流，它将数据写入另一个文件。这个过程就像在两个容器之间转移水，而缓存区就是临时存储水的容器。当缓存区满了，我们需要暂停读取数据流以防止内存过载。那么，何时会触发这个“满”的信号呢？当缓存区的大小超过一个预定的阈值时。这个阈值可以在创建可读流时设置，被称为高水位线（highWaterMark）。默认值是16k，但可以根据需要进行调整。

现在让我们看看对应的代码实现：

引入文件系统模块：

```javascript

let fs = require('fs');

```

接着创建可读和可写流：

```javascript

let rs = fs.createReadStream('./1.txt'); // 创建读取文件的可读流

let ws = fs.createWriteStream('./2.txt'); // 创建写入文件的可写流

```

我们关注的关键点是当数据从可读流流向可写流时，如何控制数据流。这涉及到监听'data'事件：

```javascript

rs.on('data', function (data) {

// 向可写流写入数据并检查返回值

let flag = ws.write(data);

if (!flag) {

// 如果可写流返回false，表示缓存区已满，我们应该暂停读取流以避免消耗过多内存

rs.pause(); // 暂停读取流

}

});

```

当缓存区被清空，也就是所有数据都被成功写入目标文件后，会触发可写流的'drain'事件。这时我们可以继续写入数据：

```javascript

ws.on('drain', function () {

// 缓存区清空，重新开启流动模式以便继续写入数据

rs.resume(); // 恢复读取流的读取操作

});

```

我们还需要处理可读流的'readable'事件，它告诉我们何时有数据可供读取：

```javascript

rs.on('readable', function() {

// 当可读流中有数据可读时执行的操作（这里使用递归调用read函数）

read(); // 注意这里的read函数是一个递归调用函数，当ws.write返回true时继续调用自身。确保每次处理完一批数据后重新检查可写流的写入状态。

});

```

请注意这段代码使用了递归调用read函数来处理可读流中的数据，确保只有在可写流准备好接收更多数据时才会继续读取数据。这是一个简化的处理方式，实际使用时可能需要更复杂的逻辑来处理各种边界情况。同时请注意递归调用的限制以避免栈溢出错误。在实际应用中还需要处理错误事件等其它事件以确保程序的健壮性。代码末尾部分对可读和可写流的用法进行了总结并鼓励大家提供反馈和指正不准确的地方。整体而言，文章和代码展示了如何在Node.js中使用文件系统模块创建和管理数据流的过程，以高效地处理文件读写操作。这种基于流的编程方式对于处理大型文件非常有效且重要。希望这些内容对大家的学习有所帮助并鼓励大家多多支持狼蚁SEO这个平台和作者的努力工作。最后请允许我用以下文字作为结尾：狼蚁虽小却富有力量，知识如金需要分享与积累。让我们携手前行在知识的海洋同成长与进步！