一篇文章带你搞懂观察者模式

最新推荐文章于 2025-03-06 08:57:36 发布
最新推荐文章于 2025-03-06 08:57:36 发布
阅读量2k 收藏
点赞数
分类专栏： 设计模式 文章标签： 设计模式 java
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/qq_40242512/article/details/113885905
版权
本文详细介绍了观察者模式的应用，通过气象站与第三方应用（如新浪、百度）的天气信息推送，展示了如何使用Subject、Observer接口和ConcreteSubject/ConcreteObserver实现。接着，通过数值转换的示例演示了如何将一个整数转换为二进制、八进制和十六进制，并观察其变化。

摘要生成于 C知道 ，由 DeepSeek-R1 满血版支持， 前往体验 >

文章目录

观察者模式

1、目的

  观察者模式使得一个对象的状态改变时，已经注册的其它依赖对象能够观察到这一改变。

2、观察者和被观察者关系

  对象之间一对多的一种设计方案，被依赖的对象为被观察者，依赖的对象为Observer（观察者）。当被观察者的状态发生变化，所有的依赖对象Observer都将被通知，属于行为型模式。

3、UML

在这里插入图片描述

  • Subject：通常是由类实现的可观察的接口
    • registerObserver()：注册观察者
    • removeObserver()：移除观察者
    • notifyObservers()：通知注册的所有观察者
    • notifyObservers(Observer o)：通知具体的观察者
  • Observer：观察者是一个由对象实现的接口，根据Subject中的更改接受输入来进行更新。每个观察者都应该实现update方法，该方法通知它们新的状态变化。
  • ConcreteSubject：一个实现Subject的类，它处理观察者列表并更新他们的变化。

4、代码实现

4.1、demo：天气

气象站把每天测量到的天气实时推送到第三方

  • Subject
package com.lin.observer.demo2;

/**
 * @author linxh
 */
public interface Subject {

    void registerObserver(Observer observer);

    void removerObserver(Observer observer);

    void notifyObservers();

    void notifyObservers(Observer observer);

}
  • Observer
package com.lin.observer.demo2;

/**
 * @author linxh
 */
public interface Observer {

    void update(float temperature, float pressure, float humidity);
}
  • ConcreteSubject
package com.lin.observer.demo2;

import java.util.HashSet;
import java.util.Set;

/**
 * @author linxh
 */
public class Weather implements Subject {

    private float temperature;
    private float pressure;
    private float humidity;

    private final Set<Observer> observers;

    public Weather() {
        observers = new HashSet<>();
    }

    public void setData(float temperature, float pressure, float humidity) {
        this.temperature = temperature;
        this.pressure = pressure;
        this.humidity = humidity;
        notifyObservers();
    }

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

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

    @Override
    public void notifyObservers() {
        observers.forEach(o -> o.update(temperature, pressure, humidity));
    }

    @Override
    public void notifyObservers(Observer observer) {
        observer.update(temperature, pressure, humidity);
    }
}
  • ConcreteObserver
package com.lin.observer.demo2;

/**
 * @author linxh
 */
public class Sina implements Observer {

    private float temperature;
    private float pressure;
    private float humidity;

    @Override
    public void update(float temperature, float pressure, float humidity) {
        this.temperature = temperature;
        this.pressure = pressure;
        this.humidity = humidity;
        display();
    }

    public void display() {
        System.out.println("新浪天气温度：" + this.temperature);
        System.out.println("新浪天气压力：" + this.pressure);
        System.out.println("新浪天气湿度：" + this.humidity);
    }
}

package com.lin.observer.demo2;

/**
 * @author linxh
 */
public class Baidu implements Observer {

    private float temperature;
    private float pressure;
    private float humidity;

    @Override
    public void update(float temperature, float pressure, float humidity) {
        this.temperature = temperature;
        this.pressure = pressure;
        this.humidity = humidity;
        display();
    }

    public void display() {
        System.out.println("百度天气温度：" + this.temperature);
        System.out.println("百度天气压力：" + this.pressure);
        System.out.println("百度天气湿度：" + this.humidity);
    }
}
  • 测试
package com.lin.observer.demo2;

/**
 * @author linxh
 */
public class Client {
    public static void main(String[] args) {
        Weather weather = new Weather();
        Sina sina = new Sina();
        weather.registerObserver(sina);
        System.out.println("第一次天气信息");
        weather.setData(10, 10, 10);

        Baidu baidu = new Baidu();
        weather.registerObserver(baidu);
        System.out.println("第二次天气信息");
        weather.setData(20,20,20);

        weather.removerObserver(sina);
        System.out.println("第三次天气信息");
        weather.setData(30,30,30);
    }
}
  • 结果

第一次天气信息
新浪天气温度：10.0
新浪天气压力：10.0
新浪天气湿度：10.0
第二次天气信息
百度天气温度：20.0
百度天气压力：20.0
百度天气湿度：20.0
新浪天气温度：20.0
新浪天气压力：20.0
新浪天气湿度：20.0
第三次天气信息
百度天气温度：30.0
百度天气压力：30.0
百度天气湿度：30.0

4.2、demo：数值转换

输入一个输出其二进制、十进制、十六进制

  • Subject
package com.lin.observer.demo1;

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

/**
 * @author linxh
 */
public class Subject {
    private final List<Observer> observers;
    private int number;

    public Subject() {
        observers = new ArrayList<>();
    }

    public void setNumber(int number) {
        this.number = number;
        notifyAllObservers();
    }

    public int getNumber() {
        return number;
    }

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

    public void notifyAllObservers() {
        observers.forEach(Observer::update);
    }
}
  • Observer
package com.lin.observer.demo1;

/**
 * @author linxh
 */
public interface Observer {

    void update();
}
  • ConcreteObserver
package com.lin.observer.demo1;

/**
 * @author linxh
 */
public class BinaryObserver implements Observer {

    private final Subject subject;

    public BinaryObserver(Subject subject) {
        this.subject = subject;
        this.subject.registerObserver(this);
    }

    @Override
    public void update() {
        System.out.println("Binary String：" + Integer.toBinaryString(subject.getNumber()));
    }
}

package com.lin.observer.demo1;

/**
 * @author linxh
 */
public class OctalObserver implements Observer {

    private final Subject subject;

    public OctalObserver(Subject subject) {
        this.subject = subject;
        this.subject.registerObserver(this);
    }

    @Override
    public void update() {
        System.out.println("Octal String: " + Integer.toOctalString(subject.getNumber()));
    }
}

package com.lin.observer.demo1;


/**
 * @author linxh
 */
public class HexObserver implements Observer {

    private final Subject subject;

    public HexObserver(Subject subject) {
        this.subject = subject;
        this.subject.registerObserver(this);
    }

    @Override
    public void update() {
        System.out.println("Hex String: " + Integer.toHexString(subject.getNumber()));
    }
}
  • 测试
package com.lin.observer.demo1;

/**
 * @author lin
 * @version V1.0
 */
public class Client {

    public static void main(String[] args) {
        Subject subject = new Subject();
        new HexObserver(subject);
        new OctalObserver(subject);
        new BinaryObserver(subject);
        System.out.println("First number change: 15");
        subject.setNumber(15);
        System.out.println("Second number change: 12");
        subject.setNumber(12);
    }
}
  • 结果

First number change: 15
Hex String: f
Octal String: 17
Binary String：1111
Second number change: 12
Hex String: c
Octal String: 14
new BinaryObserver(subject);
System.out.println(“First number change: 15”);
subject.setNumber(15);
System.out.println(“Second number change: 12”);
subject.setNumber(12);
}
}

Unity常用设计模式-观察者模式：游戏中的事件传播
weixin_51186493的博客
01-01 1057
当在Unity中应用观察者模式时，通常是为了实现一种解耦和灵活性较强的事件机制。观察者模式允许一个对象（称为主题）维护一组依赖于它的对象（称为观察者），当主题的状态发生变化时，所有观察者都能够得到通知并进行相应的处理。
观察者模式
u011569827的博客
09-14 361
介绍 指多个对象间存在一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。这种模式有时又称作发布-订阅模式、模型-视图模式，它是对象行为型模式。 原理 观察者模式类似订牛奶业务 奶站/气象局：Subject 用户/第三方网站：Observer Subject：登记注册、移除和通知 registerObserver 注册 removeObserver 移除 notifyObservers() 通知所有的注册的用户，根据不同需求，可以是更新数据，让用 户来取，也
23种设计模式之《观察者模式（Observer）》在c#中的应用及理解
最新发布
yuanpan的专栏
03-06 2160
观察者模式通过将主题和观察者解耦，使得系统更加灵活和可扩展。它非常适合处理对象之间的一对多依赖关系，尤其是在需要动态通知和更新的场景中。在 C# 中，观察者模式可以通过事件和委托机制更简洁地实现，但经典的设计模式实现方式仍然有助于理解其核心思想。
一篇文章掌握观察者模式
Android小白
02-22 161
一.案例引入 1.案例描述 、 2.普通方案介绍 方式1 方式2 具体代码 显示当前天气情况（可以理解成是气象站自己的网站） 结果 传统方式优缺点分析 二.观察者模式 1.原理 2.观察者模式解决上述问题的原理类图 3.具体代码 Subject public interface Subject { public void registerObserver(Observer o); public void removeObserver(Observer o); pu
理解观察者模式(Observer Pattern)必看的文章
我的博客新地址： http://www.n-pei.com
08-10 4110
1.       说明:观察者模式是软件设计的一种模式,也叫做发布/订阅模式。日常生活中基本上都有用到它。比如使用MSN当你的一个好友上线时,你就会收到上线通知;开心网当某个人转帖后,他的好友就都可以收到这个转帖,等等。也就是说一个目标管理所有依赖于它的观察者对象,当它本身状态发生变化时主动发出通知。2.       结构:      3.       用途:a.      
《观察者模式》
li1060849458的博客
02-05 241
观察者模式（有时又被称为发布（publish ）-订阅（Subscribe）模式、模型-视图（View）模式、源-收听者(Listener)模式或从属者模式）是软件设计模式的一种。在此种模式中，一个目标物件管理所有相依于它的观察者物件，并且在它本身的状态改变时主动发出通知。这通常透过呼叫各观察者所提供的方法来实现。此种模式通常被用来实现事件处理系统。 观察者模式（Observer）完美的将观察者
Javascript 模式实例 观察者模式
12-09
有兴趣的朋友可以先了解一下一些牛人的，比如李会军大哥设计模式篇中观察者的那一节 http://www.cnblogs.com/Terrylee/archive/2006/10/23/Observer_Pattern.html说说我自己对这模式的理解，其思想核心是：每个被...
Qt设计模式之观察者模式
01-16
本篇文章将深入探讨Qt中的观察者模式（Observer Pattern），这是一种行为设计模式，它定义了对象之间的一对多依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都会得到通知并自动更新。 观察者模式的核心...
PHP设计模式之观察者模式入门与应用案例详解
01-21
其次，观察者还必须要有自己的操作，也就是说，你不能光看我的文章啊，还得自己动手，否则你聚在一堆儿没事做也没什么意义，白看一篇文章，浪费了时间。 从面向过程的角度来看，首先是观察者向主题注册，注册完之后...
【Java设计模式】观察者模式
09-23
Java中的观察者模式定义了对象之间的一对多关系，确保当一个对象更新其状态时，所有依赖的观察者都会自动得到通知并更新，增强了系统的响应能力和模块化。 ## 二、详细解释及实际示例 1. **实际示例**： - 在一个...
观察者模式-
路辉的博客
12-29 289
观察者模式观察者模式的概念jdk API实现简单动态发布提醒的例子Guava 实现简单动态发布提醒的例子源码中的例子 观察者模式的概念 观察者模式其实比起之前的设计模式，较为特别，区别还是比较明显的 他是一个比较被动的模式，简单来说有点像触发事件或者说监听器的概念，就是A类执行了某个方法(不是指定的发信息给某类)，然后B类、C类等关注了它的类收到了对应的信息。 放在生活中，就是你特别关注的女神发了动态，qq、微博之类的会提醒你，当然，往往与此同时，被提醒的不止你一个，还有其他众多的关注了女神的粉丝。 放在工
评论
添加红包

请填写红包祝福语或标题

个

红包个数最小为10个

元

红包金额最低5元

当前余额3.43元 前往充值 >
需支付：10.00元
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付元
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。

余额充值