发布\订阅模式:
在软件架构中，发布-订阅是一种消息范式，消息的发送者（称为发布者）不会将消息直接发送给特定的接收者（称为订阅者）。而是将发布的消息分为不同的类别，无需了解哪些订阅者（如果有的话）可能存在。同样的，订阅者可以表达对一个或多个类别的兴趣，只接收感兴趣的消息，无需了解哪些发布者（如果有的话）存在。 有着松耦合、可拓展性强等优点。
这里是一个pub/sub的简单实现:
class EventEmitter {
constructor(){
//observers是一个对象，形式如下：
// {
// chA: [fnA1, fnA2, ...],
// chB: [fnB1, fnB2, fnB3, ...]
// }
// 其中 chA，chB，对应不同频道， fn是每个频道 里面的回调函数
// 订阅、发布： 其实就是往 observers 里面写入回调函数（fn）, 以及遍历执行回调函数的过程（fn（arg））
// 订阅 : on('foo', fn)表示 订阅了 频道 foo ，如果 foo频道有消息推送， 就触发回调函数
// 发布： trigger('foo', 'hello')表示 发送一条消息 hello 到 foo 频道，
// 这样 订阅了 foo频道的所有 订阅者 都可以接收到 其数据
this.observers = {}
}
on(channel, f) {
let key = channel
if (Array.isArray(this.observers[key])) {
this.observers[key].push(f)
} else {
this.observers[key] = [f]
}
}
trigger(channel, ...args) {
let _observer = this.observers[channel]
if (!_observer || _observer.length === 0) {
return
}
for (let fn of _observer) {
fn(...args)
}
}
off(channel) {
this.observers[channel] = null
}
}
// 其使用 方式如下
var e = new EventEmitter()
e.on('a', (data) => {
console.log('a data', data)
})
e.on('b', (data) => {
console.log('b data', data)
})
e.trigger('a', 'hello')
e.trigger('b', {
x: 2,
y: 3
})
e.off('a')
结论：
发布\订阅模式的实现很简单， 主要有三部分构成：
- 一个消息中心：observers 用于存储每个订阅的回调函数
- 一个订阅函数： on 用于往 消息中心写入对应频道的监听回调函数
- 一个发布函数：trigger 发布消息， 触发对应频道的所有回调函数，并将数据作为回调函数的参数 传给了订阅者
