观察者模式常常会和发布订阅模式一起哪来比较,它们二者同样重要。
直观的例子:
Vue 的双向绑定原理用到了发布订阅模式的思想;
在函数式编程中,广泛应用观察者设计模式思想。
但是,可能在平常,写业务代码,真实用到这两样设计思想的并不多,只好在做技术总结的时候复盘一下,温故再温故啦。(也有一种可能是:或许是运用还不是很熟,在有些场景,可以用到,但会忽视掉)
闲话少说,奥利给,冲它!!
简介
观察者模式和发布订阅模式的区别在于:
后者比前者多了一个中间商。
观察者模式:
- 观察者 Observer
- 被观察者 Subject
发布订阅模式:
- 订阅者 subscriber (类似于观察者)
- 发布者 publisher (类似于被观察者)
- 调度中心(中间商)
一图胜千言:
有了以上的基本认识,咱们再展开说说~~
观察者模式
观察者模式之前写过 juejin.cn/post/707289…,这里再优化下注解,并再封装一个 Observer 类,由此创建多个 Observer 实例:
class Subject{// 被观察者 constructor(){ this.observers=[] } add(observer){ this.observers.push(observer) } notify(newMsg){ this.observers.forEach(i=>i.consoleFn(newMsg)) } } class Observer{// 观察者 constructor(name){ this.name=name } consoleFn(newMsg){ console.log(newMsg + '======》》》'+ this.name +'收到了') } } let sub = new Subject() let observer1 = new Observer("观察者1") let observer2 = new Observer("观察者2") sub.add(observer1) // Observer1 观察 sub sub.add(observer2) // Observer2 观察 sub sub.notify("我是被观察者,我发布了一个信息!") // sub 发布消息 // 我是被观察者,我发布了一个信息!======》》》观察者1收到了 // 我是被观察者,我发布了一个信息!======》》》观察者2收到了
要点小结:
- 写一个 Subject 类,有:添加观察者 add、通知观察者 notify 方法(也可补充写删除观察者 del 方法);
- 写一个 Observer 类,打印出所接收到的信息;
- 实例化一个被观察者;
- 实例化一个或多个观察者;
- 用 add 方法进行绑定;
- 用 notify 方法进行通知;
发布订阅模式
发布订阅模式,就是比观察者模式多了一个“中间商”,也叫调度中心;
发布者 publisher == 被观察者 Subject
订阅者 subscriber == 观察者 Observer
调度中心 Event Channel,或者说是大家熟悉的 Vue 双向绑定中的 Dep,依赖管理中心、订阅中心
// 发布者 Publisher class Pub { constructor() { this.deps = []; } addDep(dep) { this.deps.push(dep); } publish(dep) { this.deps.forEach(item => item === dep && item.notify()); } } // 订阅者 Subscriber class Sub { constructor(val) { this.val = val; } update(callback) { callback(this.val) } } // 调度中心 class Dep { constructor(callback) { // 核心是这个 callback 函数; this.subs = []; this.callback = callback; } addSub(sub) { this.subs.push(sub); } notify() { this.subs.forEach(item => item.update(this.callback)); } } let pub = new Pub() // 实例化一个发布者 // 实例化一个调度中心,传入一个用于处理数据的函数; const dep1 = new Dep((data) => console.log('我是调度中心,我先把消息处理一下,然后发给 ===》》》', data)) let sub1 = new Sub("订阅者1") // 实例化订阅者1 let sub2 = new Sub("订阅者2") // 实例化订阅者2 pub.addDep(dep) // 发布者绑定调度中心 dep.addSub(sub1) // 调度中心添加订阅者1 dep.addSub(sub2) // 调度中心添加订阅者2 pub.publish(dep) // 发布者把消息推给调度者 // 我是调度中心,我先把消息处理下先 订阅者1 // 我是调度中心,我先把消息处理下先 订阅者2
要点小结:
- 写一个 Pub 发布者类,有添加调度中心 addDep,推送消息 publish 两个方法;
- 写一个 Sub 订阅者类,有获取信息 update 方法;
- 写一个 Dep 调度中心类,有添加订阅者 addSub,通知消息 notify 两个方法;
- 实例化发布者;
- 实例化 1 个或多个调度的对象;
- 实例化 1 个或多个订阅者对象;
- 发布者绑定调度中心;
- 调度中心绑定订阅者;
- 发布者发布消息;
由上面的例子可见,发布者不会把消息直接发给订阅者,而是会先发给调度中心,再由调度中心发给订阅者;
有小朋友就问了:不就比观察者模式多了个“中间商”,有这个必要吗??
答案是肯定的!当然有!!
观察者模式中,被观察者直接把消息发给观察者,这是强绑定的,作为观察者,只有我主动绑定了我要观察的对象,我才能知道它发的消息给我;
而在发布订阅模式中,发布者和订阅者是 完全解耦 的,作为发布者,我把消息发给调度中心之后,我就不用管了,我只负责发布消息,不管谁接收;同样,订阅者,只负责接收调度中心来的消息,不用管是哪个发布者发的;
高内聚、低耦合,是我们的最终追求!!
小结
观察者模式和发布订阅模式,想想还是挺有意思的;
为什么要这么演进,我尝试用一个实际生活场景解释 —— 领导的发言稿,要打印出来,供下面的同事学习;
做法1:没有任何设计思想时,每个人都去找领导要这个稿子的电子版,然后去打印;
做法2:用观察者模式设计思想,领导主动把这个电子稿以邮件形式群发给大家,让大家自行打印;如果稿件有内容变动的话,领导再主动推送给大家一份新的;
做法3:用发布订阅者模式设计思想,领导发给秘书,秘书再分发给大家;因为稿件可能存在部分敏感信息,需要经过处理,分发给不同的同事,比如某类员工只能看其中一部分内容;