觀察者模式——學習筆記

来源:https://www.cnblogs.com/cndada/archive/2023/03/14/17215565.html
-Advertisement-
Play Games

觀察者模式 介紹 觀察者模式是極其重要的一個設計模式，在許多框架都使用了，以及實際開發中也會用到。 定義對象之間的一種一對多的依賴關係，使得每當一個對象的狀態發生變化時，其相關的依賴對象都可以得到通知並被自動更新。主要用於多個不同的對象對一個對象的某個方法會做出不同的反應！ 以不同觀察者從同一個天氣 ...


觀察者模式

介紹

觀察者模式是極其重要的一個設計模式，在許多框架都使用了，以及實際開發中也會用到。

定義對象之間的一種一對多的依賴關係，使得每當一個對象的狀態發生變化時，其相關的依賴對象都可以得到通知並被自動更新。主要用於多個不同的對象對一個對象的某個方法會做出不同的反應！

以不同觀察者從同一個天氣臺中獲取數據為例，實踐一下簡單而普通的觀察者模式實現。在（23GoF）書中也有這個例子，這裡借鑒了Observable 進行了一些修改。

其核心在於理解它的定義、使用場景、以及四個重要的方法：

  • addObserver(Observer o);
  • addObserver(Observer o);
  • addObserver(Observer o);
  • update(Object o);

update 由 觀察者實現，其餘的由主題實現。

代碼示例

1. Subject 主題介面

/**
 * @Author CNDA
 * @Date 2023/3/14 8:42
 * @ClassName: Subject
 * @Description: Subject 主題，一旦有改變則推送給所有已經訂閱的觀察者或者觀察者自己拉取數據
 * 註意：這個方案只是做學習，並不適用於多線程以及同步的情況。
 * @Version 1.0
 */
public interface Subject {
    void addObserver(Observer o); // 添加觀察者到列表中
    
    void removeObserver(Observer o); // 從列表中輸出觀察者
    
    void notifyObserver(Object arg); // 將 arg 的數據發送給所有觀察者
    
    int size(); // 返回當前主題的所有訂閱者個數
}

2. Observer 觀察者介面/抽象類 這裡是介面實現

public interface Observer {
    /**
     * 當主題有變化，會通知所有訂閱的 Observer
     * @param arg 主題變化的數據
     * 觀察者可以主動 ”拉取“ 或者 由主題 ”推送“
     */
    void update(Object arg);
}

3. 實現 Subject 介面類——WeatherData 類

天氣主題為例。

public class WeatherData implements Subject {
    private float temperature;
    private float humidity;
    private float light;
    private float co_2;
    private boolean isPush = true; // true 為主動推送，false 為訂閱者調用對應getxxx() 方法拉取數據。
    


    // 觀察者列表
    private final List<Observer> observers;
    
    // 無參構造
	public WeatherData() {
        this.observers = new ArrayList<>();
    }
    
    // 提供 getter() 給觀察者拉取數據。
    public float getTemperature() {
        return temperature;
    }

    public float getHumidity() {
        return humidity;
    }

    public float getLight() {
        return light;
    }

    public float getCo_2() {
        return co_2;
    }
    
    public void setPush(boolean isPush){
        this.isPush = isPush;
    }

   
    @Override
    public void addObserver(Observer o) {
        observers.add(o);
    }

    @Override
    public void removeObserver(Observer o) {
        int i = observers.indexOf(o);
        if (i >= 0) {
            observers.remove(o);
        }
    }

    @Override
    public void notifyObserver(Object arg) {
        // 通知 observers 的所有觀察者
        for (Observer observer : observers) {
            observer.update(arg);
        }
    }

    // 設置內容、更新數據。
    public void setManager(float temperature, float humidity, float light, float co_2){
        if (isPush){
            Map<String,Float> pramMap = new HashMap<>();
            pramMap.put("temperature",temperature);
            pramMap.put("humidity",humidity);
            pramMap.put("light",light);
            pramMap.put("co_2",co_2);
            push(pramMap);
        }else {
            this.temperature = temperature;
            this.humidity = humidity;
            this.light = light;
            this.co_2 = co_2;
            pull();
        }
    }
    
    public void pull(){
        notifyObserver(null);
    }
    
    public void push(Map<String,Float> map){
        notifyObserver(map);
    }
	
    @Override
    public int size() {
        return observers.size();
    }
	// 清理 Observers
    public void clearObservers(){
        observers.clear();
    }
}

通常基礎的觀察者模式的落地實現，一般會有一個變數控制：booble change。

change 表示標記已經改變的事實。

在 java.util.Observable 中就有一個這個變數，其主要作用是由主題來規定是否更新數據。

可能有些值需要一定的量變才能代表其數據價值。並不是每次變動都要通知所有訂閱者更新數據。

而觀察者更新數據的方式又分為 主動推送（push） 和 觀察者拉取（pull）：

如果有一定量的數據，並不是每個觀察者都需要主題推送所有數據，可能只需要個別數據，這個時候就可以向外部暴露介面，讓觀察者拉取所需要的數據。

4. 實現 Observer 介面類 —— DefaultObserver、BaseObserver

4.1 DisplayElement

public interface DisplayElement {
    void display();
}

所有 Observer 都需要實現這個方法，用於顯示列印不同觀察者的內容。代表觀察者的數據內容展示。

4.2 BaseObserver

使用的是推送數據。

public class BaseObserver implements Observer, DisplayElement {
    private float temperature;
    private float humidity;
    private float light;
    private float co_2;

    private Subject subject;
    
    @Override
    public void update(Object arg) {
        // 解析 arg
        if (arg instanceof HashMap){
            Map<String, Float> map = (Map<String, Float>) arg;
            this.temperature = map.get("temperature");
            this.co_2 = map.get("co_2");
            this.light = map.get("light");
            this.humidity = map.get("humidity");
        }
        display();

    }


    @Override
    public void display() {
        System.out.println("BaseObserver Context temperature : " + this.temperature
                + " humidity : " + this.humidity + " light : " + this.light + " Co_2 : " + this.co_2);
    }
    
    public BaseObserver(Subject subject) {
        this.subject = subject;
    }
	
    // 取消訂閱
    public void unsubscribe() {
        subject.removeObserver(this);
    }
    
	// 設置主題
    public void setSubject(Subject subject) {
        this.subject = subject;
    }

}

4.3 DefaultObserver

使用的是拉取數據

public class DefaultObserver implements Observer, DisplayElement {
    private float temperature;
    private float humidity;
    private  Subject subject;

    public DefaultObserver(Subject subject) {
        this.subject = subject;
    }

    @Override
    public void update(Object arg) {
        // 如果 arg 是 null 則主動拉取
        if (subject instanceof WeatherData) {
            WeatherData weatherData = (WeatherData) subject;
            this.temperature = weatherData.getTemperature();
            this.humidity = weatherData.getHumidity();
        }
        display();
    }

    public void unsubscribe() {
        subject.removeObserver(this);
    }
    // 重置 Subject 引用
    public void setSubject(Subject subject) {
        this.subject = subject;
    }

    @Override
    public void display() {
        System.out.println("DefaultObserver Context temperature : " + this.temperature + " humidity : " + this.humidity);
    }
}

5. 測試效果

@Test
public void test01(){
    // 主題
    WeatherData weatherData = new WeatherData();

    // 準備兩個觀察者
    DefaultObserver observer = new DefaultObserver(weatherData);
    BaseObserver baseObserver = new BaseObserver(weatherData);

    // 將觀察者訂閱到列表中
    weatherData.addObserver(observer);
    weatherData.addObserver(baseObserver);

    // 主題更新數據
    weatherData.setManager(32.5f,20.6f,155.6f,16.9f);
    weatherData.setManager(30.2f,26.9f,504.6f,19.9f);
    weatherData.setManager(28.9f,10.6f,400.1f,30.9f);
}

已知主題預設是推送：

image-20230314162802133

只有 BaseObserver 才有數據更新。

設置 weatherData.setPush(false); 改為由觀察者拉取數據。

image-20230314162906031

註意：上面將拉取和推送單獨分開了。從而導致在推送時，拉取不到新的數據，反之亦然。

5.1 測試觀察者取消訂閱

// 主題更新數據
weatherData.setManager(32.5f,20.6f,155.6f,16.9f);
observer.unsubscribe();
weatherData.setManager(30.2f,26.9f,504.6f,19.9f);
weatherData.setManager(28.9f,10.6f,400.1f,30.9f);

image-20230314163348970

結果符合預期。

5.2 測試主題清空觀察者列表

// 主題更新數據
weatherData.setManager(32.5f,20.6f,155.6f,16.9f);
weatherData.clearObservers();
weatherData.setManager(30.2f,26.9f,504.6f,19.9f);
weatherData.setManager(28.9f,10.6f,400.1f,30.9f);

image-20230314163555151

JDK 中的 Observable 可觀察者

上面的代碼是在學習了觀察者模式以及 Observable 之後進行一些修改的。

JDK 中有觀察者模式的實現方案：Observable 和 Observer。但是在 JDK 9 中被廢棄了，因為存在一些問題。其中最主要的是 Observable 是一個類，不易於擴展，以及各種安全問題。而 Observer 又依賴於 Observable。

所以這些問題就是 Observable 的黑暗面。

在 Swing 中，也有運用到過觀察者模式。

總結

簡單來說觀察者模式是典型的一對多結構。觀察者模式可以方便統一的更新訂閱者的數據，觀察者可以從主題中獲取對應的數據，不關心數據如何產生，以及如何傳遞，只關心如何使用這些數據。而主題只維護好觀察者列表，當數據更新時根據業務情況去通知所有訂閱的觀察者。達到松耦合、可擴展、易維護的目的。

自己對於模式的一個淺層理解和簡單代碼實現，可以根據自己的想法圍繞著該模式的定義進行設計，也可以看其他優秀的博客和優質的代碼，學習精華和思想。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • webgl 系列 —— 漸變三角形
    其他章節請看： webgl 系列 漸變三角形 本文通過一個漸變三角形的示例逐步分析：varying變數、合併緩衝區、圖形裝配、光柵化、varying 內插 繪製三個點v1 需求：繪製三個相同顏色的點，效果如下： 通過三角形的學習，這個需求非常容易實現。代碼如下： const VSHADER_SOUR ...
  • [Vue3] 組件上的ref不能與組件名相同
    情景 關鍵 組件沒有正確引入 函數無限遞歸 解決 如果在網上搜索[Vue warn]: Component is missing template or render function. 或[Vue warn]: Invalid vnode type when creating vnode: nul ...
  • 記錄--你不知道的forEach函數
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 老實說我不喜歡用forEach，因為它導致的一些bug總是這麼不經意，盤點我不喜歡的原因 原因一：不支持處理非同步函數 先看一個例子： async function test() { let arr = [3, 2, 1] arr.forE ...
  • 一文帶你瞭解 JS Module 的始末
    寫在前面 模塊化開發是我們日常工作潛移默化中用到的基本技能，發展至今非常地簡潔方便，但開發者們（指我自己）卻很少能清晰透徹地說出它的發展背景， 發展過程以及各個規範之間的區別。故筆者決定一探乾坤，深入淺出學習一下什麼是前端模塊化。 通過本文，筆者希望各位能夠收穫到： 前端模塊化發展的大致歷史背景 � ...
  • Vue項目遷移小程式，實操乾貨分享
    代碼如下： 我這邊用的阿裡OSS直傳的，主要思路是獲取截圖對象，粘貼到指定div位置，獲取文件流，將文件流賦值給clientUpload方法。 使用wx/qq 快捷指令就可以截圖上傳圖片了。 <div class="layui-form-item"> <label class="layui-form ...
  • C/S架構和B/S架構兩種數字孿生技術路線的區別是什麼？
    山海鯨可視化創造了一種CS和BS熱切換的編輯模式，即CSaaS架構，可以在安裝軟體之後一鍵從軟體的CS狀態切換為一個BS伺服器，讓私有化部署變得十分輕鬆。在視頻中我們先在CS模式下的軟體中進行了編輯，隨後熱切換到BS模式下的web中依然可以在幾乎完全相同的體驗下進行編輯。 ...
  • 藍牙-低功耗中心設備
    代理模式（Proxy Pattern）：前端設計模式中的代理模式是一種結構型模式，它允許在不改變原始對象的情況下，通過引入一個代理對象來控制對原始對象的訪問。代理對象充當原始對象的中介，客戶端與代理對象交互，代理對象再將請求轉發給原始對象。 代理模式在前端開發中經常被用來處理一些複雜或者耗時的操作， ...
  • 【讀書筆記】你不知道的JavaScript（中）
    第一部分 類型和語法 第一章 類型 JavaScript 有七種內置類型： • 空值（null） • 未定義（undefined） • 布爾值（ boolean） • 數字（number） • 字元串（string） • 對象（object） • 符號（symbol，ES6 中新增） typeof ...
一周排行
    -Advertisement-
    Play Games
  • abp(net core)+easyui+efcore實現倉儲管理系統——ABP升級7.3上(五十八)
    @ 先看一下導出的整體效果（如下圖），其中標註的區域都是通過後臺動態生成的： 一、先在Word中建立好表格模板 1.1、參數創建方法（Word和WPS） 1.1.1、Office中Word域的創建 1.1.1.1、選中指定的單元格 -> 點擊頭部工具欄中的”插入“ -> 選擇 ”文檔部件“ -> 選 ...
  • .NET6+Quartz實現定時任務
    在實際工作中，經常會有一些需要定時操作的業務，如：定時發郵件，定時統計信息等內容，那麼如何實現才能使得我們的項目整齊劃一呢？本文通過一些簡單的小例子，簡述在.Net6+Quartz實現定時任務的一些基本操作，及相關知識介紹，僅供學習分享使用，如有不足之處，還請指正。 ...
  • 將紙殼CMS通知通過WebHook發送到釘釘
    紙殼CMS支持將評論、留言、表單提交、訂閱等通知，通過WebHook發送到第三方平臺，比如釘釘。 創建釘釘WebHook 需要在釘釘群中創建自定義機器人，具體方法可以參考釘釘的官方文檔： 自定義機器人接入 需要註意的是，在安全設置中不要使用加簽，使用自定義關鍵字即可。在發送的消息中，只要包含這個關鍵 ...
  • javaSE學習Day1之多態及向下轉型
    向下轉型的使用 Java的多態性： 父類指向子類的聲明 Animal animal = new Dog()//Dog()重寫了父類Animal 有了對象的多態性以後，記憶體實際上載入的是==子類==的屬性和方法，但是由於變數聲明為==父類類型==，導致編譯時只能調用父類的屬性和方法，子類特有的屬性方法 ...
  • spring源碼環境搭建
    spring源碼環境搭建 組件 版本 jdk 1.8.0_192 spring-framework 5.3.x gradle 7.5.1 idea 2022.3.3 aspectJ 1.9 可根據spring-framwork項目說明靈活選擇 一、拉取spring-framework項目 1、spr ...
  • PLG SaaS 案例：如何實踐外鏈自動增長策略？
    首先任何的商業邏輯，光流量增長，沒法變現是沒用的。 就像博客群發提效工具，得有對應的用戶，更得有對應付費用戶群體的畫像。剩下的就是靠增長，被動讓他們找到你的產品，用產品解決他們痛點，他們自然而然會付費。 下麵大致分享下從三個方向分享下： 用戶痛點 -> 真正的付費用戶群體 產品價值 PLG 增長 一 ...
  • javaSE學習Day1之Object類的使用
    Object類的使用 Object類 Object類中的方法可以在網上搜索得到 Object類是所有java類的父類 如果類在聲明中未使用extends關鍵字指明其父類，則預設父類為java.lang.Object類 Object類中的功能(屬性、方法)具有通用性。 屬性：無 方法：equals() ...
  • Qt源碼閱讀(二) moveToThread
    Qt 源碼分析之moveToThread 這一次，我們來看Qt中關於將一個QObject對象移動至一個線程的函數moveToThread Qt使用線程的基本方法 首先，我們簡單的介紹一下在Qt中使用多線程的幾種方法: 重寫QThread的run函數，將要在多線程執行的任務放到run函數里 /*myt ...
  • javaSE學習Day1之包裝類的使用
    包裝類的使用 包裝類的使用 java提供8種基本數據類型對應的包裝類，使得基本數據類型變數具有類的特征 掌握：==基本數據類型、包裝類、String==三者之間的互相轉換 自動裝箱與自動拆箱==[基本數據類型和包裝類的轉換]== JDK5.0新特性，自動裝箱與自動拆箱。 class Test{ pu ...
  • 面試官：如何保證介面冪等性？一口氣說了9種方法！
    本文已經收錄到Github倉庫，該倉庫包含電腦基礎、Java基礎、多線程、JVM、資料庫、Redis、Spring、Mybatis、SpringMVC、SpringBoot、分散式、微服務、設計模式、架構、校招社招分享等核心知識點，歡迎star~ Github地址 大家好，我是大彬~ 今天來聊聊接 ...
所有分類