nodejs的大部分核心api都是基于异步事件驱动设计的，所有可以分发事件的对象都是eventemitter类的实例。
大家知道，由于nodejs是单线程运行的，所以nodejs需要借助事件轮询，不断去查询事件队列中的事件消息，然后执行该事件对应的回调函数，有点类似windows的消息映射机制。至于更细的实现环节，可以另行查找资料。
下面介绍eventemitter的使用。
1、监听事件和分发事件
eventemitter实例可以使用on或addlistener监听事件，emit()方法分发事件，如下所示：
const events = require('events'), eventemitter = events.eventemitter, util = require('util'); function myemiter(){ eventemitter.call(this); }; util.inherits(myemiter,eventemitter);//继承eventemitter类 const myemitterins = new myemiter(); myemitterins.on('data',(o)=>{ console.log('receive the data:'+o.a); });
或者使用class类
class myemiter extends eventemitter{}//继承eventemitter类 const myemitterins = new myemiter(); myemitterins.on('data',(o)=>{ console.log('receive the data:'+o.a); }); myemitterins.emit('data',{a:1});
执行结果如下：
e:\developmentdocument\nodejsdemo>node event-example.js
receive the data:1
2、向事件监听回调函数传递参数
从上面的例子可以看出，emit()方法可以传递任意的参数集合给回调函数，需要注意的一点是this关键字指向的是调用emit方法的eventemiter实例，但在箭头函数中例外，this指向的是全局this，因为箭头函数中的this是在定义时绑定。如下所示：
class myemiter extends eventemitter{} const myemitterins = new myemiter(); myemitterins.on('data',function(data){ console.log("普通回调函数中this："); console.log(this); }); myemitterins.on('data1',(data1)=>{ console.log("箭头回调函数中this："); console.log(this); }); myemitterins.emit('data',{a:1}); myemitterins.emit('data1',{a:1});
执行结果如下：
e:\developmentdocument\nodejsdemo>node event-example.js
普通回调函数中this：
myemiter {
domain: null,
_events: { data: [function], data1: [function] },
_eventscount: 2,
_maxlisteners: undefined }
箭头回调函数中this：
{}
这里讲到箭头函数中的this，就顺便说一下，为什么箭头函数能够实现定义时绑定this，就是因为箭头函数内部根本就没有绑定this的机制，它使用的是外层作用域的this，因此它也不能作为构造函数。
3、事件监听程序的执行顺序
eventemiter实例可以绑定多个事件，当我们顺序触发这些事件时，eventemiter会以同步模式执行，既第一个事件处理函数没有完成，便不会触发下一个事件，如下所示：
class myemiter extends eventemitter{} const myemitterins = new myemiter(); myemitterins.on('data',function(data){ console.time('data事件执行了'); for(var i = 0 ; i< 100000; i++) for(var j = 0 ; j< 100000; j++) ; console.timeend('data事件执行了'); }); myemitterins.on('data1',(data1)=>{ console.log("data1事件开始执行..."); }); myemitterins.emit('data',{a:1}); myemitterins.emit('data1',{a:1});
执行结果如下：
e:\developmentdocument\nodejsdemo>node event-example.js
data事件执行了: 4721.401ms
data1事件开始执行...
当然我们可以在回调函数中使用异步操作，例如settimeout，setimmediate或者process.nexttick()等，从而实现异步的效果，如下所示：
myemitterins.on('data',function(data){ setimmediate(()=>{ console.log('data事件执行了...'); }); });
执行结果如下：
e:\developmentdocument\nodejsdemo>node event-example.js
data1事件执行了...
data事件执行了...
4、一次性事件监听
eventemiter可以使用once监听某个事件，则该事件处理程序只会触发一次，之后emit该事件都会被忽略，因为监听程序被注销了，如下所示：
myemitterins.once('one',(data)=>{ console.log(data); }); myemitterins.emit('one','this is first call!'); myemitterins.emit('one','this is second call!');
执行结果如下：
e:\developmentdocument\nodejsdemo>node event-example.js
this is first call!
从上面的结果看出，'one'事件只执行了一次。
5、移除事件绑定
类似dom事件监听，eventemiter也可以移除事件绑定，利用removelistener(eventname,listener)方法解除某个事件的绑定，因此回调函数listener必须是命名函数，要不然找不到该函数，因为函数是引用型类型，就算函数体是一样，也不是同一个函数，如下所示：
myemitterins.on('data',function(e){ console.log(e); }); myemitterins.removelistener('data',function(e){ console.log(e); }); myemitterins.emit('data','hello data!'); function deal(e){ console.log(e); } myemitterins.on('data1',deal); myemitterins.removelistener('data1',deal); myemitterins.emit('data1','hello data1!');
执行结果如下：
e:\developmentdocument\nodejsdemo>node event-example.js
hello data!
e:\developmentdocument\nodejsdemo>
从执行结果可以看出，data事件使用的是匿名函数，因此没有被移除掉，而data1事件则成功解除绑定了。这里需要注意一点的是emit触发某个事件后，所有跟该事件绑定的回调函数都会被调用，即使你在某个回调函数中使用removelistener函数移除掉另一个回调也没有用，但是随后的事件队列是移除了该回调的。如下所示：
function dealdata1(e){ console.log('data事件执行了...a'); } myemitterins.on('data',function(e){ console.log(e); myemitterins.removelistener('data',dealdata1);//这里解除dealdata1的绑定 }); myemitterins.on('data',dealdata1); myemitterins.emit('data','data事件执行了...b'); /*执行结果为： data事件执行了...b data事件执行了...a */ //再次触发该事件时,dealdata1回调已经被解除绑定了 myemitterins.emit('data','data事件执行了...'); //data事件执行了... 另外可以使用removealllisteners()解除所有事件的绑定。
6、获取事件监听数量和监听函数
使用emitter.listenercount(eventname)函数获取指定事件的监听数量，函数emitter.listeners(eventname)则可以用来获取指定事件的所有监听函数，使用如下所示：
var cba = ()=>{}, cbb = ()=>{}; var emitter = new myemiter(); emitter.on('data',cba); emitter.on('data',cbb); console.log('emitter实例的data事件绑定了%d个回调函数',emitter.listenercount('data')); console.log('它们是：',emitter.listeners('data'));
执行结果如下：
e:\developmentdocument\nodejsdemo>node event-example.js
emitter实例的data事件绑定了2个回调函数
它们是： [ [function: cba], [function: cbb] ]
7、获取和设置emitter的最大监听数量
nodejs对同一事件的监听数量建议不宜超过10个，这个可以查看eventemitter.defaultmaxlisteners属性便可得知，如下所示：
console.log(eventemitter.defaultmaxlisteners);//结果为10个
emitter通过getmaxlisteners()方法获取最大监听数量以及setmaxlisteners(n)方法设置最大监听数量,如下所示：
var cba = ()=>{}, cbb = ()=>{}; var emitter = new myemiter(); emitter.setmaxlisteners(1); emitter.on('data',cba); emitter.on('data',cbb); console.log(emitter.getmaxlisteners());
执行结果如下：
e:\developmentdocument\nodejsdemo>node event-example.js
emitter的事件最大监听数是：1
(node:6808) warning: possible eventemitter memory leak detected. 2 data listener
s added. use emitter.setmaxlisteners() to increase limit
如上结果所示，如果设置了最大监听数量，则同一事件的监听最好不要超过该最大值，否则很可能发送内存泄漏。