function Msg(name, data) { this.name = name;// 消息标识名称,不同的消息应该不同的名称 this.data = data;// 消息携带的数据,格式不限制 } function Listener(keys, callback) { if (typeof keys === "string") { this.keys = keys.split(‘-‘); } else { this.keys = keys;// 监听的消息关键字,也就是消息的唯一标识,keys的顺序不代表事件发生的顺序 } this.callback = callback;// 当满足消息条件的时候,出发的回调 this.msgs = {};// 因为需要监听多个消息,因此这里的会有一个队列,存储感兴趣的消息 } // 匹配 Listener.prototype.match = function(msg/* Msg */) {// 简单的名字相等规则 var i = 0, len = this.keys.length; for (; i < len; i++) { if (this.keys[i] == msg.name) {// 中 this.msgs[msg.name] = msg; } } this.fire(); }; Listener.prototype.fire = function() { var i = 0, len = this.keys.length, key; for (; i < len; i++) { key = this.keys[i]; if (!this.msgs.hasOwnProperty(key)) {// 如果有这个属性,那么说明消息已经达到 return false; } } // 调用callback var msgs = this.msgs; this.msgs = {}; this.callback.call(undefined,msgs); }; // 一个页面只需要一个消息中心(大型的单页应用也许不是很适合) // 消息中心用来匹配消息和函数回调 function MsgCenter() { this.listeners = []; } MsgCenter.prototype.push = function(name, data) { var i = 0, len = this.listeners.length, msg = new Msg(name, data); for (; i < len; i++) { this.listeners[i].match(msg); } }; MsgCenter.prototype.on = function(keys, callback) { this.listeners.push(new Listener(keys, callback)); };
时间: 2024-10-12 14:17:02