首页 > 代码库 > 一个简单消息中心,实现回调的扁平化
一个简单消息中心,实现回调的扁平化
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)); };
一个简单消息中心,实现回调的扁平化
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。