68 lines
1.4 KiB
JavaScript
68 lines
1.4 KiB
JavaScript
/** 使用方法
|
||
* 页面引入
|
||
* import Utils from '@/jsFile/tools/observer.js';
|
||
*
|
||
* 使用
|
||
* // 订阅消息
|
||
* Utils.subscribe('test', function (e) {
|
||
* console.log(e);
|
||
* });
|
||
* setTimeout(()=>{
|
||
* // 发布消息
|
||
* Utils.publish('test', {
|
||
* msg: '参数'
|
||
* });
|
||
* },3000)
|
||
*/
|
||
|
||
|
||
/*
|
||
* 发布-订阅模式（观察者模式）
|
||
* */
|
||
|
||
export const Observer = (function() {
|
||
let messages = {}; // 消息队列
|
||
|
||
return {
|
||
// 订阅消息
|
||
subscribe(type, fn) {
|
||
// 消息不存在，创建消息执行队列
|
||
if (typeof messages[type] === 'undefined') {
|
||
messages[type] = [fn];
|
||
}
|
||
// 消息存在，将执行动作推进消息执行队列
|
||
else {
|
||
messages[type].push(fn);
|
||
}
|
||
},
|
||
// 发布消息
|
||
publish(type, args) {
|
||
// 如果消息未被注册，返回false
|
||
if (!messages[type]) return false;
|
||
// 定义消息信息
|
||
let events = {
|
||
type: type, // 消息类型
|
||
args: args || {} // 消息携带数据
|
||
};
|
||
for (let i = 0; i < messages[type].length; i++) {
|
||
// 执行动作
|
||
messages[type][i].call(this, events)
|
||
}
|
||
},
|
||
// 删除消息
|
||
remove(type, fn) {
|
||
// 消息队列存在
|
||
if (messages[type] instanceof Array) {
|
||
// 从最后一个消息动作遍历
|
||
let i = messages[type].length - 1;
|
||
for (; i >= 0; i++) {
|
||
// 存在该消息动作，则移除
|
||
messages[type][i] === fn && messages[type].splice(i, 1);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
})();
|
||
|
||
export default Observer;
|