位置: 编程技术 - 正文

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 卡住

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

当不能再向 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创建项目)

  • 一般纳税人开劳务发票几个点
  • 建筑垃圾清运税率多少
  • 受托加工开票如何选名称
  • 超过规定标准的扣除项目金额怎么算
  • 代收的电费计入什么费用
  • 不动产官网查询
  • 咨询服务合同印花税税目
  • 救护车能随便买吗
  • 出口货物免税的税种包括
  • 银行存款一直没动会怎样
  • 农业合作社预付款怎么算
  • 商品买一送一是打五折吗
  • 购进商品返点的钱用于抵扣货款怎么入账?
  • 公司收到股东的钱现金流量表怎么填
  • 外籍员工缴纳商业保险
  • 机动车发票抵扣联有什么用
  • 固定基金会计分录怎么处理
  • 税务局退的教育费附加怎么做账
  • 外贸企业增值税表二填写流程
  • 工效挂钩企业工资税前扣除有何规定?
  • 测试费怎么入账
  • 公司组织的团建受伤算工伤吗
  • linux grub
  • 个体户年报如何公示
  • 对于接受捐赠的资产价值,应计入当期损益
  • bios详细解释及作用
  • 应收账款怎么做分录
  • mac怎么删除应用程序中没有的软件
  • 收购农产品进项税抵扣税率是多少
  • 专用发票怎样申报
  • 以银行存款交纳欠缴税金会计分录
  • 超分模型
  • 固定资产售卖的账务处理
  • 双峰骆驼什么意思
  • php 序列化和json性能
  • 银行汇票的记载事项有哪些
  • vue清空input file的值
  • 无形资产的处置方式
  • 【深度学习】AI一键换天
  • 增资扩股税务处罚标准
  • 专票开户行少写一个字
  • 公司注销税款太多
  • 去年发生了什么
  • 长期待摊费用的最新账务处理
  • sqlserver存储过程写法
  • 主营业务收入净额在哪个报表里面
  • 预收账款确认的条件
  • 记账凭证核算形式
  • 工程异地施工缴什么税
  • 疫情防控免税政策
  • 劳务发票税额
  • 个人原因指什么
  • 进项税额已抵扣又红字冲红税务系统自动冲回吗
  • 税务局退以前年度的税款怎样记账
  • 销项税现金流量附表如何指定
  • 改制后的企业
  • 阿里云 远程连接
  • linux系统vim编辑readonly option
  • WIN7系统屏幕亮度哪里设置
  • 正常关机开机后爱奇艺自动卸载
  • ubuntu如何下载
  • mac计算器怎么用
  • mac电脑登录
  • mmc.exe是什么
  • win7系统搜索在哪
  • win7连接投屏器
  • 蓝牙鼠标不能动了
  • unity3d怎么编程
  • 事件委托机制的三个主要组件
  • js必学知识点
  • unity用visual
  • angularjs1.5
  • android设计模式的应用场景
  • css中position的用法
  • Python第三方库的常见安装方法有
  • 干部试用期满转正考察谈话提纲
  • 年收入12w
  • 国家税务局总局河南官网
  • 福建省茶叶协会会长名单
  • 公积金上个月没交
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设