位置: 编程技术 - 正文

Node.js中使用事件发射器模式实现事件绑定详解(nodejs示例)

编辑:rootadmin

推荐整理分享Node.js中使用事件发射器模式实现事件绑定详解(nodejs示例),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:nodejs怎么使用,node.js in action,node.js用途,node.js使用教程,node.js使用教程,node.js的使用,node.js用途,node.js用途,内容如对您有帮助,希望把文章链接给更多的朋友!

在Node里,很多对象都会发射事件。比如,一个TCP服务器,每当有客户端请求连接就会发射“connect”事件,又比如,每当读取一整块数据,文件系统就会发射一个“data”事件。这些对象在Node里被称为事件发射器(event emitter)。事件发射器允许程序员订阅他们感兴趣的事件,并将回调函数绑定到相关的事件上,这样每当事件发射器发射事件时回调函数就会被调用。发布/订阅模式非常类似传统的GUI模式,比如按钮被点击时程序就会收到相应的通知。使用这种模式,服务端程序可以在一些事件发生时作出反应,比如有客户端连接,socket上有可用数据,或者文件被关闭的时候。

还可以创建自己的事件发射器,事实上,Node专门提供了一个EventEmitter伪类,可以把它当作基类来创建自己的事件发射器。

理解回调模式

异步编程不使用函数返回值来表明函数调用的结束,而是采用后继传递风格。

“后继传递风格”(CPS:Continuation-passing style)是一种编程风格,流程控制被显式传递给下一步操作……

CPS风格的函数会接受一个函数作为额外参数,这个函数用来显式指出程序控制的下个流程,当CPS函数计算出它的“返回值”,它就会调用那个代表了程序下个流程的函数,并将CPS函数的“返回值”作为其参数。

出自维基百科—— http.request API(见后面章节)创建一个HTTP请求来访问远程HTTP服务器时的两个必要步骤。第一行采用了“后继传递风格”(CPS:Continuation-passing style),传递了一个当HTTP响应时会被调用的内联函数。HTTP请求API在这儿使用CPS是因为程序需要在http.request函数执行完毕后才继续执行后续操作。

当http.request执行完毕,就会调用那个匿名回调函数,然后将HTTP响应对象作为参数传递给它,这个HTTP响应对象是个事件发射器,根据Node文档,它可以发射包括data,end在内的很多事件,你注册的那些回调函数会在每次事件发生时被调用。

作为一条经验,当你需要在请求的操作完成后重新获取执行权时使用CPS模式,以及当事件可以发生多次时使用事件发射器模式。

理解事件类型

被发射的事件都有一个用字符串表示的类型,前面的例子包含“data”和“end”两个事件类型,它们是由事件发射器来定义的任意字符串,不过约定俗成的是,事件类型通常都由不包含空字符的小写单词组成。

不能用代码来推断出事件发射器能产生哪些类型的事件,因为事件发射器API并没有内省机制,因此你使用的API应该有文档来表明它能发射那些类型的事件。

一旦事件发生,事件发射器就会调用跟事件相关的监听器,并将相关数据作为参数传递给监听器。在前面http.request那个例子里,“data”事件回调函数接受一个data对象作为它第一个也是唯一的参数,而“end”不接受任何数据,这些参数作为API契约的一部分也是由API的作者主观定义的,这些回调函数的参数签名也会在每个事件发射器的API文档里有说明。

事件发射器虽然是个为所有类型事件服务的接口,不过“error”事件是Node里的一个特殊实现。Node里的大多数事件发射器都会在程序发生错误时产生“error”事件,如果程序没有监听某个事件发射器的 “error”事件,事件发射器将会注意到并在错误发生时向上抛出一个未捕获异常。

你可以在Node PERL里运行下面的代码来测试下效果,它模拟了一个能产生两种事件的事件发射器:

你将会看到下面的输出:

代码第2行,随便发射了一个叫“event1”的事件,没有任何效果,但是当发射“error”事件时,错误被抛出到堆栈。如果程序不是运行在PERL命令行环境里,程序将会因为未捕获的异常而崩溃。

使用事件发射器API

任何实现了事件发射器模式的对象(比如TCP Socket,HTTP 请求等)都实现了下面的一组方法:

下面我们具体介绍它们。

使用.addListener()或.on()绑定回调函数

通过指定事件类型和回调函数,你可以注册当事件发生时被执行的操作。比如,文件读取数据流时如果有可用的数据块,就会发射一个“data”事件,下面代码展示如何通过传入一个回调函数来让程序告诉你发生了data事件。

你也可以使用.on,它只是.addListener的简写方式,下面的代码和上面的是一样的:

前面代码,使用事先定义的一个的命名函数作为回调函数,你也可以使用一个内联匿名函数来简化代码:

前面说过,传递给回调函数的参数个数和签名依赖于具体的事件发射器对象和事件类型,它们并不是被标准化的,“data”事件可能传递的是一个数据缓冲对象,“error”事件传递一个错误对象,数据流的“end”事件不向事件监听器传递任何数据。

绑定多个事件监听器

事件发射器模式允许多个事件监听器监听同一个事件发射器的同一事件类型,比如:

事件发射器负责按监听器的注册顺序调用指定事件类型上绑定的所有监听器,也就是说:

1.当事件发生后事件监听器可能不会被立刻调用,也许会有其它事件监听器在它之前被调用。2.异常被抛出到堆栈是不正常的行为,可能是因为代码里有bug,当事件被发射时,如果有一个事件监听器在被调用时抛出了异常,可能会导致一些事件监听器永远不会被调用。这种情况下,事件发射器会捕获到异常,也许还会处理它。

看下面这个例子:

因为第一个监听器抛出了异常,因此第二个监听器不会被调用。

用.removeListener()从事件发射器移除一个事件监听器

Node.js中使用事件发射器模式实现事件绑定详解(nodejs示例)

如果当你不再关心一个对象的某个事件时,你可以通过指定事件类型和回调函数来取消已注册的事件监听器,像这样:

这个例子里,最后一行把一个可能在将来被随时调用的事件监听器从事件发射器对象移除了。

为了删除监听器,你必须给回调函数命名,因为在添加和删除的时候需要回调函数的名字。

使用.once()让回调函数最多执行一次

如果你想监听一个最多执行一次的事件,或者只对某个事件发生的第一次感兴趣,可以用.once()函数:

上面的代码,receiveData函数只会被调用一次。如果readStream对象发射了data事件,receiveData回调函数将会而且仅会被触发一次。

它其实只是个方便方法,因为很简单的就能实现它,像这样:

上面代码里,你重新定了EventEmitter.prototype.once函数,同时也重定义了每个继承自EventEmitter的所有对象的once函数。代码只是简单的使用.on()方法,一旦收到了事件,就用.removeEventListener()取消回调函数的注册,并调用原来的回调函数。

注意:前面代码里使用了function.apply()方法,它接受一个对象并把它作为内含的this变量,以及一个参数数组。前面例子里,通过事件发射器把未修改过的参数数组透明地传递给回调函数。

用.removeAllListeners()从事件发射器移除所有事件监听器

你可以像下面那样从事件发射器移除所有注册到指定事件类型上的所有监听器:

比如,你可以这样取消所有进程中断信号的监听器:

注意:作为一条经验,推荐你只在确切知道删除了什么内容时才使用这个函数,否则,应该让应用程序其它部分来删除事件监听器集合,或者也可以让程序的那些部分自己负责移除监听器。但不管怎样,在某些罕见的场景下,这个函数还是很有用的,比如当你准备有序的关闭一个事件发射器或者关闭整个进程的时候。

创建事件发射器

事件发射器用一个很棒的方式让编程接口变得更通用,在一个常见易懂的编程模式里,客户端直接调用各种函数,而在事件发射器模式中,客户端被绑定到各种事件上,这会让你的程序变得更灵活。(译者注:这句不太自信,贴出原文:The event emitter provides a great way of making a programming interface more generic. When you use a common understood pattern, clients bind to events instead of invoking functions, making your program more flexible.)

此外,通过使用事件发射器,你还可以获得许多特性,比如在同一事件上绑定多个互不相关的监听器。

从Node事件发射器继承

如果你对Node的事件发射器模式感兴趣,并打算用到自己的应用程序里,你可以通过继承EventEmitter来创建一个伪类:

注意:util.inherits建立了MyClass的原形链,让你的MyClass实例可以使用EventEmitter的原形方法。

发射事件

通过继承自EventEmitter,MyClass可以像这样发射事件了:

上面的代码,当someMethond方法被MyClass的实例调用时,就会发射一个叫“cuteom event”的事件,这个事件还会发射两个字符串作为数据:“argument 1”和“argument 2”,它们将会作为参数传递给事件监听器。

MyClass实例的客户端可以像这样监听“custom event”事件:

再比如,你可以这样创建一个每秒发射一次“tick”事件的Ticker类:

用Ticker类的客户端可以展示如何使用Ticker类和监听“tick”事件,

小结

事件发射器模式是种可重入模式(recurrent pattern),可以用它将事件发射器对象从一组特定事件的代码中解耦合。

可以用event_emitter.on()来为特定类型的事件注册监听器,并用event_emitter.removeListener()来取消注册。

还可以通过继承EventEmitter和简单的使用.emit()函数来创建自己的事件发射器。

Node.js模块加载详解 JavaScript是世界上使用频率最高的编程语言之一,它是Web世界的通用语言,被所有浏览器所使用。JavaScript的诞生要追溯到Netscape那个时代,它的核心内容

Node.js中创建和管理外部进程详解 Node被设计用来高效的处理I/O操作,但是你应该知道,有些类型的程序并不适合这种模式。比如,如果你打算用Node处理一个CPU密集的任务,你可能会堵塞

Node.js中使用Buffer编码、解码二进制数据详解 JavaScript很擅长处理字符串,但是因为它最初的设计是用来处理HTML文档,因此它并不太擅长处理二进制数据。JavaScript没有byte类型,没有结构化的类型(s

标签: nodejs示例

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

上一篇:Node.js中使用计时器定时执行函数详解(node-js)

下一篇:Node.js模块加载详解(nodejs引入模块)

  • 个税年度汇算清缴开始时间
  • 年底企业所得税计提少了
  • 待转销项税额是几级科目
  • 建筑发票一般开几个点
  • 网络文化传媒公司名字
  • 待抵扣进项税什么时候抵扣
  • 高新技术企业入库难吗
  • 结转上年度的企业所得税会计分录?
  • 医院减免医药费后还可以报保险吗
  • 暂估出库是什么意思
  • 哪些房屋交易需要公证
  • 进项税发票已经认证但对方又作废
  • 企业所得税季报营业收入,营业成本怎么填
  • 税务与审计调整结果不一致该如何调整?
  • 小规模企业季度超过30万,怎么收取增值税
  • 房租增值税专用发票和普通发票的税率
  • 可以选择用简易计算办法计税的是哪些
  • 高新技术企业怎么申报企业所得税
  • 违约金收入如何缴税
  • 外贸企业免征增值税
  • 小规模纳税人少计提的工资怎么办
  • 公益性捐赠专用会计科目
  • 员工住院押金会计处理
  • 金蝶软件测试笔试题及答案
  • 路由器间歇性断网怎么解决
  • macos monterey值得安装吗
  • 王者荣耀如何更改战区
  • 处理废料会计分录
  • 公司收回货款会计分录
  • php过滤emoji
  • 消费税的计税方法有
  • php零基础入门
  • 其他业务支出属于什么会计科目
  • 增值税专用发票怎么开
  • 损益类账户的期末余额一般在借方还是贷方
  • php取值
  • 【深度学习时间序列预测案例】零基础入门经典深度学习时间序列预测项目实战(附代码+数据集+原理介绍)
  • 企业对外投资资产的成本可以税前扣除吗
  • 专票地址错了要作废吗
  • 采矿权价款怎么做账
  • 海关缴款书能重开吗
  • 收到购置税完税通知书
  • 税务局清卡需要公章吗?
  • 修改账本
  • 资产负债表中存货
  • 百旺金赋怎么开红字发票
  • 新公司第一年要交什么税
  • sql编程软件哪个好用
  • 会计利润属于什么会计科目
  • 股东垫付的钱可以作为实收资本吗
  • 采购暂估业务处理流程
  • 诉讼期间的利息法院支不支持
  • 产品检验费怎样计算
  • 会计账簿记账规范要求
  • 纳税申报表中的销售额
  • 借别人的承兑后期还现钱可以吗?
  • 安装mysql失败原因
  • windows 10的安装
  • win2000停止服务
  • linux安装tmux
  • windows8介绍
  • win10无u盘装系统教程
  • Win8出现奇怪爆音的完美解决方法
  • win10mobile最新版本
  • linux计划任务如何设置
  • opengl 变形
  • math和maths哪个对
  • jquery table加载数据
  • android基础入门教程
  • unity 控件
  • js eval
  • js原型作用
  • jquery中的each方法
  • 利用python进行
  • 重庆市电子发票样式
  • 吉林省耕地占用税实施办法
  • 苏州社保代缴机构查询
  • 试运行期间的收入应如何处理
  • 如何在国税网查企业年金
  • 公司的车销售给个人怎么做账
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

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

    友情链接: 武汉网站建设