Node——事件的监听与触发

Node.js是由事件驱动的,每个任务都可以当作一个事件来处理,本贴将对Node.js中的events模块及其中处理事件的类EventEmitter的使用进行详细讲解。
在这里插入图片描述

1、EventEmitter对象

在JavaScript中,通过事件可以处理许多用户的交互,比如鼠标的单击、键盘按键的按下、对鼠标移动的反应等。在Node.js中也提供了类似的事件驱动,主要是通过events模块实现的,该模块中提供了EventEmitter类,用于处理事件。要使用EventEmitter类处理事件,首先需要对其进行初始化,代码如下:

EventEmitter = require('events')
eventEmitter = new EventEmitter()

在Node.js中,可以添加监听事件的对象都是继承自EventEmitter对象,后者提供了用于处理Node.js事件的方法,常用方法及说明如下表所示:
在这里插入图片描述
说明
EventEmitter对象的addListener()方法和on()方法都用来添加监听事件,它们的使用是等效的,实际上,on方法在内部实现时调用了addListener()方法。Node.js中推荐使用on()方法添加监听事件。

使用EventEmitter对象创建简单事件,在WebStorm中创建一个.js文件,其中创建一个EventEmitter对象,并使用其on方法添加监听事件,在监听事件中输出一个日志信息,然后使用emit()方法触发该监听事件。代码如下:

//引入events模块
var events = require('events');
//生成EventEmitter对象
var custom = new events.EventEmitter();
//添加监听事件tick
custom.on('tick', function (code) {
     console.log('执行指定事件!');
});
//主动触发监听事件tick
custom.emit('tick');

运行程序,效果如下图所示:
在这里插入图片描述
上面的代码中,使用EventEmitter对象添加监听事件和触发监听事件的代码都放在了一个文件中,但实际应用时,通常会把添加监听事件的模块和触发监听事件的模块分开,如下图所示就是一种常用的实现Node.js监听事件的文件构成方式。其中,app.js文件中添加相关监听事件,rint.js文件中触发相关监听事件。
在这里插入图片描述
演示项目中监听事件的添加与触发,程序开发步骤如下:
(1)在WebStorm中创建一个rint.js文件,该文件中使用EventEmitter对象的emit()方法每隔1秒触发一次tick事件,代码如下:

//定义变量,用来记录执行次数
num=0
//引入events模块
var events = require('events');
//生成 EventEmitter 对象
exports.timer = new events.EventEmitter();
//触发监听事件tick
setInterval(function () {
     num+=1
     exports.timer.emit('tick',num);
}, 1000);

(2)创建一个app.js文件,为rint模块添加具体的tick事件,该事件中输出一个日志信息,代码如下:

//引入rint模块
var rint = require('./rint.js');
//添加监听事件
rint.timer.on('tick', function (code) {
     console.log(`执行第 ${code} 次监听事件`);
});

运行app.js文件,效果如下图所示:
在这里插入图片描述

2、添加和触发监听事件

前面我们演示了如何在Node.js中添加监听事件和触发监听事件,主要用到的是EventEmitter对象的on方法和emit方法,下面对这两个方法及其使用进行详细讲解。

2.1、 添加监听事件

通过上面的学习,我们已经知道,在Node.js中添加监听事件使用的是EventEmitter对象的on方法,该方法主要用来将回调函数添加到名为eventName的事件监听器数组的末尾,其语法格式如下:

on(eventName,listener)
  • eventName:一个字符串,表示事件名称。
  • listener:回调函数。

在使用on方法向事件监听器数组中添加函数时,不会检查其是否已被添加,如果多次调用并传入相同的eventName与listener,会导致listener被重复添加多次。例如,下面代码会为tick事件添加3次同样的输出日志函数:

//引入events模块
var events = require('events');
//生成EventEmitter对象
var custom = new events.EventEmitter();
//添加监听事件tick
custom.on('tick', function () {
     console.log('第1次添加!');
});
custom.on('tick', function () {
     console.log('第2次添加!');
});
custom.on('tick', function () {
     console.log('第3次添加!');
});
//主动触发监听事件tick
custom.emit('tick');

执行上面代码时,默认运行结果如下:

1次添加!
第2次添加!
第3次添加!

从上面的运行结果可以看出,在默认情况下,事件监听器会按照添加的顺序依次调用,但如果想要改变添加顺序,该怎么办呢?EventEmitter对象提供了一个prependListener方法,该方法可以将事件回调函数添加到监听器数组的开头,其语法如下:

prependListener(eventName, listener)
  • eventName:一个字符串,表示事件名称。
  • listener:回调函数。

例如,将上面的代码修改如下:

//引入events模块
var events = require('events');
//生成EventEmitter对象
var custom = new events.EventEmitter();
//添加监听事件tick
custom.on('tick', function () {
     console.log('第1次添加!');
});
//将回调函数添加到事件监听器数组的开头
custom.prependListener('tick', function () {
     console.log('第2次添加!');
});
custom.on('tick', function () {
     console.log('第3次添加!');
});
//主动触发监听事件tick
custom.emit('tick');

运行结果会变成下面这样:

2次添加!
第1次添加!
第3次添加!

另外,需要注意的是,在上面的示例中,我们可以为同一个事件添加多个回调函数,但如果添加的回调函数超过10个,则会出现如下图所示的警告提示:
在这里插入图片描述
通过观察上图可以看到,如果为同一个事件添加的回调函数超过了10个,程序可以正常运行,但会在运行完之后出现警告提示,如何避免该警告呢?EventEmitter对象提供了一个setMaxListeners方法,该方法用来设置可以监听的最大回调函数数量,其语法格式如下:

setMaxListeners(limit)
  • limit:一个数字,用来表示可以监听的最大回调函数数量。

例如,将监听器可以监听的最大回调函数数量设置为15个,代码如下:

custom.setMaxListeners(15)

2.2、添加单次监听事件

使用前面介绍的on方法添加事件时,事件一旦添加就会一直存在,但如果遇到只想执行一次监听事件的情况,使用on方法就无能为力了,这时可以使用EventEmitter对象的once方法,该方法用来将单次监听器listener添加到名为eventName的事件,当eventName事件下次触发时,监听器会先被移除,然后再调用。once方法的语法格式如下:

once(eventName,listener)
  • eventName:一个字符串,表示事件名称。
  • listener:回调函数。

使用once方法添加单次监听事件:在WebStorm中创建一个index.js文件,其中使用EventEmitter对象的once方法为监听事件绑定一个回调函数,然后使用emit方法触发该监听事件,在触发时,设置每秒触发一次,代码如下:

//引入events模块
var events = require('events');
//生成EventEmitter对象
var custom = new events.EventEmitter();
function onUncaughtException(error) {
     //输出异常内容
     console.log('发生异常,请多加小心 !');
}
//添加监听事件event
custom.once('event', onUncaughtException);
//主动触发监听事件event
setInterval(function () {
     custom.emit('event');
}, 1000);

运行程序,效果如下图所示:
在这里插入图片描述
说明
上图中,使用once方法添加监听事件后,每隔一秒触发一次该事件,但只执行了一次。但是,如果将代码中第10行的once修改为on,则运行结果会变成每隔一秒输出一次日志。

2.3、触发监听事件

当对指定对象添加监听事件后,需要触发添加的监听事件,这时需要使用EventEmitter对象的emit方法,其语法格式如下:

emit(eventName[, ...args])
  • eventName:一个字符串,表示要触发的事件名称。
  • args:回调函数中需要的参数。
  • 返回值:布尔值,表示是否成功触发事件。

使用emit方法触发事件:在WebStorm中创建一个index.js文件,其中使用EventEmitter对象的on方法为监听事件绑定一个回调函数,然后使用emit方法触发该监听事件,代码如下:

//引入events模块
var events = require('events');
//生成EventEmitter对象
var custom = new events.EventEmitter();
//添加监听事件event
custom.on('event', function listener() {
     console.log('触发监听事件!');
});
//主动触发监听事件event
custom.emit('event');

运行程序,效果如下:

触发监听事件!

上面为事件添加的回调函数没有参数,但在实际开发中,可能需要定义带参数的回调函数,这时使用emit方法触发监听事件时,传入相应个数的参数即可。

触发带参数的监听事件:在WebStorm中创建一个index.js文件,其中使用EventEmitter对象的on方法为监听事件绑定两个回调函数,第一个回调函数有一个参数,第二个回调函数的参数为不定长参数,然后使用emit方法触发该监听事件,代码如下:

//引入events模块
var events = require('events');
//生成EventEmitter对象
var custom = new events.EventEmitter();
//添加监听事件event
custom.on('event', function listener1(arg) {
     console.log(`第 1 个监听器中的事件有参数 ${arg}`);
});
//添加监听事件event
custom.on('event', function listener1(...args) {
     parameters = args.join(', ');                              //连接参数
     console.log(`第 2 个监听器中的事件有参数 ${parameters}`);
});
//主动触发监听事件event
custom.emit('event', 1, '明日','年龄:30','爱好:编程');

运行程序,效果如下图所示:
在这里插入图片描述
从上图可以看出,由于在第一个event事件中定义的回调函数中只有一个参数arg,因此在触发时,即使传入了多个值,其也只输入第一个值;在第二个event事件定义的回调函数中,由于使用了“…args”进行定义,这表示它是一个不定长参数,因此在触发时,会根据传入参数的个数输出相应的内容。

3、删除监听事件

前面已经学习了如何添加及触发监听事件,如果添加的监听事件不需要了,可以将它删除。删除监听事件的方法如下:

  • removeListener(eventName,listener):删除指定名称的监听事件。
  • removeAllListeners([eventName]):删除全部监听事件。

下面通过一个实例来演示如何使用Node.js中删除监听事件的方法。将要添加到监听事件的回调函数单独定义,并添加到event监听事件并触发;在触发监听事件后,使用removeListener方法删除该监听事件,并通过输出删除前后的监听事件名称进行对比。代码如下:

//引入events模块
var events = require('events');
//生成EventEmitter对象
var custom = new events.EventEmitter();
function listener() {
     console.log('触发监听事件!');
}
//添加监听事件event
custom.on('event', listener);
//主动触发监听事件event
custom.emit('event');
console.log(custom.eventNames());            //输出删除前的监听事件名称
custom.removeListener('event',listener) ;    //删除event事件
console.log(custom.eventNames());            //输出删除后的监听事件名称

说明
在EventEmitter中还提供了off(eventName, listener)方法,该方法实际上相当于removeListener方法的别名,也可以删除指定名称的监听事件,其使用方法与removeListener完全一样。运行程序,效果如下图所示:
在这里插入图片描述
在使用removeListener方法删除监听事件时,如果同一个事件监听器被多次添加到指定eventName的监听器数组中,则必须多次调用removeListener方法才能删除所有事件。例如:

//引入events模块
var events = require('events');
//生成EventEmitter对象
var custom = new events.EventEmitter();
function listener() {
     console.log('触发监听事件!');
}
//添加监听事件event
custom.on('event', listener);
/*多次添加同一个事件*/
custom.on('event', listener);
custom.on('event', listener);
custom.on('event', listener);
//主动触发监听事件event
custom.emit('event');
console.log(custom.eventNames());         //输出删除前的监听事件名称
custom.removeListener('event',listener);  //删除event事件
console.log(custom.eventNames());         //输出删除后的监听事件名称

上面代码中为event事件添加了4次listener回调函数,但只使用removeListener删除了一次event事件,运行结果如下图所示:
在这里插入图片描述
观察上图可以看出,删除前后,event事件都存在,说明使用removeListener并没有完全删除多次添加的event事件。这时,如果想要完全删除event事件,可以使用removeListener方法删除4次,也可以直接使用removeAllListeners删除所有的监听事件,代码如下:

custom.removeAllListeners('event');  //删除所有event事件

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mfbz.cn/a/201507.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

C语言进阶指南(15)(函数指针的创建与使用)

*欢迎来到博主的专栏——C语言进阶指南 博主id 文章目录 函数指针函数指针的应用——回调函数函数指针数组 函数指针 函数也有地址(函数在调用的时候会占用内存空间,所以函数是有地址的),因此我们也可以用一个指针指向函数 1 函数…

利用数据库的表,生成word文档的表结构注释说明

文章目录 1.场景说明2.解决办法3.生成文档3.1.实现思路3.2.引入Apache POI依赖3.3.获取表及表字段说明Mapper3.4.POI创建文档表格,并填充数据3.5.完整的接口下载代码3.6.效果展示 1.场景说明 在项目中表已经建立好了,但是现在想对外提供一个表的字段的描…

Kong处理web服务跨域

前言 好久没写文章了,大概有半年多了,这半年故事太多,本文写不下,就写写文章标题问题! 问题描述 关于跨域的本质问题我这里不过多介绍,详细请看历史文章 跨域产生的原因以及常见的解决方案。 我这边是新…

连锁零售企业如何提高异地组网的稳定性?

随着数字化时代的到来,连锁零售企业面临着日益复杂和多样化的网络挑战。连锁零售企业是在不同地理位置拥有分支机构和零售店,可能同城或异地,需要确保各个地点之间的网络连接稳定和可靠。但由于不同地区的网络基础设施差异、网络延迟和带宽限…

【 C 语言经典100例】C 练习实例10

题目&#xff1a;打印楼梯&#xff0c;同时在楼梯上方打印两个笑脸。 程序分析&#xff1a;用 ASCII 1 来输出笑脸&#xff1b;用i控制行&#xff0c;j来控制列&#xff0c;j根据i的变化来控制输出黑方格的个数。 #include<stdio.h>int main() {int i,j;printf("\…

浙江省跨境电商产业联盟大会成功举办:开启探索数字贸易丝路电商之旅

11月26日上午&#xff0c;浙江省跨境电商产业联盟大会在杭州国际博览中心“丝路电商馆”成功举办。浙江省商务厅副厅长张钱江出席活动并致辞。39个省级跨境电商产业园代表&#xff0c;知名跨境电商平台、卖家、服务商企业代表、高校智库专家等参加本次活动&#xff0c;吸引大批…

基于PaddleOCR银行卡识别实现(三)

前言 基于PaddleOCR银行卡识别实现&#xff08;一&#xff09; 基于PaddleOCR银行卡识别实现&#xff08;二&#xff09; 前两篇文章讲了检测模型和识别模型的实现&#xff0c;这一篇文章姗姗来迟&#xff0c;将讲解下两个模型的串联应用和PaddleOCR的源码精简&#xff0c;下面…

全局异常处理类

全局异常处理类 创建步骤 定义一个自己的全局错误处理类GlobalExceptionHandler创建一个ExceptionHandler类&#xff0c;主要是用ControllerAdvice和 ExceptionHandler处理错误信息 以下说明各个注解的作用&#xff1a; ControllerAdvice(annotations {RestController.class…

【爬虫实战】最新python豆瓣热榜Top250

一.最终效果 豆瓣是大多数新手练习爬虫的 二.数据定位过程 对于一个目标网站&#xff0c;该如何快速判定页面上的数据来源&#xff1f;首先你需要简单web调试能力&#xff0c;对大多数开发者来说都chrome浏览器应该是不二选择&#xff0c;当然我选中的也是。F12打开调试面板&…

在PyCharm中配置PyQt5环境

在PyCharm中配置PyQt5环境 文章目录 1.安装第三方库2.PyQt5设计器3.PyUIC转换工具 &#x1f339;꧔ꦿ&#x1f339;꧔ꦿ&#x1f339;꧔ꦿ&#x1f339;꧔ꦿ&#x1f339;꧔ꦿ&#x1f339;꧔ꦿ&#x1f339;꧔ꦿ&#x1f339;꧔ꦿ&#x1f339;꧔ꦿ&#x1f339;꧔ꦿ&#x1…

《On Java》

文章目录 一、Java概述1.JVM、JRE和JDK的关系2.什么是Java程序的主类3.Java和C的区别 三、面向对象3.1 面向对象三大特性封装继承多态 3.2 基本类型默认值3.3 和 equals 四、操作符4.1 比特和字节4.2 位操作&^ 4.3 运算符Math.round()loat f3.4;是否正确 4.4 实战小于n的最…

外包干了5个月,技术退步明显.......

先说一下自己的情况&#xff0c;大专生&#xff0c;18年通过校招进入武汉某软件公司&#xff0c;干了接近4年的功能测试&#xff0c;今年年初&#xff0c;感觉自己不能够在这样下去了&#xff0c;长时间呆在一个舒适的环境会让一个人堕落! 而我已经在一个企业干了四年的功能测…

【刷题】DFS

DFS 递归&#xff1a; 1.判断是否失败终止 2.判断是否成功终止&#xff0c;如果成功的&#xff0c;记录一个成果 3.遍历各种选择&#xff0c;在这部分可以进行剪枝 4.在每种情况下进行DFS&#xff0c;并进行回退。 199. 二叉树的右视图 给定一个二叉树的 根节点 root&#x…

DDoS高防IP到底是什么?

DDoS高防IP是提供一个带防御的IP&#xff0c;主要是针对网络中的DDoS攻击进行保护&#xff0c;是针对互联网服务器遭受大流量的DDoS攻击后&#xff0c;导致服务不可用的情况下&#xff0c;用户可以通过配置高防IP&#xff0c;将攻击流量引流到高防IP上&#xff0c;从而确保源站…

【浅尝C++】运算符重载(含类的3大默认成员函数:赋值、取地址、const对象取地址运算符重载)

&#x1f388;归属专栏&#xff1a;浅尝C &#x1f697;个人主页&#xff1a;Jammingpro &#x1f41f;记录一句&#xff1a;在Linux与C中来回横跳&#xff0c;哪个学累了&#xff0c;就去学另外一个~~ 文章前言&#xff1a;本篇文章简要介绍C的运算符重载&#xff0c;同时接着…

如何用CHAT写“科技探索者”视频号运营方案

问CHAT&#xff1a;生成一篇“科技探索者”视频号运营方案&#xff0c;要求内容&#xff1a; &#xff08;1&#xff09;视频号的定位、面向的人群、主要发布哪方面的内容 &#xff08;2&#xff09;视频号的内容设计&#xff08;用什么样的方式来体现、最好有内容创意&#xf…

Java大型智慧工地APP云平台源码带AI智能识别功能

智慧工地为建筑全生命周期赋能&#xff0c;用创新的可视化与智能化方法&#xff0c;降低成本&#xff0c;创造价值。 一、智慧工地APP概述 智慧工地”立足于互联网&#xff0c;采用云计算&#xff0c;大数据和物联网等技术手段&#xff0c;针对当前建筑行业的特点&#xff0c;…

Spark local模式的安装部署

安装与配置Spark开发环境。 相关知识 Apache Spark是专为大规模数据处理而设计的快速通用的计算引擎。Spark是UC Berkeley AMP lab(加州大学伯克利分校的AMP实验室)所开源的类Hadoop MapReduce的通用并行框架&#xff0c;Spark拥有Hadoop MapReduce所具有的优点&#xff1b;但…

Linux 进程(二)

1.当前工作目录 Linux 下使用 ls /proc 查看程序中的进程&#xff0c;其中这些蓝色的数字代表的就是进程。 其中cwd(current working directory)就是当前工作目录&#xff0c;那么为什么cwd 和 exe 是在同一级目录下呢因为 进程需要依赖可执行程序&#xff0c;可执行程序需要依…

Reactor模式

Reactor模式有点类似事件驱动模式。在事件驱动模式中&#xff0c;当有事件触发时&#xff0c;事件源会将事件分发到Handler&#xff08;处理器&#xff09;&#xff0c;由Handler负责事件处理。Reactor模式中的反应器角色类似于事件驱动 模式中的事件分发器&#xff08;Dispatc…
最新文章