实现一个完整的发布订阅模式


前言

发布-订阅模式是我们经常会接触的到的设计模式,它定义一个对象间的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都将得到通知。在 JavaScript 开发中,我们一般用事件模型来替代传统的发布-订阅模式

现实生活中的发布订阅模式

毛小星是一个球鞋爱好者,他最近在逛淘宝的时候,看上了一双芝加哥配色的 AJ One 篮球鞋,但是问过客服美眉被告知,这个配色的鞋已经售罄了。好在客服美眉告诉毛小星,不久后耐克公司还会复刻一批芝加哥配色的球鞋,但是具体什么时候,目前还没有确切消息。
于是客服美眉告诉毛小星,只要收藏我们的店铺,一旦有新球鞋进货的时候,就立马发出消息通知毛小星。此时杨小A也想买一双球鞋,于是也按照客服美眉的建议收藏了店铺,耐心的等待球鞋进货的消息。
上面这个例子中,球鞋到货,自动发送消息通知就是一个典型的发布-订阅模式,毛小星、杨小A这两个购买者就是订阅者,他们收藏了店铺,店铺就作为发布者,在球鞋到货的时候就会给遍历收藏店铺的订阅者,然后给它们发送消息。
其实还有很多发布-订阅模式的应用场景,例如 Vue 的 EventBus,微前端中的两个子应用之间的通信。

发布-订阅模式的优点

  1. 支持简单的广播通信,当对象状态发生改变时,会自动通知已经订阅过的对象。买鞋的人不用再给天天给客服美眉发送消息了,一旦有鞋子,店铺会自动通知买家。

这个特性被广泛应用于异步编程中,这是一种替代传递回调函数的方案。比如,我们可以订阅 ajax 请求的 error、success等事件。或者如果想在动画的每一帧完成之后做一些事情,那我们可以订阅一个事件,然后在动画的每一帧完成之后发布这个事件。在异步编程中使用发布-订阅模式,我们就无需过多关注对象在异步运行期间的内部状态,而只需要订阅感兴趣的事件发生点。

  1. 发布者与订阅者耦合性降低,发布者只管发布一条消息出去,它不关心这条消息如何被订阅者使用,同时,订阅者只监听发布者的事件名,只要发布者的事件名不变,它不管发布者如何改变;同理卖家(发布者)它只需要将鞋子来货的这件事告诉订阅者(买家),他不管买家到底买还是不买,还是买其他卖家的。只要鞋子到货了就通知订阅者即可。

第二点说明发布-订阅模式可以去到对象之间的硬编码的通知机制,一个对象不用再显示的调用另外一个对象的某个接口。发布-订阅模式让两个对象松耦合得联系在一起,虽然不太清楚彼此的细节,但这不影响他们之间互相通信。当有新的订阅者出现时,发布者的代码不需要任何修改;同样发布者需要改变时,也不会影响到之前的订阅者。只要之前约定的事件名没有变化,就可以自由地改变它们。

发布-订阅模式的缺点

  1. 创建订阅者需要消耗一定的时间和内存。
  2. 虽然可以弱化对象之间的练习,但是如果过度使用的话,代码反而不太好理解和维护。特别是有多个发布者和订阅者的嵌套到一起的时候,要跟踪一个bug并不是一件轻松的事情。

实现一个通用的发布订阅模式

话不多说,直接上代码,不上代码的技术博客都是耍流氓!

// 定义事件中心类
class MyEvent {handlers = {} // 存放事件 map,发布者,存放订阅者$on(type, fn) {if (!Reflect.has(this.handlers, type)) { // 如果没有定义过该事件,初始化该订阅者列表this.handlers[type] = []}this.handlers[type].push(fn) // 存放订阅的消息}$emit(type, ...params) {if (!Reflect.has(this.handlers, type)) { // 如果没有该事件,抛出错误throw new Error(`未注册该事件${type}`)}this.handlers[type].forEach((fn) => { // 循环事件列表,执行每一个事件,相当于向订阅者发送消息fn(...params)})}$remove(type, fn) {if (!Reflect.has(this.handlers, type)) {throw new Error(`无效事件${type}`)}if (!fn) { // 如果没有传入方法,表示需要将该该类型的所有消息取消订阅return Reflect.deleteProperty(this.handlers, type)} else {const inx = this.handlers[type].findIndex((handler) => handler === fn)if (inx === -1) { // 如果该事件不在事件列表中,则抛出错误throw new Error('无效事件')}this.handlers[type].splice(inx, 1) // 从事件列表中删除该事件if (!this.handlers[type].length) { // 如果该类事件列表中没有事件了,则删除该类事件return Reflect.deleteProperty(this.handlers, type)}}}
}

参考文章:

  • Javascript中理解发布–订阅模式
  • JavaScript设计模式与开发实践

实现一个完整的发布订阅模式相关推荐

  1. 实现一个简单的发布订阅模式

    文章目录 一.发布订阅模式是什么? 二.发布订阅模式的优缺点 三.实现一个通用的发布订阅模式 一.发布订阅模式是什么? 发布订阅模式是对象间的一种一对多的关系,由发布者.订阅者.消息管理器三部分组成, ...

  2. 每日学习一个设计模式--观察者模式(发布-订阅模式)

    定义 观察者(Observer)模式的定义:指多个对象间存在一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新.这种模式有时又称作发布-订阅模式.模型-视图模式,它 ...

  3. 从东京奥运会看js设计模式之发布订阅模式

    开篇废话:本篇文章介绍发布-订阅模式,想必很多人听说过有一种观察者模式,网上既有资料说这是两种不同的设计模式,也有说这是一种模式,我倾向于认同他们是同一种设计模式.不必过于纠结 开篇楔子:东京奥运会已 ...

  4. 【EventBus】发布-订阅模式 ( 使用代码实现发布-订阅模式 )

    文章目录 一.发布-订阅模式 二.代码实现发布-订阅模式 1.订阅者接口 2.订阅者实现类 3.发布者 4.调度中心 5.客户端 一.发布-订阅模式 发布订阅模式 : 发布者 Publisher : ...

  5. JavaScript设计模式之发布-订阅模式(观察者模式)-Part1

    <JavaScript设计模式与开发实践>读书笔记. 发布-订阅模式又叫观察者模式,它定义了对象之间的一种一对多的依赖关系.当一个对象的状态发生改变时,所有依赖它的对象都将得到通知. 例如 ...

  6. JavaScript 发布-订阅模式

    发布-订阅模式,看似陌生,其实不然.工作中经常会用到,例如 Node.js EventEmitter 中的 on 和 emit 方法:Vue 中的 $on 和 $emit 方法.他们都使用了发布-订阅 ...

  7. JavaScript中发布/订阅模式的理解

    订阅发布模式的介绍 发布订阅模式,它定义了一种一对多的关系,可以使多个观察者对象对一个主题对象进行监听,当这个主题对象发生改变时,依赖的所有对象都会被通知到. 在生活中我们常常遇到这样一种情况,我们在 ...

  8. 发布订阅模式,在工作中它的能量超乎你的想象

    不同的语言-相同的模式 最近在看设计模式的知识,而且在工作当中,做一些打点需求的时候,正好直接利用了发布订阅模式去实现的,这让我对发布订阅这种设计模式更加的感兴趣了,于是借此机会也和大家说说这个好东东 ...

  9. 手撕发布订阅模式 eventBus

    什么是发布订阅模式 比如我们很喜欢看某个公众号号的文章,但是我们不知道什么时候发布新文章,要不定时的去翻阅:这时候,我们可以关注该公众号,当有文章推送时,会有消息及时通知我们文章更新了. 上面一个看似 ...

最新文章

  1. 阿里云开源PolarDB数据库,与社区共建云原生分布式数据库生态
  2. Hybris CronJob.
  3. css中border制作各种形状
  4. 参会邀请 - CCKS2020 | 2020全国知识图谱与语义计算大会(CCKS2020)明日开幕
  5. 【学习笔记】数据链路层——轮询访问介质控制(轮询协议、令牌传递协议)
  6. Laravel Facades的实现原理
  7. 简易 Python 3 运行 Python 2 代码
  8. 华为网络计算机ct2000,2019-02-22 华为U2000 ESN查询及License加载
  9. 数据分析——泰坦尼克号乘客数据集
  10. uplift模型实战代码
  11. 电脑重置后需要清除tpm吗
  12. 为一加七Pro(LineageOs17.1 4.14内核版本)编译KernelSu
  13. 10个维修中最常见的蓝屏代码,值得收藏!
  14. OpenCV C++案例实战十八《抖音特效——“蓝线挑战”》
  15. xCAT安装配置文档
  16. 阿里云ECS端口无法访问问题解决
  17. 7月5日绝地求生服务器维护,7月5日绝地求生更新到几点 7月5日绝地求生更新时间及内容介绍...
  18. 使用HTML制作个人简历
  19. Codeforces Round #633 (Div. 2) C.Powered Addition
  20. Go基础天天练之通道

热门文章

  1. 文件导出传值的get和post方式的写法(无状态化,前端vue)
  2. VO高级使用技巧之一:可重写的重要的方法
  3. 然后是几点 (15 分)
  4. 教育部考试中心对于全国计算机等级考试无纸化考试的成绩评分标准,全国计算机等级无纸化考试说明...
  5. 一年之计在于春 给农业插上智慧翅膀
  6. 无奈的幸福——致所有无法过光棍节的男人
  7. 短视频运营推广有何意义?如何进行短视频推广?
  8. 基于STM32F407摄像头实验(有代码)
  9. STM32F407 HAL库外扩SRAM作为默认RAM使用
  10. assembly的概念