位置: 编程技术 - 正文

Node.js中的流(Stream)介绍(node.js 流)

编辑:rootadmin

推荐整理分享Node.js中的流(Stream)介绍(node.js 流),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:nodejs文件流,node.js的流的作用,nodejs文件流,node.js的流的主要作用,node.js的流的作用,nodejs的流处理模块,nodejs的流处理模块,node.js的流的作用,内容如对您有帮助,希望把文章链接给更多的朋友!

什么是流?

说到流,就涉及到一个*nix的概念:管道——在*nix中,流在Shell中被实现为可以通过 |(管道符) 进行桥接的数据,一个进程的输出(stdout)可被直接作为下一个进程的输入(stdin)。

在Node中,流(Stream)的概念与之类似,代表一种数据流可供桥接的能力。

pipe

流化的精髓在于 .pipe()方法。可供桥接的能力,在于数据流的两端(上游/下游 或称为 读/写流)以一个 .pipe()方法进行桥接。

伪代码的表现形式为:

流的分类

这里并不打算讨论所谓的Node v0.4 之前的“经典”流。那么,流分为这么几类(皆为抽象接口:

1.stream.Readable 可读流(需要实现_read方法,关注点在于对数据流读取的细节2.stream.Writable 可写流(需要实现_write方法,关注点在于对数据流写入的细节3.stream.Duplex 可读/写流(需要实现以上两接口,关注点为以上两接口的细节4.stream.Transform 继承自Duplex(需要实现_transform方法,关注点在于对数据块的处理

简单来说:

1).pipe() 的拥有者一定具备 Readable 流(并不局限于)能力,它拥有 'readable'/'data'/'end'/'close'/'error' 一系列事件可供订阅,也提供 .read()/.pause()/.resume()等一系列方法供调用;2).pipe() 的参数一定具备Writable 流(并不局限于 )能力,它拥有 'drain'/'pipe'/'unpipe'/'error'/'finish' 事件可供访问,也提供 .write()/.end() 等一系列方法供调用

什么鬼

有没有一丝丝焦虑?别急,做为一个说人话的低级码工,我会把Stream掰开了和您扯一扯的。

Stream类,在 Node.js的源码 里,是这么定义的:

Node.js中的流(Stream)介绍(node.js 流)

可以看出,本质上,Stream是一个EventEmitter,那意味着它具备事件驱动的功能(.emit/.on...)。众所周知,“Node.js 就是基于V8的事件驱动平台”,实现了事件驱动的流式编程,具备了和Node一样的异步回调的特征。

比如在 Readable 流中,有一个 readable 事件,在一个暂停的只读流中,只要有数据块准备好可读时,它就会被发送给订阅者(Readable 流有哪些呢?express中的 req,ftp或者mutli-form上传组件的req.part,系统中的标准输入 process.stdin等)。有了readable 事件,我们可以做个处理shell 命令输出的分析器之类的工具:

这样调用:

对于 Readable 流,我们还可以订阅它的 data 和 end 事件,以获取数据块并在流枯竭时获得通知,如 经典socket示例 中那样:

Readable流状态的切换需要注意的是,Readable 流有两种状态:flowing mode(激流) 和 pause mode(暂停)。前者根本停不下来,谁被pipe上了就马上不停的给;后者会暂停,直到下游显式的调用 Stream.read() 请求才读取数据块。Readable 流初始化时是 pause mode的。

这两种状态可以互为切换的,其中,

有以下任一行为,pause 转 flowing:

1.对 Readable 流添加一个data事件订阅2.对 Readable 调用 .resume() 显式开启flowing3.调用 Readable 流的 .pipe(writable) ,桥接到一个 Writable 流上

有以下任一行为,flowing 转回 pause:

1.Readable 流还没有 pipe 到任何流上,可调 .pause() 暂停2.Readable 流已经 pipe 到了流上,需 remove 掉所有 data 事件订阅,并且调用 .unpipe()方法逐一解除与下游流的关系

妙用

结合流的异步特性,我可以写出这样的应用:直接将 用户A 的输出桥接到 用户B 的页面上输出:

用户B请求的时候:

参考

how to write node programs with streams: stream-handbook

Node.js 异步编程之 Callback介绍(一) Node.js基于JavaScript引擎v8,是单线程的。Node.js采用了与通常Web上的JavaScript异步编程的方式来处理会造成阻塞的I/O操作。在Node.js中读取文件、访问数据库

初识Node.js 先来简单介绍nodeJS我们知道JavaScript是运行在浏览器中的,浏览器为它提供了一个上下文(context),从而让JavaScript得以解析执行。nodeJS其实可以这么理解,

nodejs中实现sleep功能实例 nodejs最让人不爽的就是其单线程特性,很多事情没法做,对CPU密集型的场景,性能也不够强劲。很长一段时间,我想在javascript语言框架下寻求一些解决

标签: node.js 流

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

上一篇:ubuntu下安装nodejs以及升级的办法(ubuntu下安装visual studio)

下一篇:Node.js 异步编程之 Callback介绍(一)(nodejs 异步任务队列)

  • 机票代理是否差额征税
  • 企业所得税视同销售的会计处理是?
  • 企业给员工交公积金国家有规定的
  • 长期股权投资其他综合收益什么时候转留存收益
  • 补贴收入企业所得税
  • 境外投资子公司审计报告人民币汇率
  • 非货币性资产投资个人所得税
  • 住房贷款利息专项附加扣除是返钱吗
  • 取得运输业专用发票可以抵扣进项吗
  • 金税盘的进项发票怎么导出
  • 政府专项补助购置固定资产进项税可以抵扣吗?
  • 技术开发合同免征企业所得税吗
  • 小规模印花税减免性质代码和项目名称
  • 退休职工的医疗保险怎么发放
  • 事业单位购买固定资产费自行
  • 售后回租 出租方
  • 企业所得税年报过了申报期还能修改吗
  • 广告公司收到专票怎么做成本
  • 购买汽车分期付款利息怎么算
  • 增值税小规模纳税人减免增值税政策
  • 成本和费用属于资产吗
  • 工程款分配方式
  • 长期股权投资溢价购入
  • win10更新错误0x8000402
  • 文件夹正在使用,操作无法完成
  • windows 10 build 21354
  • 材料发票可以抵税吗
  • 哪些发票内容可以抵税
  • 定额征收怎么交税
  • 即期结售汇期限包括
  • 苹果macOSBigSur是什么型号
  • PHP简单实现HTTP和HTTPS跨域共享session解决办法
  • 软件企业职工培训费税前扣除标准
  • 简易计税行业
  • php处理xml
  • 进价金额核算法例题
  • 进口货物财务处理
  • 如何在idea上运行python
  • python初学笔记
  • 微信公众号认证300元每年都要吗
  • 现金流量表期初现金余额怎么计算
  • 子公司使用母公司固定资产
  • 差旅费取得发票怎么处理
  • 什么叫误餐费
  • vscode开发gui
  • 项目资金支付
  • 个人代工程发票要缴纳的个税
  • 城镇土地使用税税率
  • 账面价值低于可抵税收
  • 一般纳税人的服务费税率是多少
  • 月末怎么计提摊销和结转
  • 投资收益主要包括哪些
  • 餐费发票报销需提供清单吗
  • 库存商品核算流程是怎样的
  • 连接mysql数据的四要素
  • rpm方式安装samba软件
  • unins000.exe - unins000是什么意思
  • win8系统找不到wifi
  • win7声音方案存在哪里
  • msedge.exe是什么
  • linux ed
  • 有没有win8系统
  • win10开启预览
  • bootstrap modal 位置
  • [置顶] rwmfqg
  • python hashcode
  • Unity3D游戏开发标准教程吴亚峰于复兴人民邮电出版社
  • linux,windows
  • NGUI之UIGrid
  • Qualcom QMI系列-基本知识介绍
  • mac如何配置pycharm
  • jquery.inarray
  • js怎么获取密码框内容
  • 地方税务局怎么查企业信息
  • 别人给公司开的普票,怎么查询
  • 应纳税额减征额账务处理
  • 哪些润滑油属于危险品类
  • 辽宁地方税务局招聘
  • 增值税税负标准是什么
  • 伊朗开心果进口价格
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

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

    友情链接: 武汉网站建设