【觀察者設計模式詳解】C/Java/JS/Go/Python/TS不同語言實現

来源:https://www.cnblogs.com/letjs/archive/2023/04/21/17340897.html
-Advertisement-
Play Games

簡介 觀察者模式（Observer Pattern）是一種行為型模式。它定義對象間的一種一對多的依賴關係，當一個對象的狀態發生改變時，所有依賴於它的對象都得到通知並被自動更新。 觀察者模式使用三個類Subject、Observer和Client。Subject對象帶有綁定觀察者到Client對象和從 ...


簡介

觀察者模式（Observer Pattern）是一種行為型模式。它定義對象間的一種一對多的依賴關係，當一個對象的狀態發生改變時，所有依賴於它的對象都得到通知並被自動更新。

觀察者模式使用三個類Subject、Observer和Client。Subject對象帶有綁定觀察者到Client對象和從Client對象解綁觀察者的方法。我們創建Subject類、Observer抽象類和擴展了抽象類Observer的實體類。

作用

  1. 一個對象狀態更新，其他依賴對象收到通知和自動更新的機制。
  2. 實現模塊化分離，實現主題與觀察者交互對象之間的松耦合。
    1）觀察者定義了對象之間一對多的關係。
    2）被觀察者(主題)用一個共同的介面來更新觀察者。
    3）觀察者和被觀察者用松耦合方式結合，被觀察者不知道觀察者的細節，只知道觀察者實現了觀察者介面。

實現步驟

  1. 創建觀察者observer基礎介面，包含主題和更新方法
  2. 創建主題subject抽象類，包含observer列表以及添加和刪除方法
  3. 創建具體的主題類，實現通知方法，發佈通知時輪詢通知全部觀察者
  4. 創建多個具體觀察者，與主題關聯，並實現自己的更新方法
  5. 客戶調用時先聲明主題，再將觀察者分別添加到主題，當主題發佈通知時，觀察者自動更新

UML

 

 

Java代碼

觀察者介面

// ObserverAPI.java 觀察者介面，Java 9已經預設支持Observer介面
// 這裡避免衝突採取ObserverAPI命名
public interface ObserverAPI {
   public Subject subject = null;
   public void update(String content);
}

具體觀察者

// ConcreteObserver.java 具體的觀察者實現類，也可以看成訂閱者，關聯對應的主題類。
// 不同的觀察者也可以對應多個主題
public class ConcreteObserver implements ObserverAPI {

   public Subject subject;

   // 給觀察者綁定主題，同時把觀察者添加到主題列表
   public ConcreteObserver(Subject subject) {
      this.subject = subject;
      this.subject.register((ObserverAPI) this);
   }

   // 觀察者發出更新通知，不用單獨告訴訂閱者，由訂閱者自行監聽
   public void update(String content) {
      System.out.println(String.format("%s::update() [subject.name = %s content = %s]",
            this.getClass().getName(),
            this.subject.getName(), content));
   }
}

// ConcreteObserver2.java 具體的觀察者實現類，也可以看成訂閱者，關聯對應的主題類。
// 不同的觀察者可以對應不同的主題。
public class ConcreteObserver2 implements ObserverAPI {

  // 這裡沒有在構造器就綁定某個主題，而是從客戶角度去註冊觀察者
  public ConcreteObserver2() {
  }

  // 觀察者發出更新通知，觀察者自行監聽
  public void update(String content) {
    System.out.println(String.format("%s::update() [content = %s]",
        this.getClass().getName(), content));
  }
}

抽象主題類

// Subject.java 定義抽象主題類或者介面，供具體主題類繼承
public abstract class Subject {
   private String name;
   // protected Set<ObserverAPI> observers = new HashSet<>();
   protected List<ObserverAPI> observers = new ArrayList<>();

   public String getName() {
      return name;
   }

   public void setName(String name) {
      this.name = name;
   }

   public void register(ObserverAPI observer) {
      System.out.println(this.getClass().getName() + "::register() [observer = " + observer.getClass().getSimpleName() + "]");
      observers.add(observer);
   }

   public void remove(ObserverAPI observer) {
      observers.remove(observer);
   }

   // 通知由具體類來實現邏輯
   public abstract void notify(String name);
}

具體主題類

// ConcreteSubject.java 觀察者主題類，也是發佈者，重寫具體的通知方法。不同主題可以關聯不同的觀察者。
public class ConcreteSubject extends Subject {

   public ConcreteSubject(String name) {
      this.setName(name);
   }

   // 不同的主題類有自己的通知方法，批量通知綁定的觀察者
   @Override
   public void notify(String content) {
      System.out.println(this.getClass().getName() + "::notify() [content = " + content + "]");
      for (Object observer : this.observers) {
         ((ObserverAPI) observer).update(content);
      }

   }

}

測試調用

    /**
     * 觀察者模式應用非常廣泛，主要是觀察者提前綁定到發佈者
     * 當發佈者發佈消息時，批量廣播通知，而無需逐一通知
     * 觀察者監聽到消息後自己決定採取哪一種行為
     */

    // 定義一個主題，也就是發佈者
    Subject concreteSubject = new ConcreteSubject("subject1");
    // 再聲明觀察者，通過構造器註冊到主題上
    ObserverAPI observer1 = new ConcreteObserver(concreteSubject);

    // 也可以單獨給主題註冊一個新的觀察者
    concreteSubject.register(new ConcreteObserver2());
    // 可以移除觀察者對象，可以打開註釋試下
    // concreteSubject.remove(observer1);

    // 主題開始發佈新通知，各觀察者自動更新
    concreteSubject.notify("hello, this is broadcast.");

Python代碼

觀察者介面

# ObserverAPI.py 觀察者抽象父類，定義一些公共方法
class ObserverAPI:

    def __init__(self, name):
        self.name = name

    # 觀察者發出更新通知，觀察者自行監聽
    def update(self, content):
        print(self.__class__.__name__ + '::update() [content = ' + content + ']')

    def set_name(self, name):
        self.name = name

具體觀察者

# ConcreteObserver.py 具體的觀察者實現類，也可以看成訂閱者，關聯對應的主題類。
# 不同的觀察者也可以對應多個主題
from src.ObserverAPI import ObserverAPI

# 具體的觀察者實現類，也可以看成訂閱者，關聯對應的主題類。
# 不同的觀察者也可以對應多個主題


class ConcreteObserver(ObserverAPI):
    # 給觀察者綁定主題，同時把觀察者添加到主題列表
    def __init__(self, subject, name):
        ObserverAPI.__init__(self, name)
        
        # python3支持的父類調用
        # super(ConcreteObserver, self).__init__(name)
        # super().__init__(name)

        self.subject = subject
        subject.register(self)

    # 觀察者發出更新通知，不用單獨告訴訂閱者，由訂閱者自行監聽
    def update(self, content):
        print(self.__class__.__name__ + '::update() [subject.name = ' +
              self.subject.name + ' content = ' + content + ']')

# ConcreteObserver2.py 具體的觀察者實現類，也可以看成訂閱者，關聯對應的主題類。
# 不同的觀察者可以對應不同的主題。
from src.ObserverAPI import ObserverAPI


# 具體的觀察者實現類，也可以看成訂閱者，關聯對應的主題類。
# 不同的觀察者可以對應不同的主題。
class ConcreteObserver2(ObserverAPI):
    # 這裡沒有在構造器就綁定某個主題，而是從客戶角度去註冊觀察者
    # 觀察者發出更新通知，觀察者自行監聽

    # def update(self, content):
    #     print(self.__class__.__name__ + '::update() [content = ' + content +']')
    
    pass

抽象主題類

# Subject.py 定義抽象主題類或者介面，供具體主題類繼承
class Subject:

    def __init__(self, name):
        self.name = name
        self.observers = []

    def get_name(self):
        return self.name

    def set_name(self, name):
        self.name = name

    def register(self, observer):
        print(self.__class__.__name__ + '::register() [observer = ' +
              observer.__class__.__name__ + ']')

        self.observers.append(observer)

    def remove(self, observer):
        self.observers.remove(observer)

    # 通知由具體類來實現邏輯
    def notify(self, name):
        pass

具體主題類

// ConcreteSubject.py 觀察者主題類，也是發佈者，重寫具體的通知方法。不同主題可以關聯不同的觀察者。
from src.Subject import Subject


# 觀察者主題類，也是發佈者，重寫具體的通知方法。不同主題可以關聯不同的觀察者。
class ConcreteSubject(Subject):
    # 不同的主題類有自己的通知方法，批量通知綁定的觀察者
    def notify(self, content):
        print(self.__class__.__name__ + '::notify() [content = ' + content +
              ']')
        for observer in self.observers:
            observer.update(content)

測試調用

import sys
import os

os_path = os.getcwd()
sys.path.append(os_path)

from src.ConcreteSubject import ConcreteSubject
from src.ConcreteObserver import ConcreteObserver
from src.ConcreteObserver2 import ConcreteObserver2


def test():
    '''
    * 觀察者模式應用非常廣泛，主要是觀察者提前綁定到發佈者
    * 當發佈者發佈消息時，批量廣播通知，而無需逐一通知
    * 觀察者監聽到消息後自己決定採取哪一種行為
    '''

    # 定義一個主題，也就是發佈者
    concrete_subject = ConcreteSubject('subject1')
    # 再聲明觀察者，通過構造器註冊到主題上
    observer1 = ConcreteObserver(concrete_subject, 'observer1')
    # 也可以單獨給主題註冊一個新的觀察者
    observer2 = ConcreteObserver2('observer2')
    concrete_subject.register(observer2)
    # 可以移除觀察者對象
    # concrete_subject.remove(observer1)

    # 主題開始發佈新通知，各觀察者自動更新
    concrete_subject.notify('hello, this is broadcast.')


if __name__ == '__main__':
    print(__file__)
    print("test start:")
    test()

更多語言版本

不同語言實現設計模式：https://github.com/microwind/design-pattern


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

-Advertisement-
Play Games
更多相關文章
  • 漏了一個“/”導致的跨域錯誤(CORS)
    在成功搭建好DRF(Django rest framework)的Blog的backend後,昨天開始搭建Vue3+axios+pinia+element_plus的前臺服務. 開始一切順利,到第一個axios的get處理的時候,出現了錯誤. axios相關的代碼如下: 載入vue-axios和ax ...
  • 記錄-實現深拷貝的四種方式
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 概念介紹 深拷貝：在堆記憶體中重新開闢一個存儲空間，完全克隆一個一模一樣的對象 淺拷貝：不在堆記憶體中重新開闢空間，只複製棧記憶體中的引用地址。本質上兩個對象（數組）依然指向同一塊存儲空間 第一種：遞歸方式（推薦，項目中最安全最常用） 使用遞歸 ...
  • vue全家桶進階之路50：Vue3 環境變數+跨域設置實例
    使用.env加尾碼的方式來建立某個模式下的環境變數， 例如：項目根目錄新建兩個環境變數文件（development開發環境和production生產環境）： .env.development .env.production 在新建的兩個環境變數文件中設置相同的環境變數名： VUE_APP_BASE_ ...
  • Vue3 代碼塊高亮顯示並可使用富文本編輯器編輯（highlight.js + wangEditor）
    一、簡單瞭解JS 1. JavaScript（簡稱JS）是作為開發Web頁面的腳本語言。 2. JS是從1995年由網景公司的布蘭德開發。 3. JavaScript的標準是ECMAScript。 4. JS代碼是從上往下執行的。 二、變數 1. 變數名的值可以重覆賦值（值可以修改），變數可以重覆聲 ...
  • HTML input type="number" 隱藏預設的步進箭頭
    HTML input type="number" 隱藏預設的步進箭頭 number 類型的 <input> 元素用於讓用戶輸入一個數字，其包括內置驗證以拒絕非數字輸入。 瀏覽器可能會選擇提供步進箭頭，讓用戶可以使用滑鼠增加和減少輸入的值，或者只需用指尖敲擊即可。但有些場景需要隱藏預設的步進箭頭。 要 ...
  • vue全家桶進階之路48：Vue3 跨域配置devServer的參數和設置
    devServer 是一個用於配置開發伺服器的選項對象。它可以用來配置伺服器的各種選項，例如代理，埠號，HTTPS 等。 以下是一些常用的 devServer 參數和設置： port：指定開發伺服器的埠號，預設為 8080。 host：指定開發伺服器的主機名，預設為 localhost。 htt ...
  • 【數據中台商業化】數據中台微前端實踐
    我們設計目前的門戶基座，可以快速瀏覽各個平臺，同時串聯數據開發與管理的工作，減少用戶的試錯成本，提升工作效率。 ...
  • vue全家桶進階之路47：Vue3 Axios攔截器封裝成request文件
    可以將Axios攔截器封裝成一個單獨的request文件，以便在整個應用程式中重覆使用。 以下是一個示例，展示如何將Axios攔截器封裝成一個request文件： 1、創建一個名為request.js的新文件，並導入Axios： import axios from 'axios'; 2、創建一個名為 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類