【设计模式——学习笔记】23种设计模式——观察者模式Observer(原理讲解+应用场景介绍+案例介绍+Java代码实现)

这篇具有很好参考价值的文章主要介绍了【设计模式——学习笔记】23种设计模式——观察者模式Observer(原理讲解+应用场景介绍+案例介绍+Java代码实现)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

案例引入

有一个天气预报项目,需求如下:

  • 气象站可以将每天测量到的温度、湿度、气压等等以公告的形式发布出去(比如发布到自己的网站或第三方)
  • 需要设计开放型API,便于其他第三方也能接入气象站获取数据
  • 提供温度、气压、湿度的接口
  • 测量数据更新时,要能实时的通知给第三方

原始方案实现

设计一个WeatherData类,类里面的方法如下:

  • getTemperature0:获取温度
  • getHumidity0:获取湿度
  • getPressure0:获取气压
  • dataChange0:可以定时(如每十分钟调用一次)调用该方法去气象站更新温度、湿度、气压数据,并主动推送给应用者

实现

【当前天气状况】

package com.atguigu.observer;

/**
 * 显示当前天气情况(可以理解成是气象站的网站)
 * @author Administrator
 *
 */
public class CurrentConditions {
   /**
    * 温度
    */
   private float temperature;
   /**
    * 气压
    */
   private float pressure;
   /**
    * 湿度
    */
   private float humidity;

   /**
    * 更新 天气情况,是由WeatherData来调用将最新的数据推送过来
    * @param temperature
    * @param pressure
    * @param humidity
    */
   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("***Today mTemperature: " + temperature + "***");
      System.out.println("***Today mPressure: " + pressure + "***");
      System.out.println("***Today mHumidity: " + humidity + "***");
   }
}

【气象台的天气数据】

package com.atguigu.observer;

/**
 * 类是核心
 * 1. 包含最新的天气情况信息
 * 2. 含有 CurrentConditions 对象
 * 3. 当数据有更新时,就主动的调用CurrentConditions对象的update方法(含 display), 这样他们(接入方)就看到最新的信息
 * @author Administrator
 *
 */
public class WeatherData {
   private float temperatrue;
   private float pressure;
   private float humidity;
   private CurrentConditions currentConditions;

   /**
    * 加入新的第三方
    * @param currentConditions
    */
   public WeatherData(CurrentConditions currentConditions) {
      this.currentConditions = currentConditions;
   }

   public float getTemperature() {
      return temperatrue;
   }

   public float getPressure() {
      return pressure;
   }

   public float getHumidity() {
      return humidity;
   }

   public void dataChange() {
      //调用 接入方的 update
      currentConditions.update(getTemperature(), getPressure(), getHumidity());
   }

   /**
    * 当数据有更新时,就调用 setData
    * @param temperature
    * @param pressure
    * @param humidity
    */
   public void setData(float temperature, float pressure, float humidity) {
      this.temperatrue = temperature;
      this.pressure = pressure;
      this.humidity = humidity;
      //调用dataChange, 将最新的信息 推送给 接入方 currentConditions
      dataChange();
   }
}

【主类】

package com.atguigu.observer;

public class Client {
   public static void main(String[] args) {
      //创建接入方 currentConditions
      CurrentConditions currentConditions = new CurrentConditions();
      //创建 WeatherData 并将 接入方 currentConditions 传递到 WeatherData中
      WeatherData weatherData = new WeatherData(currentConditions);

      //更新天气情况
      weatherData.setData(30, 150, 40);

      //天气情况变化
      System.out.println("============天气情况变化=============");
      weatherData.setData(40, 160, 20);
   }
}

【运行】

***Today mTemperature: 30.0***
***Today mPressure: 150.0***
***Today mHumidity: 40.0***
============天气情况变化=============
***Today mTemperature: 40.0***
***Today mPressure: 160.0***
***Today mHumidity: 20.0***

Process finished with exit code 0

问题分析

当添加其他第三方网站时,需要修改WeatherData类,不符合开闭原则,不利于维护

【设计模式——学习笔记】23种设计模式——观察者模式Observer(原理讲解+应用场景介绍+案例介绍+Java代码实现),设计模式,设计模式,学习,笔记,观察者模式

改进:推荐使用观察者模式

介绍

基础介绍

  • 观察者模式的工作原理:观察者到观察对象中进行注册,当观察对象的状态发生改变时,就通知已经注册的观察者,观察者可以被从观察对象中移除

登场角色

【设计模式——学习笔记】23种设计模式——观察者模式Observer(原理讲解+应用场景介绍+案例介绍+Java代码实现),设计模式,设计模式,学习,笔记,观察者模式

  • Subject(观察对象):Subject角色定义了注册、删除观察者的方法,还可以声明“获取现在的状态”的方法
  • ConcreteSubject(具体的观察对象):当自身状态发生变化后,它会通知所有已经注册的Observer角色
  • Observer(观察者):负责接收来自Subject角色状态变化的通知,声明了update方法来接收通知
  • ConcreteObserver(具体的观察者):当它的update方法被调用后,会去获取要观察的对象的最新状态

案例实现

案例一

类图

【设计模式——学习笔记】23种设计模式——观察者模式Observer(原理讲解+应用场景介绍+案例介绍+Java代码实现),设计模式,设计模式,学习,笔记,观察者模式

实现

【Subject:观察对象接口】

package com.atguigu.observer.improve;

/**
 * 接口, 让WeatherData 来实现
 */
public interface Subject {

   /**
    * 观察者注册
    * @param o
    */
   public void registerObserver(Observer o);

   /**
    * 移除观察者
    * @param o
    */
   public void removeObserver(Observer o);

   /**
    * 通知所有观察者
    */
   public void notifyObservers();
}

【Observer:观察者接口】

package com.atguigu.observer.improve;

/**
 * 观察者接口
 */
public interface Observer {

    /**
     * 更新数据
     *
     * @param temperature
     * @param pressure
     * @param humidity
     */
    public void update(float temperature, float pressure, float humidity);
}

【WeatherData:具体观察对象】

package com.atguigu.observer.improve;

import java.util.ArrayList;

/**
 * 类是核心
 * 1. 包含最新的天气情况信息
 * 2. 含有 观察者集合,使用ArrayList管理
 * 3. 当数据有更新时,就主动的调用ArrayList, 通知所有的(接入方)就看到最新的信息
 *
 * @author Administrator
 */
public class WeatherData implements Subject {
    private float temperature;
    private float pressure;
    private float humidity;
    /**
     * 观察者集合
     */
    private ArrayList<Observer> observers;

    /**
     * 构造方法
     */
    public WeatherData() {
        // 创建新的集合
        observers = new ArrayList<Observer>();
    }

    public float getTemperature() {
        return temperature;
    }

    public float getPressure() {
        return pressure;
    }

    public float getHumidity() {
        return humidity;
    }

    public void dataChange() {
        //调用 接入方的 update
        notifyObservers();
    }

    //当数据有更新时,就调用 setData
    public void setData(float temperature, float pressure, float humidity) {
        this.temperature = temperature;
        this.pressure = pressure;
        this.humidity = humidity;
        //调用dataChange, 将最新的信息 推送给 接入方 currentConditions
        dataChange();
    }

    /**
     * 注册一个观察者
     * @param o
     */
    @Override
    public void registerObserver(Observer o) {
        observers.add(o);
    }

    /**
     * 移除一个观察者
     * @param o
     */
    @Override
    public void removeObserver(Observer o) {
        if (observers.contains(o)) {
            observers.remove(o);
        }
    }

    /**
     * 遍历所有的观察者,并通知
     */
    @Override
    public void notifyObservers() {
        for (int i = 0; i < observers.size(); i++) {
            observers.get(i).update(this.temperature, this.pressure, this.humidity);
        }
    }
}

【CurrentConditions:具体观察者】

package com.atguigu.observer.improve;

public class CurrentConditions implements Observer {
    /**
     * 温度
     */
    private float temperature;
    /**
     * 气压
     */
    private float pressure;
    /**
     * 湿度
     */
    private float humidity;

    /**
     * 更新 天气情况,是由 WeatherData 来调用,我使用推送模式
     *
     * @param temperature
     * @param pressure
     * @param humidity
     */
    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("***Today mTemperature: " + temperature + "***");
        System.out.println("***Today mPressure: " + pressure + "***");
        System.out.println("***Today mHumidity: " + humidity + "***");
    }
}

【BaiduSite:具体观察者】

package com.atguigu.observer.improve;

/**
 * 百度网站
 */
public class BaiduSite implements Observer {
    private float temperature;
    private float pressure;
    private float humidity;

    /**
     * 更新天气情况,是由 WeatherData 来调用,我使用推送模式
     *
     * @param temperature
     * @param pressure
     * @param humidity
     */
    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("===百度网站====");
        System.out.println("***百度网站 气温 : " + temperature + "***");
        System.out.println("***百度网站 气压: " + pressure + "***");
        System.out.println("***百度网站 湿度: " + humidity + "***");
    }

}

【主类】

package com.atguigu.observer.improve;

public class Client {

   public static void main(String[] args) {
      //创建一个WeatherData
      WeatherData weatherData = new WeatherData();

      //创建观察者
      CurrentConditions currentConditions = new CurrentConditions();
      BaiduSite baiduSite = new BaiduSite();

      //注册到weatherData
      weatherData.registerObserver(currentConditions);
      weatherData.registerObserver(baiduSite);

      //测试
      System.out.println("通知各个注册的观察者, 看看信息");
      weatherData.setData(10f, 100f, 30.3f);

      System.out.println();
      System.out.println("----- 移除一个观察者 -----");
      weatherData.removeObserver(currentConditions);
      //测试
      System.out.println();
      System.out.println("通知各个注册的观察者, 看看信息");
      weatherData.setData(10f, 100f, 30.3f);
   }

}

【运行】

通知各个注册的观察者, 看看信息
***Today mTemperature: 10.0***
***Today mPressure: 100.0***
***Today mHumidity: 30.3***
===百度网站====
***百度网站 气温 : 10.0***
***百度网站 气压: 100.0***
***百度网站 湿度: 30.3***

----- 移除一个观察者 -----

通知各个注册的观察者, 看看信息
===百度网站====
***百度网站 气温 : 10.0***
***百度网站 气压: 100.0***
***百度网站 湿度: 30.3***

Process finished with exit code 0

分析

  • 使用该模式,拓展方便,比如需要新增一个观察者,只需要实现一个具体的观察者类,然后在观察对象中注册即可

案例二

类图

【设计模式——学习笔记】23种设计模式——观察者模式Observer(原理讲解+应用场景介绍+案例介绍+Java代码实现),设计模式,设计模式,学习,笔记,观察者模式

实现

【观察者接口】

package com.atguigu.observer.Sample;

public interface Observer {
    public abstract void update(NumberGenerator generator);
}

【被观察对象抽象类】

package com.atguigu.observer.Sample;

import java.util.ArrayList;
import java.util.Iterator;

/**
 * 用来生成数值的抽象类
 */
public abstract class NumberGenerator {
    /**
     * 保存Observer们
     */
    private ArrayList observers = new ArrayList();

    /**
     * 注册Observer
     *
     * @param observer
     */
    public void addObserver(Observer observer) {
        observers.add(observer);
    }

    /**
     * 删除Observer
     *
     * @param observer
     */
    public void deleteObserver(Observer observer) {
        observers.remove(observer);
    }

    /**
     * 向Observer发送通知
     */
    public void notifyObservers() {
        Iterator it = observers.iterator();
        while (it.hasNext()) {
            Observer o = (Observer) it.next();
            o.update(this);
        }
    }

    /**
     * 获取数值
     *
     * @return
     */
    public abstract int getNumber();

    /**
     * 生成数值
     */
    public abstract void execute();
}

【具体的被观察对象】

package com.atguigu.observer.Sample;

import java.util.Random;

/**
 * 具体的被观察对象
 */
public class RandomNumberGenerator extends NumberGenerator {
    /**
     * 随机数生成器
     */
    private Random random = new Random();
    /**
     * 当前数值
     */
    private int number;

    /**
     * 获取当前数值
     * @return
     */
    public int getNumber() {                
        return number;
    }

    public void execute() {
        for (int i = 0; i < 20; i++) {
            // 生成随机数
            number = random.nextInt(50);
            // 通知观察者
            notifyObservers();
        }
    }
}

【数值显示观察者】

package com.atguigu.observer.Sample;

/**
 * 使用数字形式显示观察到的数值
 */
public class DigitObserver implements Observer {
    public void update(NumberGenerator generator) {
        System.out.println("DigitObserver:" + generator.getNumber());
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
        }
    }
}

【图像显示观察者】

package com.atguigu.observer.Sample;

/**
 * 使用图像显示观察到的数值
 */
public class GraphObserver implements Observer {
    public void update(NumberGenerator generator) {
        System.out.print("GraphObserver:");
        int count = generator.getNumber();
        for (int i = 0; i < count; i++) {
            System.out.print("*");
        }
        System.out.println("");
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
        }
    }
}

【主类】

package com.atguigu.observer.Sample;

public class Main {
    public static void main(String[] args) {
        NumberGenerator generator = new RandomNumberGenerator();
        Observer observer1 = new DigitObserver();
        Observer observer2 = new GraphObserver();
        generator.addObserver(observer1);
        generator.addObserver(observer2);
        generator.execute();
    }
}

【运行】

DigitObserver:2
GraphObserver:**
DigitObserver:7
GraphObserver:*******
DigitObserver:6
GraphObserver:******
DigitObserver:26
GraphObserver:**************************
DigitObserver:16
GraphObserver:****************
DigitObserver:6
GraphObserver:******
DigitObserver:28
GraphObserver:****************************
DigitObserver:10
GraphObserver:**********
DigitObserver:6
GraphObserver:******
DigitObserver:10
GraphObserver:**********
DigitObserver:20
GraphObserver:********************
DigitObserver:14
GraphObserver:**************
DigitObserver:21
GraphObserver:*********************
DigitObserver:38
GraphObserver:**************************************
DigitObserver:31
GraphObserver:*******************************
DigitObserver:34
GraphObserver:**********************************
DigitObserver:19
GraphObserver:*******************
DigitObserver:30
GraphObserver:******************************
DigitObserver:0
GraphObserver:
DigitObserver:1
GraphObserver:*

Process finished with exit code 0

观察者模式在JDK源码的应用

【设计模式——学习笔记】23种设计模式——观察者模式Observer(原理讲解+应用场景介绍+案例介绍+Java代码实现),设计模式,设计模式,学习,笔记,观察者模式

Observable直接就是类,没有实现Subject接口,直接在类中实现管理Observer的核心方法,当然,可以写更多的子类来集成Observable以便实现更多的操作

【设计模式——学习笔记】23种设计模式——观察者模式Observer(原理讲解+应用场景介绍+案例介绍+Java代码实现),设计模式,设计模式,学习,笔记,观察者模式文章来源地址https://www.toymoban.com/news/detail-625127.html

总结

  • 可替换性强:被观察对象中的观察者集合的观察者类型是Observer角色,可以接收各种各样的具体Observer角色,而且可以统一调用他们的update方法;Observer的update方法接收的数据类型也是Subject,在update方法里面也可以统一调用方法来获取具体被观察对象的属性
  • update方法所需要的参数非常灵活,可以自己按照需求来定义
  • 观察者模式并非主动去观察,而是被观测对象主动去通知,称为发布——订阅模式可能更加贴切

文章说明

  • 本文章为本人学习尚硅谷的学习笔记,文章中大部分内容来源于尚硅谷视频(点击学习尚硅谷相关课程),也有部分内容来自于自己的思考,发布文章是想帮助其他学习的人更方便地整理自己的笔记或者直接通过文章学习相关知识,如有侵权请联系删除,最后对尚硅谷的优质课程表示感谢。
  • 本人还同步阅读《图解设计模式》书籍(图解设计模式/(日)结城浩著;杨文轩译–北京:人民邮电出版社,2017.1),进而综合两者的内容,让知识点更加全面

到了这里,关于【设计模式——学习笔记】23种设计模式——观察者模式Observer(原理讲解+应用场景介绍+案例介绍+Java代码实现)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 【设计模式】观察者模式

    观察者模式(又被称为发布-订阅(Publish/Subscribe)模式,属于行为型模式的一种,它定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态变化时,会通知所有的观察者对象,使他们能够自动更新自己。 Subject:抽象主题(被观察者

    2024年02月13日
    浏览(51)
  • 设计模式——观察者模式

    观察者模式可以分为观察者和被观察者,观察者通过注册到一个被观察者中,也可视为订阅,当被观察者的数据发生改变时,会通知到观察者,观察者可以据此做出反应。 可以类比订阅报纸,报社就是被观察者,订阅者就是观察者,订阅者通过订阅报纸与报社建立联系,而报

    2024年02月15日
    浏览(52)
  • 设计模式---观察者模式

    1,概念         属于行为模式的一种,定义了一种一对多的依赖关系,让多个观察者对象同时监听某一对象主题对象,这个主题对象在状态变化时,会通知所有的观察者对象,使他们能够自动更新自己。 在观察者模式中有如下角色: Subject:抽象主题(抽象被观察者),

    2024年02月15日
    浏览(65)
  • 设计模式:观察者模式

    定义 观察者模式(Observer Pattern)是一种行为设计模式,允许一个对象(称为“主题”或“可观察对象”)维护一组依赖于它的对象(称为“观察者”),当主题的状态发生变化时,会自动通知所有观察者对象。 应用场景 观察者模式适用于以下场景: 联动反应 :当一个对象

    2024年04月08日
    浏览(59)
  • 设计模式之观察者模式

    可以帮你的对象知悉现况,不会错过该对象感兴趣的事。对象甚至在运行时可决定是否要继续被通知。 从报纸和杂志的订阅说起: 报社的业务就是出版报纸 向某家报社订阅报纸,只要他们有新报纸出版,就会给你送来。只要你是他们的订户,你就会一直收到新报纸。 当你不

    2024年01月24日
    浏览(53)
  • 设计模式(11)观察者模式

    一、概述: 1、定义:观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时,会通知所有观察者对象,使它们能够自动更新自己。 2、结构图: 实现  调用

    2024年02月11日
    浏览(52)
  • 设计模式——14. 观察者模式

    观察者模式(Observer Pattern)是一种行为型设计模式,用于定义对象之间的一对多依赖关系,使得当一个对象的状态发生改变时,所有依赖于它的对象都能够自动收到通知并更新自己的状态,以保持与被观察对象的同步。观察者模式也被称为发布-订阅模式。 观察者模式包含以

    2024年02月07日
    浏览(44)
  • 重温设计模式 --- 观察者模式

    观察者模式 是一种行为型设计模式,它允许对象之间建立一种一对多的关系,使得当一个对象状态改变时,所有依赖它的对象都能够自动得到通知并更新自己的状态。该模式可以帮助我们实现松耦合的系统,以便更好地应对变化和扩展。 在观察者模式中,有两个角色: 观察

    2024年02月13日
    浏览(58)
  • 设计模式:行为型模式 - 观察者模式

    定义: 又被称为发布-订阅(Publish/Subscribe)模式,它定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态变化时,会通知所有的观察者对象,使他们能够自动更新自己。 在观察者模式中有如下角色: Subject:抽象主题(抽象被观察

    2023年04月22日
    浏览(96)
  • 设计模式【行为型】-- 观察者模式

    观察者模式(Observer Pattern)是一种行为型设计模式,用于在对象之间建立一种一对多的依赖关系,使得当一个对象状态改变时,其相关依赖对象都能得到通知并自动更新。 主题( Subject ):也称为被观察者,它维护一个观察者列表,并提供添加、删除和通知观察者的方法。

    2024年02月15日
    浏览(51)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包