观察者设计模式（Observer Design Pattern）[论点:概念、组成角色、相关图示、示例代码、框架中的运用、适用场景]

news2024/9/21 15:51:28

文章目录

  • 概念
  • 组成角色
  • 相关图示
  • 示例代码
  • 框架中的运用
  • 适用场景

概念

        观察者设计模式（Observer Design Pattern）是一种行为型设计模式，它定义了一种对象间的一对多的依赖关系，让多个观察者对象同时监听某一个主题对象，当主题对象状态发生改变时，通知所有观察者对象，使它们能够自动更新。

组成角色

  1. 主题（Subject）：主题是一个抽象类或接口，它定义了添加、删除和通知观察者的方法。
  2. 具体主题（ConcreteSubject）：具体主题是主题接口的实现，它包含观察者列表和业务逻辑。当状态发生改变时，具体主题负责通知所有观察者。
  3. 观察者（Observer）：观察者是一个抽象类或接口，它定义了一个更新方法，用于接收主题的通知。
  4. 具体观察者（ConcreteObserver）：具体观察者是观察者接口的实现，它根据主题的通知来更新自己的状态。

相关图示

在这里插入图片描述

示例代码

        这个代码示例展示了观察者设计模式的基本实现。具体主题ConcreteSubject存储了观察者列表和当前状态，当状态发生改变时，它会通知所有注册的观察者。观察者ConcreteObserverA和ConcreteObserverB实现了观察者接口Observer，并在更新状态时输出相应的消息。在main方法中，我们创建了一个具体主题和两个具体观察者，将观察者添加到主题中，然后改变主题的状态并观察输出结果。当从主题中移除一个观察者后，再次改变主题状态，可以看到只有剩下的观察者接收到了通知。

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

// 主题接口
interface Subject {
    // 添加观察者
    void addObserver(Observer observer);
    // 移除观察者
    void removeObserver(Observer observer);
    // 通知所有观察者
    void notifyObservers();
}

// 具体主题
class ConcreteSubject implements Subject {
    // 存储观察者的列表
    private List<Observer> observers = new ArrayList<>();
    // 主题的状态
    private String state;

    // 设置状态并通知所有观察者
    public void setState(String state) {
        this.state = state;
        notifyObservers();
    }

    // 添加观察者到列表
    @Override
    public void addObserver(Observer observer) {
        observers.add(observer);
    }

    // 从列表中移除观察者
    @Override
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }

    // 通知所有观察者状态已改变
    @Override
    public void notifyObservers() {
        for (Observer observer : observers) {
            observer.update(state);
        }
    }
}

// 观察者接口
interface Observer {
    // 更新观察者状态
    void update(String state);
}

// 具体观察者A
class ConcreteObserverA implements Observer {
    // 当收到主题通知时，更新状态
    @Override
    public void update(String state) {
        System.out.println("ConcreteObserverA received new state: " + state);
    }
}

// 具体观察者B
class ConcreteObserverB implements Observer {
    // 当收到主题通知时，更新状态
    @Override
    public void update(String state) {
        System.out.println("ConcreteObserverB received new state: " + state);
    }
}

public class ObserverDemo {
    public static void main(String[] args) {
        // 创建具体主题
        ConcreteSubject subject = new ConcreteSubject();
        // 创建具体观察者A和B
        ConcreteObserverA observerA = new ConcreteObserverA();
        ConcreteObserverB observerB = new ConcreteObserverB();

        // 向主题添加观察者A和B
        subject.addObserver(observerA);
        subject.addObserver(observerB);

        // 改变主题状态并通知观察者
        subject.setState("New state 1");
        subject.setState("New state 2");

        // 从主题中移除观察者A
        subject.removeObserver(observerA);

        // 再次改变主题状态并通知观察者
        subject.setState("New state 3");
    }
}

运行结果
在这里插入图片描述

框架中的运用

在Spring框架中，观察者模式主要应用在事件处理机制中。Spring监听器主要涉及到以下几个构成部分：

  1. ApplicationEvent（事件）：
    ApplicationEvent是Spring中所有事件的基类，它继承自java.util.EventObject。自定义事件需要继承ApplicationEvent。当某个特定操作发生时，可以创建一个自定义的ApplicationEvent实例，并将其发布到整个应用程序。
  2. ApplicationListener（监听器）：
    ApplicationListener是一个泛型接口，泛型参数为继承自ApplicationEvent的类。监听器负责监听特定类型的事件。实现ApplicationListener接口的类需要实现onApplicationEvent()方法以处理对应的事件。当一个事件被发布时，关注该事件的监听器会收到通知，并执行onApplicationEvent()方法来处理事件。
  3. ApplicationEventPublisher（事件发布器）：
    ApplicationEventPublisher是一个接口，负责发布事件。它提供了publishEvent()方法，用于发布事件到整个应用程序。在Spring中，ApplicationContext实现了ApplicationEventPublisher接口，因此事件发布主要由ApplicationContext管理。
  4. ApplicationEventMulticaster（事件多播器）：
    ApplicationEventMulticaster是一个接口，负责将事件分发给关联的监听器。SimpleApplicationEventMulticaster是ApplicationEventMulticaster的一个默认实现。在Spring中，ApplicationEventMulticaster负责管理所有注册的ApplicationListener。当ApplicationEventPublisher发布事件时，ApplicationEventMulticaster会将事件分发给所有关注该事件的监听器。
  • org.springframework.context.ApplicationEvent:

ApplicationEvent是Spring事件模型的基类，它继承了java.util.EventObject。所有自定义事件需要继承ApplicationEvent类。

package org.springframework.context;

import java.util.EventObject;

public abstract class ApplicationEvent extends EventObject {
    private static final long serialVersionUID = 7099057708183571937L;
    private final long timestamp;

    public ApplicationEvent(Object source) {
        super(source);
        this.timestamp = System.currentTimeMillis();
    }

    public final long getTimestamp() {
        return this.timestamp;
    }
}
  • org.springframework.context.ApplicationListener:

ApplicationListener是一个泛型接口，它的泛型参数是一个继承自ApplicationEvent的类。它类似于观察者模式中的观察者。实现ApplicationListener接口的类需要实现onApplicationEvent()方法以处理事件。

package org.springframework.context;

import java.util.EventListener;

public interface ApplicationListener<E extends ApplicationEvent> extends EventListener {
    void onApplicationEvent(E event);
}
  • org.springframework.context.ApplicationEventPublisher:

ApplicationEventPublisher接口负责发布事件。它类似于观察者模式中的主题。实现该接口的类需要实现publishEvent()方法来发布事件。

package org.springframework.context;

public interface ApplicationEventPublisher {
    void publishEvent(ApplicationEvent event);
    void publishEvent(Object event);
}
  • org.springframework.context.event.SimpleApplicationEventMulticaster：

SimpleApplicationEventMulticaster是ApplicationEventMulticaster接口的一个实现。它负责将事件分发给关联的监听器。其主要方法是multicastEvent(ApplicationEvent)，该方法会遍历注册的监听器，并将事件分发给匹配的监听器。

package org.springframework.context.event;

public class SimpleApplicationEventMulticaster extends AbstractApplicationEventMulticaster {
    // ...

    @Override
    public void multicastEvent(final ApplicationEvent event, @Nullable ResolvableType eventType) {
        ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event));
        for (ApplicationListener<?> listener : getApplicationListeners(event, type)) {
            Executor executor = getTaskExecutor();
            if (executor != null) {
                executor.execute(() -> invokeListener(listener, event));
            } else {
                invokeListener(listener, event);
            }
        }
    }

    // ...
}
  • org.springframework.context.support.AbstractApplicationContext：

AbstractApplicationContext实现了ApplicationEventPublisher接口，因此在Spring中，事件发布主要由ApplicationContext管理。AbstractApplicationContext中的publishEvent(ApplicationEvent)方法会委托给ApplicationEventMulticaster进行事件的发布。

public abstract class AbstractApplicationContext extends DefaultResourceLoader
        implements ConfigurableApplicationContext {

    // ...

    @Override
    public void publishEvent(ApplicationEvent event) {
        publishEvent(event, null);
    }

    @Override
    public void publishEvent(Object event) {
        publishEvent(event, null);
    }

    protected void publishEvent(Object event, @Nullable ResolvableType eventType) {
        Assert.notNull(event, "Event must not be null");
        if (logger.isTraceEnabled()) {
            logger.trace("Publishing event in " + getDisplayName() + ": " + event);
        }

        // Decorate event as an ApplicationEvent if necessary
        ApplicationEvent applicationEvent;
        if (event instanceof ApplicationEvent) {
            applicationEvent = (ApplicationEvent) event;
        } else {
            applicationEvent = new PayloadApplicationEvent<>(this, event);
            if (eventType == null) {
                eventType = ((PayloadApplicationEvent) applicationEvent).getResolvableType();
            }
        }

        // Multicast right now if possible - or lazily once the multicaster is initialized
        if (this.earlyApplicationEvents != null) {
            this.earlyApplicationEvents.add(applicationEvent);
        } else {
            getApplicationEventMulticaster().multicastEvent(applicationEvent,
        eventType);
        }
          // 发布事件给父级 ApplicationContext
      	if (this.parent != null) {
            if (this.parent instanceof AbstractApplicationContext) {
                ((AbstractApplicationContext) this.parent).publishEvent(event, eventType);
            } else {
                this.parent.publishEvent(event);
            }
        }
		}
}
// ...

总之大概的逻辑是这样

  1. 创建自定义事件CustomEvent，该事件需要继承ApplicationEvent。

  2. 创建自定义事件监听器CustomEventListener，该监听器需要实现ApplicationListener<CustomEvent>接口。

  3. 在需要的地方使用ApplicationEventPublisher（通常是ApplicationContext）发布事件。在AbstractApplicationContext中，publishEvent方法会将事件委托给ApplicationEventMulticaster进行发布。

  4. SimpleApplicationEventMulticaster（默认的ApplicationEventMulticaster实现）会将事件分发给关联的监听器。在multicastEvent方法中，它会遍历所有注册的监听器，并将事件分发给匹配的监听器。

  5. 监听器收到事件后，将执行onApplicationEvent()方法处理事件。

        通过上述流程，我们可以看到Spring监听器执行原理是基于观察者设计模式的。当事件发布后，所有关注该事件的监听器都会收到通知并执行相应的操作。这种机制实现了松耦合的事件处理，可以在不同组件之间实现动态交互。

适用场景

  1. 事件处理系统：观察者模式可以用于实现事件驱动的架构，当一个事件发生时，所有关心这个事件的观察者都会收到通知。这在GUI开发、游戏开发等场景中非常常见。
  2. 数据绑定和同步：当多个组件需要共享或同步相同的数据时，可以使用观察者模式。当数据发生变化时，所有依赖于该数据的观察者都会收到通知并自动更新。这在前端开发、实时协同编辑等场景中非常有用。
  3. 消息发布和订阅：观察者模式可以用于实现发布/订阅系统。在这种系统中，发布者负责发布消息，订阅者负责订阅消息。当发布者发布新消息时，所有订阅了该消息的订阅者都会收到通知。这在分布式系统、消息队列、事件总线等场景中非常常见。
  4. 状态监控和报警：在系统监控和报警场景中，观察者模式可以用于实时监控被观察对象的状态。当被观察对象的状态发生异常时，观察者可以根据预定义的规则执行相应的操作，如发送报警邮件、记录日志等。

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

LLaMA模型文件 (搬运工)

LLaMA模型文件 (搬运工)

LLaMA需要进行申请才能获得官方模型权重。 但是申请的审批时间一般都很长。 这里提供现有的huggingface上&#xff0c;第三方上传的一些LLaMA模型文件&#xff1a; LLaMA-7BLLaMA-13BLLaMA-7B-hfLLaMA-13B-hf 这里要注意&#xff0c;原始的LLaMA权重文件&#xff0c;是不能…
阅读更多...
【Java面试八股文】SSM,SpringBoot篇

【Java面试八股文】SSM,SpringBoot篇

引言&#xff1a; 本文对多个平台的面试题进行了汇总、分类、概括、整理&#xff0c;对重点进行了标出&#xff0c;更便于阅读和记忆。 【黑马Java笔记踩坑汇总】JavaSEJavaWebSSMSpringBoot瑞吉外卖SpringCloud黑马旅游谷粒商城学成在线牛客面试题 目录 Spring 简单介绍Spri…
阅读更多...
ubuntu 20.04 安装obs 录屏软件

ubuntu 20.04 安装obs 录屏软件

obs是一个非常好用的录屏软件&#xff0c;我们在windows安装和使用是非常的简单&#xff0c;但是在ubuntu安装还是比较麻烦的&#xff0c;需要使用命令行&#xff0c;还需要很多的依赖。 修改源 deb http://archive.ubuntu.com/ubuntu/ focal main restricted universe multi…
阅读更多...
大白话告诉你！前端是怎么回事儿？

大白话告诉你！前端是怎么回事儿？

假期回家&#xff0c;学会计的表弟化身十万个为什么的问我&#xff01; 你们前端到底是干什么的&#xff1f;为什么我的同学好多转行去做这个的&#xff1f;你们前端程序员真的这么赚钱么&#xff1f;你也别跟我说什么敲代码的&#xff0c;你告诉我&#xff0c;你敲得这是什么代…
阅读更多...
Linux网络——部署YUM仓库

Linux网络——部署YUM仓库

Linux网络——部署YUM仓库 一、YUM仓库服务1.准备安装源&#xff1a;①.软件仓库的提供方式②.RPM软件包的来源③.构建CentOS7软件仓库④.在软件仓库中加入非官方RPM包组⑤.访问yum仓库 2.yum下载软件包的方式①..开启缓存下载②.通过yum命令的选项下载③.通过yumdownloader命令…
阅读更多...
容器化实战--vmware安装centos7-安装docker-idea部署springBoot项目到docker

容器化实战--vmware安装centos7-安装docker-idea部署springBoot项目到docker

前言 走过的坑终将化为蒲公英&#xff0c;风一吹就消散了&#xff0c;然后继续掉坑… 整体背景 win10 idea2019.3 vmware15 pro CentOS-7-x86_64-DVD-2009.iso docker 23.0.4 redis mysql8 springBoot项目 1.安装虚拟软件vmware15 pro 安装vmware15 2.安装宿主机centos7 …
阅读更多...
为什么你永远不应该在CSS中使用px来设置字体大小

为什么你永远不应该在CSS中使用px来设置字体大小

代码部署后可能存在的BUG没法实时知道&#xff0c;事后为了解决这些BUG&#xff0c;花了大量的时间进行log 调试&#xff0c;这边顺便给大家推荐一个好用的BUG监控工具 Fundebug。 在Josh Collinsworth的博客文章“永远不要用px作为字体大小”中&#xff0c;作者讨论了为什么不…
阅读更多...
HashMap 的特点及其优缺点以及底层实现

HashMap 的特点及其优缺点以及底层实现

Hash&#xff1a;散列 Map&#xff1a;映射 顾名思义&#xff0c;是以 key-value 的形式存储数据 public class HashMap<K,V> {transient Node<K,V>[] table;// 初始容量 16static final int DEFAULT_INITIAL_CAPACITY 1 << 4; }通过源码可知&#xff0c;…
阅读更多...
Web安全 iwebsec 靶场搭建.

Web安全 iwebsec 靶场搭建.

Web安全 iwebsec靶场搭建 iwebsec 本质上是一个漏洞集成容器&#xff0c;里面集成了大量的漏洞环境.&#xff08;如&#xff1a;集合了SQL注入、文件包含、命令执行、XXE、反序列化、SSRF、XSS、文件上传等常见的web漏洞环境&#xff09; 目录&#xff1a; 靶场安装步骤&#…
阅读更多...
免费gpt-4-国内使用gpt-4

免费gpt-4-国内使用gpt-4

如何用上gpt-4 GPT-4尚未正式发布和公开&#xff0c;因此我们无法提供对GPT-4的具体使用方法。但是&#xff0c;可以从GPT-4的前一代——GPT-3的使用经验和GPT-4的预期功能来看&#xff0c;建议如下&#xff1a; 了解GPT-4的语言处理能力和适用场景&#xff1a;GPT-4预计将进一…
阅读更多...
影视动画制作中的后期渲染是什么意思？

影视动画制作中的后期渲染是什么意思？

影视动画制作是一项非常复杂的任务&#xff0c;需要涵盖从剧本创作到角色设计、场景布置、动画制作、后期渲染等多个环节。其中&#xff0c;后期渲染是制作过程中的最后一步&#xff0c;也是非常重要的一步&#xff0c;它可以使得动画画面更加真实、细腻&#xff0c;达到更好的…
阅读更多...
CPU Cache：访问存储速度是如何大幅提升的？

CPU Cache：访问存储速度是如何大幅提升的？

我们了解到不同的物理器件&#xff0c;它们的访问速度是不一样的&#xff1a;速度快的往往代价高、容量小&#xff1b;代价低且容量大的&#xff0c;速度通常比较慢。为了充分发挥各种器件的优点&#xff0c;计算机存储数据的物理器件不会只选择一种&#xff0c;而是以 CPU 为核…
阅读更多...
浅析“04.23王者荣耀KPL比赛因出现硬件异常导致比赛延期”这一事件

浅析“04.23王者荣耀KPL比赛因出现硬件异常导致比赛延期”这一事件

背景 不知道朋友们有没有看昨天晚上八点多的王者荣耀KPL比赛&#xff08;成都AG超玩会VS广州TTG&#xff09;这一场&#xff0c;当时比赛进行到快15分钟的时候出现了红方请求暂停的情况&#xff0c;后来比赛直播界面就一直提示如下&#xff1a; 本以为这个问题应该不算太严重…
阅读更多...
Java——栈的压入,弹出序列

Java——栈的压入,弹出序列

题目链接 牛客网在线oj题——栈的压入,弹出序列 题目描述 输入两个整数序列&#xff0c;第一个序列表示栈的压入顺序&#xff0c;请判断第二个序列是否可能为该栈的弹出顺序。假设压入栈的所有数字均不相等。例如序列1,2,3,4,5是某栈的压入顺序&#xff0c;序列4,5,3,2,1是…
阅读更多...
手把手教你PXE高效网络装机、Kickstart无人值守安装（详细版）

手把手教你PXE高效网络装机、Kickstart无人值守安装（详细版）

目录 一、部署PXE远程安装服务1.1PXE定义1.2PXE服务优点1.3搭建网络体系前提条件1.4 搭建PXE远程安装服务器 二. 实验2.1 服务器操作2.2 安装启动TFTP服务并修改TFTP服务的配置文件2.3 安装并启用DHCP服务2.4 准备linux内核&#xff0c;初始化镜像文件2.5 准备PXE引导程序2.6 安…
阅读更多...
编程中最难的就是命名？这几招教你快速上手

编程中最难的就是命名？这几招教你快速上手

作者&#xff1a;陈立(勤仁) 你可不能像给狗狗取名字那样给类、方法、变量命名。仅仅因为它很可爱或者听上去不错。 在写代码的时候&#xff0c;你要经常想着&#xff0c;那个最终维护你代码的人可能将是一个有暴力倾向的疯子&#xff0c;并且他还知道你住在哪里。 01 为什么…
阅读更多...
GitHub star最多的 dnmp环境 安装

GitHub star最多的 dnmp环境 安装

对于安装GitHub上start最多的dnmp环境的步骤及感悟 https://github.com/yeszao/dnmp/blob/master/README.md 在服务器上装docker与docker-compose 注意&#xff1a;安装docker-compose的时候选择官方版本安装(虽然慢但是请等等)&#xff0c;我操作时出现过国内镜像地址安装但…
阅读更多...
flex弹性布局的基本操作知识

flex弹性布局的基本操作知识

今天为大家阐述如何在开发APP或网站的时候&#xff0c;制定一套弹性布局&#xff0c;相互之间兼容&#xff0c;那么我们就可以用Flex来实现&#xff1a; 什么是flex?&#xff1a;Flex是Flexible Box的缩写&#xff0c;意为”弹性布局”&#xff0c;用来为盒状模型提供最大的灵…
阅读更多...
Ubuntu 上使用nginx部署vue项目(403/(98: Address already in use))

Ubuntu 上使用nginx部署vue项目(403/(98: Address already in use))

准备好前端dist文件 保证dist/index.html 点击在本地可以访问&#xff0c; 一&#xff0c;nginx安装 第一步&#xff0c;更新源列表 apt-get update 第二步&#xff0c;安装nginx apt-get install nginx 第三步&#xff0c;检查nginx是否安装成功。如果出现版本号说明安…
阅读更多...
直播预告：重保常见攻击场景及解决方案

直播预告：重保常见攻击场景及解决方案

重保在即&#xff0c;针对邮件系统的网络攻击、主机威胁、账号失陷等攻击场景&#xff0c;该如何应对&#xff1f; 4月25日&#xff08;周二&#xff09;15&#xff1a;00-16&#xff1a;30 Coremail举行重保常见攻击场景及解决方案直播交流会 在这里&#xff0c;您将看到&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023