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>