观察者模式和发布订阅模式的区别

news/2024/4/22 7:16:34

从下图中可以看出,观察者模式中观察者和目标直接进行交互,而发布订阅模式中统一由调度中心进行处理,订阅者和发布者互不干扰。这样一方面实现了解耦,还有就是可以实现更细粒度的一些控制。比如发布者发布了很多消息,但是不想所有的订阅者都接收到,就可以在调度中心做一些处理,类似于权限控制之类的。还可以做一些节流操作。

二 概念上的区别

1.观察者模式,目标和观察者是基类,目标提供维护观察者的一系列方法,观察者提供更新接口。具体观察者和具体目标继承各自的基类,然后具体观察者把自己注册到具体目标里,在具体目标发生变化时候,调度观察者的更新方法。

比如有个“天气中心”的具体目标A,专门监听天气变化,而有个显示天气的界面的观察者B,B就把自己注册到A里,当A触发天气变化,就调度B的更新方法,并带上自己的上下文。

2.发布订阅,订阅者把自己想订阅的事件注册到调度中心,当该事件触发时候,发布者发布该事件到调度中心(顺带上下文),由调度中心统一调度订阅者注册到调度中心的处理代码。

比如有个界面是实时显示天气,它就订阅天气事件(注册到调度中心,包括处理程序),当天气变化时(定时获取数据),就作为发布者发布天气信息到调度中心,调度中心就调度订阅者的天气处理程序。

三、发布订阅模式简介

1)定义和原理
发布订阅模式是一种消息传递模式,其中发布者发布消息,而订阅者接收和处理这些消息。它是一种松耦合的通信方式,允许发布者和订阅者在不知道彼此存在的情况下进行通信。

发布订阅模式的原理基于消息队列或主题,发布者将消息发布到特定的消息队列或主题中,而订阅者可以订阅这些消息队列或主题以接收和处理消息。发布者和订阅者之间的通信是异步的,这意味着发布者发布消息后,订阅者可以在任何时候接收和处理消息。

发布订阅模式的核心思想是将发布者和订阅者解耦,使得它们可以独立地运行和扩展。这种解耦有助于提高系统的灵活性和可伸缩性,因为发布者和订阅者可以根据需要进行扩展和修改,而不会影响彼此的操作。

发布订阅模式在许多领域都有应用,如

  • 消息队列
  • 事件驱动架构
  • 实时数据更新
  • 消息推送

它是一种非常有用的通信模式,可以帮助开发人员构建高效、可靠和可扩展的系统。

2) 发布订阅模式的优势
发布订阅模式具有以下优势:
  1. 解耦:发布者和订阅者是松耦合的,它们可以独立地运行和扩展,而不会相互影响。
  2. 灵活性:发布者可以随时发布消息,而订阅者可以随时订阅和取消订阅消息,这使得系统更加灵活。
  3. 可伸缩性:发布者和订阅者可以根据需要进行扩展和修改,而不会影响彼此的操作。
  4. 异步通信:发布者和订阅者之间的通信是异步的,这意味着发布者发布消息后,订阅者可以在任何时候接收和处理消息。
  5. 消息过滤:订阅者可以根据自己的需求订阅特定的消息,从而实现消息过滤。
  6. 可靠性:发布订阅模式通常使用消息队列或主题来存储消息,这可以确保消息不会丢失,并且可以在订阅者不可用时进行存储。
  7. 分布式系统:发布订阅模式可以在分布式系统中使用,从而实现跨节点的通信。

 

四、发布订阅模式的实现

1)消息队列
发布订阅模式可以使用消息队列来实现。消息队列是一种存储和转发消息的技术,它可以在发布者和订阅者之间提供异步通信。

在发布订阅模式中,发布者将消息发布到消息队列中,而订阅者可以从消息队列中接收和处理消息。消息队列可以作为发布者和订阅者之间的中间件,它可以确保消息的可靠性和有序性。

使用消息队列实现发布订阅模式的步骤如下:

  1. 创建消息队列:创建一个消息队列来存储和转发消息。
  2. 发布消息:发布者将消息发布到消息队列中。
  3. 订阅消息:订阅者订阅消息队列以接收和处理消息。
  4. 处理消息:订阅者从消息队列中接收消息并进行处理。

在实现发布订阅模式时,需要考虑以下几个方面:

  1. 消息队列的选择:根据需求选择合适的消息队列,如 RabbitMQ、Kafka 等。
  2. 消息的格式:定义消息的格式,以便发布者和订阅者能够理解和处理消息。
  3. 消息的发布和订阅:确定发布者和订阅者如何发布和订阅消息。
  4. 消息的处理:订阅者需要根据自己的需求处理消息,如数据处理、日志记录等。
  5. 消息的可靠性:考虑如何确保消息的可靠性,如消息确认、消息重试等。
  6. 消息的有序性:考虑如何确保消息的有序性,如消息排序、消息分组等。

总之,使用消息队列实现发布订阅模式可以提供高效、可靠和可扩展的通信方式。在实现时,需要根据具体需求进行选择和配置。

2)发布订阅者
在发布订阅模式中,发布者和订阅者是两个独立的实体,它们通过某种通信渠道(如消息队列)进行交互。

发布者负责将消息发布到通信渠道中,而订阅者则负责从通信渠道中接收和处理消息。发布者和订阅者之间的通信是异步的,这意味着发布者发布消息后,订阅者可以在任何时候接收和处理消息。

以下是使用发布订阅模式实现发布者和订阅者的基本步骤:

  1. 创建通信渠道:创建一个消息队列或主题来存储和转发消息。
  2. 发布消息:发布者将消息发布到通信渠道中。
  3. 订阅消息:订阅者订阅通信渠道以接收和处理消息。
  4. 处理消息:订阅者从通信渠道中接收消息并进行处理。

在实现发布订阅模式时,需要考虑以下几个方面:

  1. 通信渠道的选择:根据需求选择合适的通信渠道,如消息队列、主题等。
  2. 消息的格式:定义消息的格式,以便发布者和订阅者能够理解和处理消息。
  3. 消息的发布和订阅:确定发布者和订阅者如何发布和订阅消息。
  4. 消息的处理:订阅者需要根据自己的需求处理消息,如数据处理、日志记录等。
  5. 消息的可靠性:考虑如何确保消息的可靠性,如消息确认、消息重试等。
  6. 消息的有序性:考虑如何确保消息的有序性,如消息排序、消息分组等。
  7. 总之,发布订阅模式实现发布者和订阅者之间的通信,提供了一种高效、可靠和可扩展的通信方式。在实现时,需要根据具体需求进行选择和配置。
3)消息主题
在发布订阅模式中,消息主题是用于发布和订阅消息的标识符。它是发布者和订阅者之间的桥梁,用于定义订阅者感兴趣的消息类型。

以下是使用消息主题实现发布订阅模式的基本步骤:

  1. 创建消息主题:创建一个唯一的消息主题来标识要发布的消息类型。
  2. 发布消息:发布者将消息发布到特定的消息主题中。
  3. 订阅消息:订阅者订阅特定的消息主题以接收和处理消息。
  4. 处理消息:订阅者从订阅的消息主题中接收消息并进行处理。

在实现发布订阅模式时,需要考虑以下几个方面:

  1. 消息主题的设计:设计合适的消息主题,以便发布者和订阅者能够理解和处理消息。
  2. 消息的发布和订阅:确定发布者和订阅者如何发布和订阅消息主题。
  3. 消息的处理:订阅者需要根据自己的需求处理消息,如数据处理、日志记录等。
  4. 消息的可靠性:考虑如何确保消息的可靠性,如消息确认、消息重试等。
  5. 消息的有序性:考虑如何确保消息的有序性,如消息排序、消息分组等。

总之,消息主题是发布订阅模式中的重要概念,用于定义发布者和订阅者之间的通信。在实现时,需要根据具体需求进行选择和配置。

五、发布订阅模式的

  1. 应用场景
  2. 实时数据更新
  3. 消息推送
  4. 事件驱动架构
  5. 注意事项
  6. 消息丢失和重复
  7. 消息顺序问题
  8. 消息过期问题

六 总结

1. 最大的区别是调度的地方。

虽然两种模式都存在订阅者和发布者(具体观察者可认为是订阅者、具体目标可认为是发布者),但是观察者模式是由具体目标调度的,而发布/订阅模式是统一由调度中心调的,所以观察者模式的订阅者与发布者之间是存在依赖的,而发布/订阅模式则不会。2. 两种模式都可以用于松散耦合,改进代码管理和潜在的复用。

七, 代码如下

观察者模式

// 观察者
class Observer {constructor() {}update(val) {}
}
// 观察者列表
class ObserverList {constructor() {this.observerList = []}add(observer) {return this.observerList.push(observer);}remove(observer) {this.observerList = this.observerList.filter(ob => ob !== observer);}count() {return this.observerList.length;}get(index) {return this.observerList(index);}
}
// 目标
class Subject {constructor() {this.observers = new ObserverList();}addObserver(observer) {this.observers.add(observer);}removeObserver(observer) {this.observers.remove(observer);}notify(...args) {let obCount = this.observers.count();for (let index = 0; index < obCount; index++) {this.observers.get(i).update(...args);}}
}

 发布/订阅模式

class PubSub {constructor() {this.subscribers = {}}subscribe(type, fn) {if (!Object.prototype.hasOwnProperty.call(this.subscribers, type)) {this.subscribers[type] = [];}this.subscribers[type].push(fn);}unsubscribe(type, fn) {let listeners = this.subscribers[type];if (!listeners || !listeners.length) return;this.subscribers[type] = listeners.filter(v => v !== fn);}publish(type, ...args) {let listeners = this.subscribers[type];if (!listeners || !listeners.length) return;listeners.forEach(fn => fn(...args));        }
}let ob = new PubSub();
ob.subscribe('add', (val) => console.log(val));
ob.publish('add', 1);

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.cpky.cn/p/8547.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈,一经查实,立即删除!

相关文章

二叉树入门算法题详解

二叉树入门题目详解 首先知道二叉树是什么&#xff1a; 代码随想录 (programmercarl.com) 了解后知道其实二叉树就是特殊的链表&#xff0c;只是每个根节点节点都与两个子节点相连而其实图也是特殊的链表&#xff0c;是很多节点互相连接&#xff1b;这样说只是便于理解和定义…

php命令行运行 逻辑运算符 多维数组

php命令行运行 1. 命令行的使用2. 逻辑运算符3. 多维数组 1. 命令行的使用 查看php的版本 php -v执行php代码 ➜ ~ php /Users/fanzhen/Documents/phpStudy/hd.php bool(false)2. 逻辑运算符 3. 多维数组 三维数组 取第零个元素 第0个元素的第一个数组

Vivado开发FPGA使用流程、教程 verilog(建立工程、编译文件到最终烧录的全流程)

目录 一、概述 二、工程创建 三、添加设计文件并编译 四、线上仿真 五、布局布线 六、生成比特流文件 七、烧录 一、概述 vivado开发FPGA流程分为创建工程、添加设计文件、编译、线上仿真、布局布线&#xff08;添加约束文件&#xff09;、生成比特流文件、烧录等步骤&a…

vue 非父子通信-event bus 事件总线

1.作用 非父子组件之间&#xff0c;进行简易消息传递。(复杂场景→ Vuex) 2.步骤 创建一个都能访问的事件总线 &#xff08;空Vue实例&#xff09; import Vue from vue const Bus new Vue() export default Bus A组件&#xff08;接受方&#xff09;&#xff0c;监听Bus的…

51_蓝桥杯_led流水灯

一 原理图分析 二 三八译码器工作原理 三八译码器&#xff1a;3个输入控制8路互斥的低电平有效输出。 C B A 输出 0 0 0 Y0 0 0 1 Y1 0 1 0 Y2 0 1 1 Y3 1 0 0 Y4 1 0 1 Y5 1 1 0 Y6 1 1 1 Y7 三 锁存器工作原理 锁存器&#xff1a;当使…

vue如何动态加载显示本地图片资源

在实际开发中&#xff0c;根据某一个变量动态展示图片的情况有很多。实现方法分打包构建工具的差异而不同。 1、webpack的项目 require引入图片资源 2、vite的项目 new URL(url,base).href 疑问解答&#xff1a;为什么vite项目不可以用require&#xff1f; 原因在于&#xf…