Node.js pipe实现源码解析(node.js import)

编辑：rootadmin

推荐整理分享Node.js pipe实现源码解析(node.js import)，希望有所帮助，仅作参考，欢迎阅读内容。

文章相关热门搜索词:nodejs 开源项目,node.js import,nodejs换源,node.js import,node.js import,nodejs开源协议,nodejs pipe(),nodejs换源,内容如对您有帮助，希望把文章链接给更多的朋友！

从前面两篇文章，我们了解到。想要把 Readable 的数据写到 Writable，就必须先手动的将数据读入内存，然后写入 Writable。换句话说，每次传递数据时，都需要写如下的模板代码

为了方便使用，Node.js 提供了 pipe() 方法，让我们可以优雅的传递数据

现在，就让我们来看看它是如何实现的吧

pipe

首先需要先调用 Readable 的 pipe() 方法

执行 pipe() 函数时，首先将 Writable 记录到 state.pipes 中，然后绑定相关事件，最后如果 Readable 不是 flow 模式，就调用 resume() 将 Readable 改为 flow 模式

传递数据

Readable 从数据源获取到数据后，触发 data 事件，执行 ondata()

ondata() 相关代码：

在 ondata(chunk) 函数内，通过 dest.write(chunk) 将数据写入 Writable

此时，在 _write() 内部可能会调用 src.push(chunk) 或使其 unpipe，这会导致 awaitDrain 多次增加，不能清零，Readable 卡住

当不能再向 Writable 写入数据时，Readable 会进入 pause 模式，直到所有的 drain 事件触发

触发 drain 事件，执行 ondrain()

每个 drain 事件触发时，都会减少 awaitDrain，直到 awaitDrain 为 0。此时，调用 flow(src)，使 Readable 进入 flow 模式

到这里，整个数据传递循环已经建立，数据会顺着循环源源不断的流入 Writable，直到所有数据写入完成

unpipe

不管写入过程中是否出现错误，最后都会执行 unpipe()

Readable.prototype.unpipe() 函数会根据 state.pipes 属性和 dest 参数，选择执行策略。最后会触发 dest 的 unpipe 事件

unpipe 事件触发后，调用 onunpipe()，清理相关数据

End

在整个 pipe 的过程中，Readable 是主动方 ( 负责整个 pipe 过程：包括数据传递、unpipe 与异常处理 )，Writable 是被动方 ( 只需要触发 drain 事件 )

总结一下 pipe 的过程：

首先执行 readbable.pipe(writable)，将 readable 与 writable 对接上当 readable 中有数据时，readable.emit('data')，将数据写入 writable 如果 writable.write(chunk) 返回 false，则进入 pause 模式，等待 drain 事件触发 drain 事件全部触发后，再次进入 flow 模式，写入数据不管数据写入完成或发生中断，最后都会调用 unpipe() unpipe() 调用 Readable.prototype.unpipe()，触发 dest 的 unpipe 事件，清理相关数据

参考：

nodejs动态创建二维码的方法本文实例为大家分享了nodejs动态创建二维码的具体代码，供大家参考，具体内容如下!--弹出二维码--divclass="qrcode"divpid="saoma"扫描二维码/p/div/divjs代码：$.

关于在mongoose中填充外键的方法详解本文主要给大家介绍的是关于mongoose中填充外键的相关内容，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍：MongoDBMongoDB是典型的N

Mongoose实现虚拟字段查询的方法详解前言不知道大家知不知道，mongoose为数据模型提供了虚拟属性，借此可以更加一致地、方便地读写模型属性，类似于C#或Java中的访问器。我们知道虚拟属

标签: node.js import

本文链接地址:https://www.jiuchutong.com/biancheng/380929.html 转载请保留说明！

上一篇：理解nodejs的stream和pipe机制的原理和实现(nodejs dgram)

下一篇：nodejs动态创建二维码的方法(nodejs创建项目)