觀察者模式——學習筆記

来源: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
  • （開源）都進來！簡單易懂、功能強大的許可權+可視化流程管理系統
    1、預覽地址：http://139.155.137.144:9012 2、qq群:801913255 一、前言 隨著網路的發展，企業對於信息系統數據的保密工作愈發重視，不同身份、角色對於數據的訪問許可權都應該大相徑庭。 列如 1、不同登錄人員對一個數據列表的可見度是不一樣的，如數據列、數據行、數據按鈕 ...
  • 設計模式-C#實現簡單工廠模式
    前言 上一篇文章寫瞭如何使用RabbitMQ做個簡單的發送郵件項目，然後評論也是比較多，也是準備去學習一下如何確保RabbitMQ的消息可靠性，但是由於時間原因，先來說說設計模式中的簡單工廠模式吧！ 在瞭解簡單工廠模式之前，我們要知道C#是一款面向對象的高級程式語言。它有3大特性，封裝、繼承、多態。 ...
  • Nodify學習 一：介紹與使用
    Nodify學習 一：介紹與使用 - 可樂_加冰 - 博客園 (cnblogs.com) Nodify學習 二：添加節點 - 可樂_加冰 - 博客園 (cnblogs.com) 介紹 Nodify是一個WPF基於節點的編輯器控制項，其中包含一系列節點、連接和連接器組件，旨在簡化構建基於節點的工具的過程 ...
  • 使用C#/.NET解析Wiki百科數據實現獲取歷史上的今天
    創建一個webapi項目做測試使用。 創建新控制器，搭建一個基礎框架，包括獲取當天日期、wiki的請求地址等 創建一個Http請求幫助類以及方法，用於獲取指定URL的信息 使用http請求訪問指定url，先運行一下，看看返回的內容。內容如圖右邊所示，實際上是一個Json數據。我們主要解析 大事記 部 ...
  • .NET科普：.NET簡史、.NET Standard以及C#和.NET Framework之間的關係
    最近在不少自媒體上看到有關.NET與C#的資訊與評價，感覺大家對.NET與C#還是不太瞭解，尤其是對2016年6月發佈的跨平臺.NET Core 1.0，更是知之甚少。在考慮一番之後，還是決定寫點東西總結一下，也回顧一下.NET的發展歷史。 首先，你沒看錯，.NET是跨平臺的，可以在Windows、 ...
  • Nodify學習 二：添加節點
    Nodify學習 一：介紹與使用 - 可樂_加冰 - 博客園 (cnblogs.com) Nodify學習 二：添加節點 - 可樂_加冰 - 博客園 (cnblogs.com) 添加節點（nodes） 通過上一篇我們已經創建好了編輯器實例現在我們為編輯器添加一個節點 添加model和viewmode ...
  • 論如何直接用EF Core實現創建更新時間、用戶審計，自動化樂觀併發、軟刪除和樹形查詢（上）
    前言 資料庫併發，數據審計和軟刪除一直是數據持久化方面的經典問題。早些時候，這些工作需要手寫複雜的SQL或者通過存儲過程和觸發器實現。手寫複雜SQL對軟體可維護性構成了相當大的挑戰，隨著SQL字數的變多，用到的嵌套和複雜語法增加，可讀性和可維護性的難度是幾何級暴漲。因此如何在實現功能的同時控制這些S ...
  • C# 使用模式匹配的好處,因為好用所以推薦~
    類型檢查和轉換：當你需要檢查對象是否為特定類型，並且希望在同一時間內將其轉換為那個類型時，模式匹配提供了一種更簡潔的方式來完成這一任務，避免了使用傳統的as和is操作符後還需要進行額外的null檢查。 複雜條件邏輯：在處理複雜的條件邏輯時，特別是涉及到多個條件和類型的情況下，使用模式匹配可以使代碼更 ...
  • 推薦一種批量判斷文件是否存在的快速辦法
    在日常開發中，我們經常需要和文件打交道，特別是桌面開發，有時候就會需要載入大批量的文件，而且可能還會存在部分文件缺失的情況，那麼如何才能快速的判斷文件是否存在呢？如果處理不當的，且文件數量比較多的時候，可能會造成卡頓等情況，進而影響程式的使用體驗。今天就以一個簡單的小例子，簡述兩種不同的判斷文件是否... ...
  • 論如何直接用EF Core實現創建更新時間、用戶審計，自動化樂觀併發、軟刪除和樹形查詢（中）
    前言 資料庫併發，數據審計和軟刪除一直是數據持久化方面的經典問題。早些時候，這些工作需要手寫複雜的SQL或者通過存儲過程和觸發器實現。手寫複雜SQL對軟體可維護性構成了相當大的挑戰，隨著SQL字數的變多，用到的嵌套和複雜語法增加，可讀性和可維護性的難度是幾何級暴漲。因此如何在實現功能的同時控制這些S ...
所有分類