• 技术文章 >web前端 >js教程

    深入聊聊node.js中的EventEmitter

    青灯夜游青灯夜游2022-05-09 21:33:59转载422
    本篇文章带大家了解一下node中的EventEmitter,简单聊聊一下异步操作、error事件、EventEmitter类,希望对大家有所帮助!

    events(事件触发器)


    events是nodejs内置的事件触发器,在node的内置模块里很多都用到了events,比如http.server在每次接受到请求时触发事件,还有stream就是基于事件的使用on来监听对应的事件。 所有触发事件的对象都是EventEmitter实例,这些对象暴露了EventEmitter.on('事件',callback),通常使用EventTmitte.on注册事件,EventEmitter.emit触发事件。

    例子:

      const events= require('events');
    const event=new events();//实例化EventEmitter
    event.on('data',(a,b)=>{
        console.log('参数'+a+b)
        console.log(this,'this')
        //注意,如果callback是 箭头函数的话this指向的是全局对象
        //      如果callback是function(){}形式的话,this会绑定到EventEmitter实例上
        console.log('emit触发了data事件')
    })
    event.emit('data',1,2); //使用emit触发事件

    异步操作

    因为EventEmitter.on('事件名称',callback)里的callback是同步执行的,但是在某些情况下我们不得不使用异步操作所以我们可以在使用SetImmediate来执行异步操作

     const events= require('events');
    const event=new events();
    event.on('event', (a, b) => {
        
      setImmediate(() => {
        console.log('this happens asynchronously');
      });
      //因为这里的监听器是同步执行的,但是我们可以使用setImediate函数等待监听器里的其他内容执行完再执行
    });
    event.emit('event',1,2);

    触发一次

    我们正常通过emit触发事件时,emit有几个事件就会被触发几次,但是我们可以使用once注册事件,使用once触发的事件只能被触发一次

      const EventEmitter =require('events');
      const MyEventEmitter=new EventEmitter();
      let a=0;
      //正常注册事件和触发
      MyEventEmitter.on('add',()=>{
          a++
          console.log(a) 
      })
      MyEventEmitter.emit('add'); // 1;
      MyEventEmitter.emit('add'); // 2;
      // 使用once注册
      MyEventEmitter.once('add',()=>{
          a++
          console.log(a);
      })
      MyEventEmitter.emit('add') // 1
      MyEventEmitter.emit('add') // 不生效了

    error事件

    EventEmitter是没有error事件的,所以当发生错误的时候只能强制退出执行,所以我们必须自己注册一个error事件,以致于在发生错误的时候触发到error事件

     const EventEmitter=require('events');
     const MyEventEmitter=new EventEmitter();
     MyEvenEmitter.on('error',(err)=>{
       console.error(err,'报错了')
     })

    除了上面那种方式我们还可以通过errorMonitor在不注册error事件的情况下,来监听emit触发的报错 使用了errorMonitor我们就不必要再去通过手动注册error事件了

      const {EventEmitter,errorMonitor}=require('events');
      const MyEventEmitter=new EventEmitter();
      MyEventEmitter.on(errorMonitor,(err)=>{
          console.log(err);
      })
      MyEventEmitter('error' , new Error('报错了'))

    EventEmitter类

    newListener事件

    在我们添加事件监听的时候会触发newListener事件,所以我们可以注册newListener事件用来在添加事件监听的时候做一些事情

     const {EventEmitter}=require('events');
      const MyEvent=new EventEmitter();
      MyEvent.on('newListener',(name,litener)=>{
          //name就是正在监听的事件的名称
          //listener是事件的处理函数
          MyEvent.on('event',()=>{
            console.log('在newListener添加的事件')
          })  
      })
      MyEvent.on('event',()=>{
          console.log('正常注册的event事件')
      })
      //此时我们再不触发event事件的情况下,newListener事件就会执行,因为我们只要正在注册事件就会触发newListener事件
      //注意:newListener事件必须要使用EventEmitter.once()注册,因为如果我们在newListener事件里再去添加注册事件的话,而且外边有多个注册事件就会触发多次newListener事件,就会发生堆栈溢出
     MyEvent.emit('event');
    
     //打印的结果
       //    在newListener注册的事件
       //     正常注册的event事件

    removeListener事件

    removeListener事件用于删除已经注册的事件,但是,removeListener不会阻止掉正在被emit触发的事件

     const callbackB=()=>{
        console.log('B')
    }
    const callbackA=()=>{
        console.log('A')
        event.removeListener('data',callbackB)
    }
    event.on('data',callbackA)
    event.on('data',callbackB)
    
    event.emit('data'); //在执行callbackA的时候删除了data,但是不会阻止掉下一个emit的触发
    event.emit('data'); //在这里的时候才是真正被删除掉了

    addListener 和on的作用一样

    eventNames

    返回一个数组,数组里包含了所有已经注册的事件的名称

     const {EventEmitter} =require('events');
     const MyEvent=new EventEmitter();
     MyEvent.on('data',()=>{});
     MyEvent.on('finish',()=>{});
     console.log(MyEvent.eventNames());
     
     //打印结果
      ['data','finish']

    getMaxListeners

    返回可以注册的事件的最大数值,默认是10,如果超过10个会有警告 但是我们可以通过setMaxListener(20) 去进行修改

    const {EventEmitter} =require('events');
     const MyEvent=new EventEmitter();
     console.log(MyEvent.getMaxListener()); //10
     event.setMaxListener(20); 
     console.log(MyEvent.getMaxListener(20));

    listenerCount

    返回注册的事件的数量

     const {EventEmitter} =require('events');
     const MyEvent=new EventEmitter();
     MyEvent.on('data',()=>{});
     MyEvent.on('data',()=>{});
     MyEvent.on('finish',()={});
     console.log(MyEvent.listenerCount()) // 2

    更多node相关知识,请访问:nodejs 教程

    以上就是深入聊聊node.js中的EventEmitter的详细内容,更多请关注php中文网其它相关文章!

    声明:本文转载于:掘金社区,如有侵犯,请联系admin@php.cn删除
    专题推荐:Node.js nodejs node
    上一篇:一文掌握JavaScript对象 下一篇:Angular知识点分享:聊聊表单、管道、绑定、指令、通信和周期
    VIP课程(WEB全栈开发)

    相关文章推荐

    • 【腾讯云】年中优惠,「专享618元」优惠券!• 什么是node转发• node中fs是内置模块吗• 浅析利用node怎么获取mac系统版本• node爬取数据实例:聊聊怎么抓取小说章节• 什么是流(Stream)?如何理解Nodejs中的流• Vercel是什么?怎么部署Node服务?
    1/1

    PHP中文网