觀察者模式——學習筆記

来源: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
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類