观察者模式的思考

🕗 发布于 2024-10-16 11:08 观察者模式 java 数据库

观察者模式由来

观察者模式（Observer Pattern）是一种行为型设计模式，它的起源可以追溯到20世纪90年代初，由设计模式四人帮（Erich Gamma, Richard Helm, Ralph Johnson 和 John Vlissides）在其著作《设计模式：可复用面向对象软件的基础》中首次提出。观察者模式用于解决对象之间的一对多依赖关系，当一个对象（被观察者）的状态发生改变时，所有依赖于它的对象（观察者）都会得到通知并自动更新。

概念

被观察者（Subject）：定义一个接口，用于添加、删除和通知观察者。
观察者（Observer）：定义一个接口，用于接收被观察者的通知并执行相应的操作。
具体被观察者（ConcreteSubject）：实现被观察者接口，维护观察者列表，并在状态改变时通知所有观察者。
具体观察者（ConcreteObserver）：实现观察者接口，具体实现接收到通知后的操作。

请在此添加图片描述

实现原理

观察者模式的核心原理是通过将对象间的依赖关系从硬编码转移到外部，使得一个对象（被观察者）可以在不通知其他对象的情况下更改其状态，然后在适当的时候通知所有依赖于它的对象（观察者）。这种解耦的设计方式使得代码更加灵活，易于扩展和维护。

我有一个朋友张三，他总是关心天气情况，每天会看天气预报，在这个过程中，天气预报（被观察者）和张三（观察者）之间就会存在一种依赖关系。当天气预报发生变化时，张三需要得到通知并及时更新自己的信息。

定义角色：

被观察者（Subject）：天气预报。它包含了当前的天气状况以及未来一段时间内的天气预报信息。
观察者（Observer）：张三。他是一个依赖于天气预报信息的用户。

建立依赖关系：

张三订阅了天气预报服务，这样当他打开电视或查看手机时，就能接收到最新的天气预报信息。

事件通知机制：

天气预报服务会在天气状况发生变化时，或者新的预报信息生成时，触发通知机制。这个机制负责将最新的天气信息发送给所有订阅了服务的用户，包括张三。

更新策略：

张三在接收到天气预报信息后，会根据信息的内容更新自己的认知，比如决定是否要带伞、穿什么衣服等。

动态加入和退出：

如果张三决定不再订阅天气预报服务，他可以随时取消订阅。同样，如果张三从一个城市搬到另一个城市，他可以订阅新的城市的天气预报服务。

技术实现

首先，我们定义一个Subject接口和一个Observer接口：

// 被观察者
public interface Subject {
    void registerObserver(Observer observer);
    void removeObserver(Observer observer);
    void notifyObservers();
}

// 观察者
public interface Observer {
    void update(String message);
}

然后，我们创建一个WeatherForecast类作为被观察者，实现Subject接口：

import java.util.ArrayList;
import java.util.List;

public class WeatherForecast implements Subject {

    private List<Observer> observers = new ArrayList<>();
    private String message;

    public void setMessage(String message) {
        this.message = message;
        notifyObservers();
    }

    @Override
    public void registerObserver(Observer observer) {
        observers.add(observer);
    }

    @Override
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }

    @Override
    public void notifyObservers() {
        for (Observer observer : observers) {
            observer.update(message);
        }
    }
}

接下来，我们创建一个WeatherWatcher类作为观察者，实现Observer接口：

public class WeatherWatcher implements Observer {

    private String name;

    public WeatherWatcher(String name) {
        this.name = name;
    }

    @Override
    public void update(String message) {
        System.out.println(name + " received weather forecast: " + message);
    }
}

最后，我们在主函数中创建一个WeatherForecast对象和两个WeatherWatcher对象，并让它们订阅天气预报：

public static void main(String[] args) {
        WeatherForecast weatherForecast = new WeatherForecast();
        WeatherWatcher watcher1 = new WeatherWatcher("张三");
        WeatherWatcher watcher2 = new WeatherWatcher("李四");

        weatherForecast.registerObserver(watcher1);
        weatherForecast.registerObserver(watcher2);

        weatherForecast.setMessage("今天天气晴朗，温度适中。");
        weatherForecast.setMessage("明天将会有大雨，请携带雨具。");
}

运行这个程序，你会看到张三和李四都收到了天气预报的通知。

请在此添加图片描述

Spring 实现

定义事件类：首先，我们需要定义一个事件类，它将携带被观察者状态变化的信息。

package com.neo.design.observer;

import org.springframework.context.ApplicationEvent;

public class WeatherEvent extends ApplicationEvent {

    private String weatherInfo;

    public WeatherEvent(Object source, String weatherInfo) {
        super(source);
        this.weatherInfo = weatherInfo;
    }

    public String getWeatherInfo() {
        return weatherInfo;
    }
}

创建事件发布者：接下来，我们创建一个事件发布者，它将负责发布天气变更事件。在这个例子中，我们将使用Spring的ApplicationEventPublisher来发布事件。

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Component;

@Component
public class WeatherEventPublisher {
    private final ApplicationEventPublisher publisher;

    public WeatherEventPublisher(ApplicationEventPublisher publisher) {
        this.publisher = publisher;
    }

    public void publishWeatherChangeEvent(String message) {
        publisher.publishEvent(new WeatherChangeEvent(message));
    }
}

创建事件监听器：然后，我们创建一个事件监听器，它将实现ApplicationListener接口，并重写onApplicationEvent方法。在这个方法中，我们将处理天气变更事件，并通知相关的观察者。

package com.neo.design.observer;

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Component;

@Component
public class WeatherEventPublisher {

    private final ApplicationEventPublisher publisher;

    public WeatherEventPublisher(ApplicationEventPublisher publisher) {
        this.publisher = publisher;
    }

    public void publishWeatherChangeEvent(String message) {
        publisher.publishEvent(new WeatherChangeEvent(message));
    }
}

创建用户服务：我们还需要创建一个用户服务，它将负责管理用户的订阅信息，并在接收到天气变更事件时通知用户。

package com.neo.design.observer;

import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;

@Service
public class UserService {

    private final List<String> subscribers = new ArrayList<>();

    public void subscribe(String subscriber) {
        subscribers.add(subscriber);
    }

    public void notifySubscribers(String message) {
        for (String subscriber : subscribers) {
            System.out.println(subscriber + " received weather forecast: " + message);
        }
    }
}

创建控制器：最后，我们创建一个控制器，它将接收用户订阅请求和天气变更请求，并调用相应的服务来处理这些请求。

package com.neo.design.observer;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class WeatherForecastController {

    @Autowired
    private UserService userService;

    @Autowired
    private WeatherEventPublisher publisher;

    @PostMapping("/subscribe")
    public String subscribe(@RequestParam("subscriber") String subscriber) {
        userService.subscribe(subscriber);
        return "Subscriber added!";
    }

    @PostMapping("/update-weather")
    public String updateWeather(@RequestParam("message") String message) {
        publisher.publishWeatherChangeEvent(message);
        return "Weather updated!";
    }
}

通过以上设计，我们利用Spring Boot的事件机制和依赖注入特性实现了一个高效的观察者模式。

验证

新增一名观察者

请在此添加图片描述

设定一个被观察者所关注的消息。

请在此添加图片描述

执行功能，返回测试结果如下

请在此添加图片描述

总结

观察者模式（Observer Pattern）在软件工程设计中扮演着重要角色，观察者模式实现了发布者（主题）和订阅者（观察者）之间的松散耦合。发布者无需知道具体的订阅者是谁，只需要维护一个订阅者列表，并在状态变化时通知它们。这种解耦使得系统更具灵活性和可扩展性。通过观察者模式，添加或移除订阅者非常容易，不需要修改发布者的代码。只需实现观察者接口并注册或取消注册即可。这使得系统在需求变化或扩展时更易于维护。它适用于各种需要实时更新和异步处理的场景，提升了系统的响应能力和用户体验，是设计模式中一个非常实用且常用的模式。

原文地址：https://blog.csdn.net/u012263509/article/details/142936001

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：代理设计模式
下一篇：Mybatis框架用到了哪些设计模式?

leetcode289:生命游戏
根据，简称为，是英国数学家约翰·何顿·康威在 1970 年发明的细胞自动机。给定一个包含m × n个格子的面板，每一个格子都可以看成是一个细胞。每个细胞都具有一个初始状态：1即为（live），或0即为
阅读更多2024-10-20
MongoDB数据恢复
注意：两个MongoDB的版本要一致，本文使用的是mongo:4.2.24。先把K8S上面的MongoDB 容器停止（可以把副本改成0）。1、将容器挂载MongoDB的数据目录备份到本地。经常是数据文
阅读更多2024-10-20
C#中实现事务
C#中实现事务
阅读更多2024-10-20
【LeetCode每日一题】——560.和为 K 的子数组
给你一个整数数组 nums 和一个整数 k ，请你统计并返回该数组中和为 k 的子数组的个数。子数组是数组中元素的连续非空序列。
阅读更多2024-10-20
「漏洞复现」满客宝智慧食堂系统 selectUserByOrgId 未授权访问漏洞
请勿利用文章内的相关技术从事非法测试，由于传播、利用此文所提供的信息而造成的任何直接或者间接的后果及损失，均由使用者本人负责，作者不为此承担任何责任。工具来自网络，安全性自测，如有侵权请联系删除。本次
阅读更多2024-10-20
React面试题目（从基本到高级）
React前端面试常见题目涵盖了React的基础概念、组件、状态管理、生命周期、性能优化等多个方面。
阅读更多2024-10-20
12.个人博客系统（Java项目基于spring和vue）
1 在校学习的学生，可用于日常学习使用或是毕业设计使用 2 毕业一到两年的开发人员，用于锻炼自己的独立功能模块设计能力，增强代码编写能力。 3 亦可以部署为商化项目使用。 4 需要完整资料及源码
阅读更多2024-10-20
YoloV8改进策略：注意力改进|DeBiFormer，可变形双级路由注意力|引入DeBiLevelRoutingAttention注意力模块（全网首发）
本次改进的核心在于将DeBiLevelRoutingAttention模块嵌入到YoloV8的主干网络中，具体位置是在SPPF（Spatial Pyramid Pooling Fast）模块之后。这一
阅读更多2024-10-20
word取消自动单词首字母大写
情况说明：在word输入单词后首字母会自动变成大写取消单词首字母大写步骤：（1）点击菜单栏文件（2）点击“更多”——>“选项”（3）点击“校对”——>“自动更正选项”（4）取消“句首字母大
阅读更多2024-10-20
web前端网页用户注册页面
【代码】web前端网页用户注册页面。
阅读更多2024-10-20

观察者模式的思考

观察者模式由来

概念

实现原理

技术实现

Spring 实现

验证

总结

相关文章