Events：玩转EventEmitter

基础用法

• 再此提到使用util.inherits从原型类继承在Node中是地道的做法。

  util.inherits是通过封装ES5的Object.create方法来实现的，它通过从一个原型到另外一个原型继承属性的方式来实现。Node中还将父类的构造函数保存在super_ 属性中。这使得调用父类构造函数变得简单许多。在使用util.inherits之后，你的原型类可以通过YourClass.super_调用EventEmitter。

  var util = require('util');
  var events = require('events');
      
  function MusicPlayer() {
      events.EventEmitter.call(this);
  }
      
  util.inherits(MusicPlayer, events.EventEmitter);
  

  构造函数中call(this)，主要是想使用eventEmitter的domain。domain是捕获最近的异常错误的方法，以至于不被冒泡到最上面被捕获。

• EventEmitter对象方法：

  • on(event, listener)：注册事件监听器。
  • once(event, listener)：一次性的监听器，监听一次后会立即解除这个监听器。
  • removeListener(event, listener)：移除指定事件的某个监听器，这个监听器必须是注册过得。
  • removeAllListeners([event])：移除所有事件的所有监听器，如果指定事件则移除指定事件的所有监听器。
  • setMaxListeners(n)：默认情况下， EventEmitters 如果你添加的监听器超过 10 个就会输出警告信息。 setMaxListeners 函数用于提高监听器的默认限制的数量。
  • listeners(event)：返回指定事件的监听器数组。
  • emit(event, [arg1], [arg2], [...])：按参数的顺序执行每个监听器，如果事件有注册监听返回true，否则返回false。

• 提到的两种思路：

  • 将需要监听的类从EventEmitter类继承获得相应的特性。
  • 混合EventEmitter：拷贝EventEmitter的属性。

  for （var methodName in EventEmitter.prototype) {
      this[methodName] = EventEmitter.prototype[methodName]
  }
  

异常处理

• 当一个EventEmitter实例发生错误时，通常会发出一个error事件。在Node中，error事件被当做特殊的情况，假如没有监听器，那么默认的动作是打印一个堆栈并退出程序。
• domain对象方法：
  • domain.create()：返回一个domain对象
  • domain.run(fn)：在domain上下文中执行一个函数，并隐式绑定所有事件，定时器和低级的请求。
  • domain.members：已加入domain对象的域定时器和事件发射器的数组。
  • domain.add(emitter)：显式的增加事件
  • domain.remove(emitter)：删除事件
  • domain.bind(callback)：以return为封装callback函数
  • domain.intercept(callback)：同domain.bind，但只返回第一个参数
  • domain.enter()：进入一个异步调用的上下文，绑定到domain
  • domain.exit()：退出当前的domain，切换到不同的链的异步调用的上下文中。对应domain.enter()
  • domain.dispose()：释放一个domain对象，让node进程回收这部分资源
• domain在使用时需要包含一些关键对象。

高级模式

• 通过监听newListener事件，可以知道一个监听器何时被添加到一个emitter上。

  eventTracker.on('newListener', function(name, listener) {
      console.log('Event name added:', name);
  });
  

• 在项目中多个模块之间的通信（以express的app对象为例）

  var express = require('express');
  var app = express();
  
  app.on('hello-alert', function() {
      console.warn('Warning!');
  })
  
  app.get('/', function(req, res) {
      res.app.emit('hello-alert');
      res.send('hello-world');
  })
  
  app.listen(3000);
  

  app对象在res.app中也是可以获得的。

• 当项目中存在很多事件的时候，组织事件名称的方法：使用对象组织管理事件名称。

  var e = MusicPlayer.events = {
      play: 'play',
      pause: 'pasuse',
      stop: 'stop',
      ff: 'ff',
      rw: 'rw',
      addTrack: 'add-track'
  };
  

第三方模块以及扩展（消息系统）

后面补坑消息系统

• rabbitMQ：

  首先需要了解AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。

  AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。

  RabbitMQ是一个开源的AMQP实现，服务器端用Erlang语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。

• zeroMQ

• Redis pub/sub API

• js-signal