位置: 编程技术 - 正文

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创建项目)

  • 公司现金账户归谁管
  • 职工薪酬如何做账
  • 企业所得税视同销售的会计处理
  • 营业总收入包含投资收益吗
  • 企业税分几种类型
  • 自然人生产经营所得,如何计算个税
  • 减免税款会计分录
  • 商业汇票和商业本票
  • 转账支票遗失能挂失吗
  • 4s店试驾车转卖怎么开票
  • 新公司第一个月报税怎么弄
  • 已经在网上申报学校可以改学校吗
  • 专票密码区压线可以报销吗
  • 重点税源表怎么自动取数
  • 福利费提取后未使用能否税前扣除?
  • 订阅报纸属于会计科目吗
  • 采用视同买断方式代销商品怎么记账?
  • 进口商品关税调整
  • macbook如何安装
  • 经费支出渠道
  • 合同作废印花税法规定
  • 其他应付款贷方增加
  • linux1970
  • 小规模商贸企业增值税税率
  • avgserv9.exe是什么进程 avgserv9进程的详细介绍
  • 社保缴费半年
  • php变量用什么符号
  • 支付离退休人员退休金可以用现金结算吗
  • 工程未竣工结算但质保期已过
  • 夕阳下的大白鲨过山车,美国新泽西州 (© John Van Decker/Alamy)
  • 无形资产相关税费
  • 企业所得税核定征收方法有哪两种
  • php比较大小
  • 微信小程序游戏手游排行榜
  • php array_fill
  • ping命令详解步骤
  • setup prompt
  • ps中文字复制粘贴
  • 防洪保安资金可以抵扣个税吗
  • 外币财务报表的未分配利润
  • 本月没有销售收入,需要申报增值税吗
  • 委托加工代收代缴消费税分录
  • 受让应收账款的账务处理
  • 商誉需要交税吗
  • 制作海报属于什么行业
  • mysql关闭连接命令
  • 个人所得税中的速算扣除数是什么意思
  • 无形资产的摊销计入什么科目
  • 开票金额和发票金额
  • 进口产品没有发票怎么入账
  • 进项税可以跨年结转吗
  • 个体户办营业执照网上怎么申请
  • 加计扣除是指什么意思
  • 工程承建方给予什么赔偿
  • 员工拿发票报销账务处理
  • 内部转账单怎么填制
  • 预提与计提的区别在哪里
  • 住房公积金的账号怎样可以查询得到
  • 做账工资和申报工资不一样
  • 无形资产是当月计提折旧吗
  • sql server建表时怎样选择数据类型
  • 如何设计高效合理的未来课程
  • linux所谓的free
  • lsf.exe是什么
  • win10提高
  • ps显示操作步骤
  • win10无internet怎么办
  • opengl怎么学
  • bootstrap响应式工具使用详解
  • 你miu的
  • unity怎么设置多个关卡
  • javascript运用
  • jupyter 安装python包
  • android 自定义
  • javascript数据结构与算法百度云视频资源
  • 税票上的开票员是谁
  • 税款所属期起怎么填写
  • 小规模纳税人利润如何缴税
  • 落地和全包一样吗
  • 年度汇算清缴计算
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

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

    友情链接: 武汉网站建设