《程序猿之设计模式实战

《程序猿之设计模式实战 · 观察者模式》

📢 大家好，我是【战神刘玉栋】，有10多年的研发经验，致力于前后端技术栈的知识沉淀和传播。 💗

🌻 CSDN入驻不久，希望大家多多支持，后续会继续提升文章质量，绝不滥竽充数，欢迎多多交流。👍

文章目录

- - 写在前面的话
  - 基础介绍
  - 代码实现
  - 观察者&发布订阅
  - 补充说明
  - 总结陈词

写在前面的话

本篇文章继续介绍一下观察者模式，这个在日常工作中接触还是挺多的，但和发布订阅模式又有什么不同呢？

相关文章：
《程序猿之设计模式实战 · 策略模式》
《程序猿之设计模式实战 · 装饰者模式》
《程序猿之设计模式实战 · 池化思想》

基础介绍

观察者模式（Observer Pattern）是一种行为设计模式，它定义了一种一对多的依赖关系，使得当一个对象的状态发生变化时，所有依赖于它的对象都会得到通知并自动更新。这种模式常用于实现事件处理系统。

主要角色：

主题（Subject）：被观察的对象，维护观察者的列表，并提供注册、注销观察者的方法。
观察者（Observer）：对主题的变化感兴趣的对象，定义一个更新接口，以便接收主题的通知。

观察者模式的日常应用场景：

事件处理系统：如 GUI 应用中的按钮点击、文本框输入等事件的处理。

消息推送：社交媒体应用中，当用户发布新内容时，所有关注该用户的用户都会收到通知。

股票市场：当股票价格变化时，所有订阅该股票的投资者都会收到更新。

天气监测：天气预报应用中，用户可以订阅天气变化的通知。

日志系统：在日志框架中，多个观察者可以监听日志事件并执行相应的处理（如写入文件、发送邮件等）。

代码实现

Spring的事件用法就是典型的观察者模式。

实现步骤：

Step1、创建自定义事件

public class CustomEvent extends ApplicationEvent {private String message;public CustomEvent(Object source, String message) {super(source);this.message = message;}public String getMessage() {return message;}
}

Step2、创建事件监听器

@Component
public class CustomEventListener {@EventListenerpublic void handleCustomEvent(CustomEvent event) {System.out.println("Received custom event - Message: " + event.getMessage());}
}

Step3、创建事件发布者

@Component
public class EventPublisher {private final ApplicationEventPublisher publisher;public EventPublisher(ApplicationEventPublisher publisher) {this.publisher = publisher;}public void publish(String message) {CustomEvent event = new CustomEvent(this, message);publisher.publishEvent(event);}
}

Step4、合适的位置触发一下事件，例如下方的服务初始化。

@Component
public class AppRunner implements CommandLineRunner {private final EventPublisher eventPublisher;@Autowiredpublic AppRunner(EventPublisher eventPublisher) {this.eventPublisher = eventPublisher;}@Overridepublic void run(String... args) throws Exception {eventPublisher.publish("Hello, Observer Pattern!");}
}

观察者&发布订阅

观察者模式和发布-订阅模式（Publish-Subscribe Pattern）有相似之处，但它们之间也存在一些关键的区别：

1、耦合度：

观察者模式：主题和观察者之间是直接的依赖关系。观察者需要知道主题的存在，并注册到主题中。

发布-订阅模式：发布者和订阅者之间是解耦的。发布者不需要知道任何订阅者的存在，反之亦然。它们通过一个中介（如消息代理）进行通信。

2、通信方式：

观察者模式：通常是同步的，观察者在主题状态变化时立即收到通知。

发布-订阅模式：可以是同步或异步的，发布者发布消息后，订阅者可以在稍后时间接收消息。

3、使用场景：

观察者模式：适用于一对多的关系，通常在同一个应用程序中使用。

发布-订阅模式：适用于分布式系统或微服务架构，允许不同的应用程序或服务之间进行通信。

总结：

观察者模式和发布-订阅模式都用于实现事件驱动的架构，但它们在耦合度、通信方式和使用场景上有所不同。选择哪种模式取决于具体的需求和应用场景。

补充说明

按前面内容所介绍的，好像发布订阅模式的使用场景更广，比如 RedisTemplate.convertAndSend 方法在 Spring 中用于将消息发送到 Redis 的某个频道。这种机制可以被视为一种发布-订阅模式的实现，而不是严格的观察者模式。又比如Kafka 中的生产者和消费者的交互属于典型的发布-订阅模式。

这里再分析比对一下两者。

发布-订阅模式

使用场景：适用于需要在不同组件之间进行松耦合通信的场景。比如，使用 Redis、Kafka 等消息中间件时，发布者和订阅者之间没有直接的依赖关系。

优点：可以轻松扩展，添加新的订阅者不需要修改发布者的代码，适合分布式系统。

观察者模式

使用场景：通常用于对象之间的直接关系，适合在同一应用程序内部进行事件通知。Spring 的事件机制就是一个典型的例子。

优点：实现简单，适合在内存中处理事件，适合小范围的事件传播。

总结一下：

发布-订阅模式：适合跨服务或组件的通信，使用消息中间件。

观察者模式：适合在同一应用程序内部的事件处理，使用 Spring 的事件机制。

这两种模式各有其适用场景，选择时可以根据具体需求来决定。