《NodeJS开发教程8-事件》

事件EventEmitter可谓是NodeJS中的重中之重!
大多数 Node.js 核心 API 都采用惯用的异步事件驱动架构,其中某些类型的对象(触发器)会周期性地触发命名事件来调用函数对象(监听器)。

例如,net.Server 对象会在每次有新连接时触发事件;fs.ReadStream 会在文件被打开时触发事件;流对象 会在数据可读时触发事件。

所有能触发事件的对象都是 EventEmitter 类的实例。 这些对象开放了一个 eventEmitter.on() 函数,允许将一个或多个函数绑定到会被对象触发的命名事件上。 事件名称通常是驼峰式的字符串,但也可以使用任何有效的 JavaScript 属性名。

EventEmitter 对象触发一个事件时,所有绑定在该事件上的函数都被同步地调用。 监听器的返回值会被丢弃。

  • 事件的基本使用
    首先需要引入
/*事件*/
var EventEmitter=require("events");

require("events")返回的EventEmitter是一个类(或者说events模块exports导出的是一个class)然后:

/*事件*/
var EventEmitter=require("events");

const event=new EventEmitter();//创建一个事件发射器实例
//注册异步事件
event.on("customEvent",function()
{
    console.log("customEvent事件触发");
});

//触发事件
event.emit("customEvent");

我们通过 const event=new EventEmitter()得到一个实例对象event
接着可以通过event.on(eventName,callbackfunc)来注册一个异步事件
在需要触发eventName事件时使用 event.emit(eventName)进行事件的触发,事件可以注册多个相同事件的监听器,在触发该事件时,依次按照注册的顺序进行触发事件监听器的回调方法callbackfunc。

  • 事件监听器回调方法中的this
    事件监听器回调方法中的this,指向的对象会有不同:
    在function(){this}中this指向的是触发该事件的发射器实例对象,也就是 下面示例中的 myEmitter
    在箭头函数()=>{this}中this指向的则是myEmitter所在的父作用域对象。
class MyEmitter extends EventEmitter{

    constructor(name)
    {
        super();
        this.name=name;
    }
    getName()
    {
        return this.name;
    }

}

const myEmitter=new MyEmitter("自定义事件发射器");
myEmitter.on("clicktest",function()
{
    //会打印:clicktest事件触发 自定义事件发射器
    console.log("clicktest事件触发",this.getName());

});
myEmitter.on("clicktest",()=>{
    //箭头函数中this指向的并不是myEmitter
    //会打印:clicktest事件触发 myEmitter父作用域中的getName()方法
    //如果把下面的this.getName=function(){}注释掉,这个事件触发后会报错,因为找不到getName()方法;
    console.log("clicktest事件触发",this.getName());
});
this.getName=function()
{
    return "myEmitter父作用域中的getName()方法";
}

//触发事件
myEmitter.emit("clicktest");
  • 事件发生的同步与异步
    EventEmitter 会按照监听器注册的顺序同步地调用所有监听器。 所以需要确保事件的正确排序且避免竞争条件或逻辑错误。 监听器函数可以使用 setImmediate() 或 process.nextTick() 方法切换到异步操作模式:
//同步与异步事件发生
myEmitter.on("asyncEvent",function()
{
    setImmediate(()=>{
        console.log("asyncEvent事件发生是异步的");
    });
    console.log("asyncEvent事件发生是同步的");
});
myEmitter.emit("asyncEvent");
console.log("看谁先执行,异步和同步");

执行输出:

asyncEvent事件发生是同步的
看谁先执行,异步和同步
asyncEvent事件发生是异步的
  • 只触发一次事件
    我们使用 myEmitter.on()注册的事件,每当在调用 myEmitter.emit()时都会触发一次监听器回调,如果我们需要只让他触发一次监听器回调,应该使用
    myEmitter.once()进行事件的注册
//只执行一次监听回调
myEmitter.on("myevent",function()
{
    console.log("myevent事件触发");
});
myEmitter.once("myevent2",function()
{
    console.log("myevent2事件触发");
});

myEmitter.emit("myevent");
myEmitter.emit("myevent");

myEmitter.emit("myevent2");
myEmitter.emit("myevent2");

执行输出:

myevent事件触发
myevent事件触发
myevent2事件触发
  • newListener内置事件
    myEmitter.on("newListener",function(){});
    newListener事件属于内置事件,含义是:当 myEmitter实例对象有 新事件监听器注册时 触发该 newListener事件。
//当有事件注册监听时触发
myEmitter.on("newListener",function()
{
    console.log("newListener事件触发");
});

myEmitter.on("myevent",function()
{
    console.log("myevent事件触发");
});
//只执行一次监听回调
myEmitter.once("myevent2",function()
{
    console.log("myevent2事件触发");
});

执行输出

newListener事件触发
newListener事件触发
  • removeListener事件移除
//事件移除
myEmitter.on("genEvent",handlerEvent);

function handlerEvent()
{
    console.log("genEvent事件触发");
}

myEmitter.emit("genEvent");
//移除改事件监听后,后续再emit该事件则忽略不会触发监听回调
myEmitter.removeListener("genEvent",handlerEvent);
myEmitter.emit("genEvent");

执行输出:

genEvent事件触发
  • 最大监听器注册数量
    每个事件默认可以注册最多 10 个监听器。 单个 EventEmitter 实例的限制可以使用 emitter.setMaxListeners(n) 方法改变

  • emitter.getMaxListeners()获取最大监听器数
    返回 EventEmitter 当前的最大监听器限制值,该值可以通过 emitter.setMaxListeners(n)

nodejs性能的提升大部分原因是得益于 异步事件机制。它摒弃掉了多线程,使用单线程进行处理主逻辑(当然io操作依然是多线程处理)通过异步事件来节约cpu的等待周期,最大限度的压榨cpu资源。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,542评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,596评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,021评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,682评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,792评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,985评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,107评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,845评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,299评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,612评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,747评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,441评论 4 333
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,072评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,828评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,069评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,545评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,658评论 2 350

推荐阅读更多精彩内容

  • Node.js EventEmitter Node.js 所有的异步 I/O 操作在完成时都会发送一个事件到事件队...
    FTOLsXD阅读 311评论 1 2
  • https://nodejs.org/api/documentation.html 工具模块 Assert 测试 ...
    KeKeMars阅读 6,313评论 0 6
  • Module definition patterns 除了作为加载依赖的机制之外,模块系统也是一种用于定义AP...
    宫若石阅读 463评论 0 0
  • 前言: 因为以前学习Node.js并没有真正意义上的去学习它,而是粗略的学习了npm的常用命令和Node.js一些...
    Srtian阅读 984评论 1 17
  • 岁月如一幅画,勾勒在了时间的空隙处,一笔一划用曾经画出了现在的山水。岁月如一首歌,绵绵起伏,用悠扬的音符,跳跃在人...
    流徒风情阅读 130评论 0 0