《深入浅出Node.js》：Node的异步I/O流程原理解析

// 定义发布/订阅对象
var ObserverEvent = (function (){    
    var cacheList = {},     // 缓存列表，存放已订阅的事件回调
       listen,             // 订阅命名事件和对应的事件回调
       trigger,            // 触发命名事件，必传第一个参数为事件的命名，其后参数为选传，数量不限，用于作为事件回调的实参传入
       remove;             // 取消命名事件订阅，并清除该命名事件对应的事件回调   listen = function( key, fn ){
       //如果还没有订阅过此命名事件，就给该命名事件创建一个数组型的缓存列表
       if( !cacheList[key] ){  
           cacheList[key] = [];
       }       //将对应的事件回调传入该命名事件的缓存列表中
       cacheList[key].push( fn );
   };   trigger = function(){
           // 取出事件命名
       var key = Array.prototype.shift.call( arguments ),
           // 取出该命名事件对应的事件回调缓存列表
           fns = cacheList[key];       // 如果没有订阅该命名事件或对应的事件回调缓存列表为空数组，则直接返回false
       if( !fns || fns.lenght === 0 ){
           return false;
       }       // 遍历该命名事件对应的事件回调缓存列表数组，对数组中的每个事件回调传入处理后的实参列表，然后执行
       for(var i=0; i<fns.length; i++){
           fns[i].apply( this, arguments );
       }
   };   remove = function( key, fn ){
       var fns = cacheList[key];       if( !fns || fns.length === 0 ){
           return false;
       }       if( !fn ){
           // 如果没有显式传入具体的事件回调函数，则清除该命名事件对应的所有事件回调缓存
           fns.length = 0;
       }else {
           for( var l=fns.length-1; l>=0; l-- ){
               var _fn = fns[l];
               if( _fn === fn ){
                   fns.splice( l, 1 );
               }
           }
       }
   };   return {
       cacheList,
       listen,
       trigger,
       remove    
}})()

// 定义发布订阅对象安装函数，该函数可以为指定对象安装发布-订阅功能
var installEvent = function( obj ){
    // 这里是将obj原型指向ObserverEvent的向下兼容写法，也可以使用Object.create(ObserverEvent)来实现
   for( var i in ObserverEvent ){
       obj[ i ] = ObserverEvent[ i ]    
    }
}

// 为pageData对象安装发布订阅功能
var pageData = {};
installEvent( pageData );

pageData.listen( "test", function(msg){
   console.log( msg );
} )

setTimeout( function(){
   pageData.trigger( "test", "发布-订阅模式测试成功！" )
}, 3000 )

// 在未被其他循环占用的情况下，3秒后打印字符串结果：
// 发布-订阅模式测试成功！