js观察者模式发布/订阅
更新日期:
文章目录
实习期结束,最近回到学校开始学习node.js,node果然是强大。不过在涉及到文件操作的时候,发现要大量使用异步回掉操作。
以前在写页面的时候,从没这么多异步操作,只有在使用’setInterval’和’XMLHttpRequest’时了解了一下异步编程。这次在学习node的过程中,把异步回掉算是弄清楚了。但是在编码书写代码的时候,陷入了回调金字塔(callback hell)。使用es6Promise解决了一些问题。也看到了EventProxy模块基于事件驱动的解决方案。
在使用EventProxy的过程中,有种似曾相识的感觉。有点像观察者模式发布/订阅。首先使用数组缓存订阅者订阅的消息,当订阅者订阅消息的时候,把订阅的消息push到指定消息的队列中,当发布者发布消息的时候,我们遍历执行push到指定消息队列中的回调事件。
而订阅者不需要关心发布者什么时候发布消息。
而发布者不需要关心订阅者订阅的状态。
var observer = new Observe();
var callback = function(num) {
console.log("event:"+num); // 输出event:2
};
// 订阅消息
observer.listen("event1", callback);
observer.listen("event2", callback);
// 移除订阅消息1
observer.remove('event1', callback);
// 发布者发布消息
observer.trigger("event1",1);
observer.trigger("event2",2);
具体代码如下:
function Observe() {
// 缓存订阅者的消息队列
this._list = [];
}
/**
*
* 订阅者订阅消息
* @param {string} key 消息名
* @param {Function} fn 回调事件
* @return {Null}
*/
Observe.prototype.listen = function(key, fn) {
if (!this._list[key]) {
this._list[key] = [];
}
// 订阅消息,添加到缓存列表中
this._list[key].push(fn);
};
/**
*
* 移除订阅的消息
* @param {string} key 消息名
* @param {Function} fn 回掉事件
* @return {Null}
*/
Observe.prototype.remove = function(key, fn) {
// 获取当前key下的消息记录
var arrFn = this._list[key];
if (!arrFn) return false;
// 未指定fn则删除当前key下所有的订阅消息
if (!fn) {
arrFn.length = 0;
} else {
for (var i = 0; i < arrFn.length; i++) {
if (fn === arrFn[i]) {
arrFn.splice(i,1);
}
}
}
};
/**
* 发布者发布消息
* @param {string} key 消息名
* @param {string | Object} 消息数据
* @return {Null}
*/
Observe.prototype.trigger = function(key, aa) {
// 得到key,第二个及以上的参数
var key = Array.prototype.shift.call(arguments);
var args = arguments;
var arrFn = this._list[key];
if (!arrFn || arrFn.length === 0) {
return;
}
// 遍历执行当前key下面的所有消息
for (var i = 0; i < arrFn.length; i++) {
arrFn[i].apply(this, args);
}
};
关注我的微博:http://weibo.com/u/3059735367
关注我的cnblogs博客:http://www.cnblogs.com/Aralic