位置: 编程技术 - 正文

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 异步任务队列)

  • 购买方收取的违约金怎么入账
  • 个人在境外取得收入纳税办法
  • 延期申报后可否延期缴纳税款
  • 小微企业普惠性税收减免政策2019 13号
  • 房地产业所得税
  • 预收账款可以挂多久
  • 公司清理固定资产汽车怎么开票
  • 关税的税收主体是外国的进出口商
  • 公司基本户可以转私人账户吗
  • 中标服务费计入什么会计科目
  • 发票超过认证期限可以红冲重开吗
  • 房地产企业增值税税率
  • 买一手房需要交哪些税费
  • 行政单位资产核算
  • 应交税金应交增值税已交税金怎么结转
  • 供应商提供财务报表
  • 企业进货不收发票怎么做帐?
  • 企业法人不是实际老板怎么办
  • 发票勾选没有确认怎么办
  • 契税法律依据
  • 银行贷款利息可以减免吗
  • 房地产土地成本计算公式
  • 单位年底发放的补助
  • 公司房租可以抵多少税
  • 不计入工资薪金所得的有哪些补贴
  • 代发保险款收入
  • 预付款比例怎么算
  • 关联交易认定标准税务
  • 预缴的城建税怎么做账
  • 如何调整任务栏图标大小
  • mac big sur 菜单栏
  • 联想一体机如何调节屏幕亮度
  • 公司赚的钱要交税吗?交多少?
  • sfx.exe
  • 工地事故赔付
  • 劳务佣金合法吗?
  • sql代码大全
  • 时间序列转换
  • 多个php文件整合到一起
  • php plates
  • php504错误
  • 雷达信号pri
  • 电子税务局购票员变更
  • 融资租赁的会计科目
  • 金蝶财务软件系统要求
  • mac怎么下载postman
  • 应收账款与应付账款冲账
  • 太阳能发票图片
  • 预期损失el
  • 承租人融资租赁会计账务处理
  • 劳务费个税账务处理办法
  • 当事人对付款时间没有约定或者约定不明的
  • 非公司股东可以分红吗
  • 小规模纳税人增值税专用发票税率
  • 金税盘清卡怎么弄
  • 一般纳税人支付的哪些增值税进项税额不能抵扣
  • 计提工资时一定要发票吗
  • 合同取得成本包括什么
  • mysql 分组语句
  • windowsserver2008r2密码重置
  • windows7中ie浏览器怎么打开
  • 怎么彻底关闭windows更新
  • centos怎么安装软件包
  • centos删除vg
  • win10注销是干嘛的
  • win10系统wifi信号断断续续
  • Immutable 在 JavaScript 中的应用
  • perl中打开文件
  • cocos2djs教程
  • unity 角色控制器设置isTrigger问题
  • jquery validate文档
  • 猫的所有视频
  • pygame实例
  • uleb128、sleb128和uleb128p1编码格式介绍
  • Android 自定义控件
  • 四川省地方税务局关于城镇土地使用税困难减免
  • 什么是增值税税率是多少
  • 江苏电子税务局网址
  • 财税相关书籍
  • 公司注册资本印花税的税率是多少
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

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

    友情链接: 武汉网站建设