Node中大量运用了事件回调,所以Node对事件做了单独的封装。所有能触发事件的对象都是 EventEmitter
类的实例,所以上一篇我们提到的文件操作的可读流、可写流等都是继承了 EventEmitter
。当然我们也可以自定义具有事件行为的自定义对象,仅需要对其继承即可。
继承EventEmitter
node的events
模块封装了EventEmitter
类型,此类型里面封装了事件注册、触发等API。
// 引入events模块const EventEmitter = require('events'); class MyEmitter extends EventEmitter { constructor(opt) { super(opt); } } // 创建事件对象实例。 const myEmitter = new MyEmitter(); // 注册event事件,event是事件名字,最好符合以驼峰命名规范。 myEmitter.on('event', () => { console.log('触发了一个事件!'); }); // 触发event事件 myEmitter.emit('event');
给回调函数传递参数
emit()
方法触发事件的同时,还可以给回调函数传递参数。
// 引入events模块const EventEmitter = require('events'); class MyEmitter extends EventEmitter { constructor(opt) { super(opt); } } // 创建事件对象实例。 const myEmitter = new MyEmitter(); // 注册event事件,event是事件名字,最好符合以驼峰命名规范。 myEmitter.on('event', (a, b) => { console.log('event: %s, %s', a, b); }); // 触发event事件,并传递参数a、b myEmitter.emit('event', 'aicoder.com', '全栈实习');
错误处理的约定
当 EventEmitter 实例中发生错误时,会触发一个 'error' 事件。 这在 Node.js 中是特殊情况。
如果 EventEmitter 没有为 'error' 事件注册至少一个监听器,则当 'error' 事件触发时,会抛出错误、打印堆栈跟踪、且退出 Node.js 进程。
const myEmitter = new MyEmitter();myEmitter.emit('error', new Error('whoops!')); // 抛出错误,并使 Node.js 崩溃
为了防止 Node.js 进程崩溃,可以在 process
对象的 uncaughtException
事件上注册监听器.
const myEmitter = new MyEmitter();// 给nodejs的进程增加未捕获异常的处理,防止程序崩溃process.on('uncaughtException', (err) => { console.error('有错误'); }); myEmitter.emit('error', new Error('whoops!')); // 打印: 有错误
只处理事件一次
on()
方法可以注册事件处理程序,而且是每次emit()
触发事件,都会被执行。但是用once()
注册的事件,仅执行一次。例如:
// 引入events模块const EventEmitter = require('events'); class MyEmitter extends EventEmitter { constructor(opt) { super(opt); } } const myEmitter = new MyEmitter(); let m = 0; myEmitter.once('event', () => { console.log(++m); }); myEmitter.emit('event'); // 打印: 1 myEmitter.emit('event'); // 忽略
实战案例
做一个应用时,我们需要在应用启动之前或者启动之后,给其他的开发人员提供一些可以注册处理程序的钩子,可以用事件的方式实现。其实本质就是发布订阅模式。
'use strict';const EventEmitter = require('events'); class Application extends EventEmitter { constructor(opt) { super(opt); this.on('error', err => { console.log('应用程序出错了!'); }); } init() { // 触发预初始化事件 this.emit('preInit'); // ... 默认的初始化代码 // 初始化事件 this.emit('init'); } start() { // 初始化服务器 this.init(); } } /**/ var app = new Application(); app.on('init', () => { console.log('初始化!'); }); app.on('preInit', () => { console.log('pre init'); }); app.start();
总结
Node中的事件处理封装很简单易用,跟jQuery的事件系统非常类似。其实自己实现一套事件系统也不难,核心思想就是:发布订阅(观察者)模式。