Java觀察者模式-SpringBoot實現觀察者模式

来源:https://www.cnblogs.com/kakarotto-chen/archive/2023/10/10/17755295.html
-Advertisement-
Play Games

觀察者模式 一、Java觀察者模式 Java觀察者模式是一種設計模式，用於實現對象之間的一對多依賴關係。在觀察者模式中，當一個對象的狀態發生變化時，它的所有依賴對象（觀察者）都會自動收到通知併進行相應的更新。 觀察者模式由以下幾個核心組件組成： 主題（Subject）：也稱為被觀察者或可觀察對象，它 ...


觀察者模式

一、Java觀察者模式

Java觀察者模式是一種設計模式，用於實現對象之間的一對多依賴關係。在觀察者模式中，當一個對象的狀態發生變化時，它的所有依賴對象（觀察者）都會自動收到通知併進行相應的更新。

觀察者模式由以下幾個核心組件組成：

  1. 主題（Subject）：也稱為被觀察者或可觀察對象，它維護一組觀察者對象，並提供方法用於添加、刪除和通知觀察者。
  2. 觀察者（Observer）：也稱為訂閱者或監聽器，它定義了接收和處理主題通知的方法。
  3. 具體主題（ConcreteSubject）：實現主題介面，維護觀察者列表，併在狀態發生變化時通知觀察者。
  4. 具體觀察者（ConcreteObserver）：實現觀察者介面，定義了接收和處理主題通知的具體邏輯。

觀察者模式的工作流程如下：

  1. 觀察者通過訂閱主題來註冊自己，使得主題知道它們的存在。
  2. 當主題的狀態發生變化時，它會通知所有註冊的觀察者。
  3. 觀察者收到通知後，根據需要進行相應的更新操作。

觀察者模式的優點包括解耦主題和觀察者，使得它們可以獨立變化；支持動態添加和刪除觀察者；實現了對象之間的松耦合，提高了系統的靈活性和可擴展性。

  • 場景1：用圖來理解：

image

  • 場景2：多模塊開發，解耦情況下，可以模塊之間傳遞參數。

二、Spring實現的觀察者模式

1、設計理念

在Spring Boot中，實現觀察者模式的設計理念是基於事件驅動的編程模型。Spring Boot提供了一種簡單而強大的事件機制，可以方便地實現觀察者模式。

以下是Spring Boot實現觀察者模式的設計理念：

  1. 事件（Event）：事件是觸發的動作或狀態變化，可以是任何Java對象。在Spring Boot中，事件通常是繼承自ApplicationEvent類的對象。

  2. 事件發佈者（Event Publisher）：事件發佈者負責發佈事件。在Spring Boot中，可以使用ApplicationEventPublisher介面來發佈事件。通常，事件發佈者是一個Spring Bean，通過依賴註入ApplicationEventPublisher來發佈事件。

  3. 事件監聽者（Event Listener）：事件監聽者是觀察者，負責接收和處理事件。在Spring Boot中，可以使用@EventListener註解標記方法，使其成為事件監聽者。當事件發佈者發佈事件時，被標記的方法會自動被調用。

  4. 事件處理邏輯：事件監聽者方法中定義了事件的處理邏輯。可以根據具體需求，在事件監聽者方法中編寫相應的業務邏輯。

通過使用Spring Boot的事件機制，可以實現松耦合的觀察者模式。事件發佈者和事件監聽者之間沒有直接的依賴關係，它們通過事件進行通信。這樣，可以方便地添加、刪除和修改事件監聽者，而不需要修改事件發佈者的代碼。

觀察者模式的設計理念在Spring Boot中體現了面向對象編程的原則，如單一職責、開閉原則和依賴倒置原則。它提供了一種靈活、可擴展和可維護的方式來實現事件驅動的編程模型。

2、繼承ApplicationEvent和不繼承的區別

  • 發送的參數可以是普通JavaBean（String、integer、自定義類）、也可以是繼承了ApplicationEvent的JavaBean
如果MyEvent繼承ApplicationEvent，則可以使用Spring框架提供的事件傳遞機制。這意味著可以通過ApplicationEventPublisher發佈事件，並且可以使用@EventListener註解標記觀察者方法來接收事件。這種方式更符合Spring框架的設計理念，可以方便地實現觀察者模式。

如果MyEvent不繼承ApplicationEvent，則無法使用Spring框架提供的事件傳遞機制。需要自己實現事件的傳遞和觀察者模式的邏輯。這種方式更適用於非Spring環境下的觀察者模式實現。

繼承ApplicationEvent的好處是可以利用Spring框架提供的事件傳遞機制，簡化了觀察者模式的實現。同時，還可以利用Spring框架提供的其他特性，如事務管理、AOP等。

不繼承ApplicationEvent的好處是更加靈活，可以根據具體需求自由定義事件的結構和傳遞方式。但需要自己實現事件的傳遞和觀察者模式的邏輯。

綜上所述，如果在Spring框架中使用觀察者模式，建議繼承ApplicationEvent，以便利用Spring框架提供的事件傳遞機制和其他特性。

3、預設是廣播模式

Spring框架中的觀察者模式預設是廣播模式。

在Spring框架中，當一個事件被髮布時，所有註冊的觀察者都會接收到該事件。這意味著，一個事件可以被多個觀察者同時接收和處理，實現了廣播的效果。

這種廣播模式的實現是通過ApplicationEventMulticaster介面和其預設實現類SimpleApplicationEventMulticaster來完成的。SimpleApplicationEventMulticaster會將事件廣播給所有註冊的觀察者。

當然，如果需要更加細粒度地控制事件的傳遞方式，也可以自定義ApplicationEventMulticaster的實現類，實現自己的事件傳遞邏輯。

總結起來，Spring框架中的觀察者模式預設是廣播模式，一個事件會被所有註冊的觀察者接收和處理。這種廣播模式的實現是通過ApplicationEventMulticaster介面和SimpleApplicationEventMulticaster類來完成的。

三、實現

1、廣播模式（預設）——不推薦

  • 事件 —— 這裡先不用，也可以用
  • 這裡發送普通的JavaBean的參數，不發送“事件”

1.1、事件（Event）（無）

1.2、事件發佈者（Event Publisher）

  • 註入ApplicationEventPublisher來實現
package com.cc.jsl.service.impl;

import com.cc.jsl.service.ILoginService;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * <p>事件發佈者（Event Publisher）</p>
 *
 * @author CC
 * @since 2023/10/10
 */
@Service
public class LoginServiceImpl implements ILoginService {

    @Resource
    private ApplicationEventPublisher eventPublisher;

    @Override
    public void login(){
        //登陸邏輯...

        //發送
        // 1、可以直接發送JavaBean的參數：如String、自定義類
        eventPublisher.publishEvent("字元串參數！");
//        eventPublisher.publishEvent(new UserCs("cs" , 18));
//        eventPublisher.publishEvent(34);
        // 2、發送事件參數（繼承了ApplicationEvent的類）

    }

}

1.3、事件監聽者（Event Listener）

  • 使用@Async、@EventListener實現
  • 可以是很多個，也可以在不同類中
package com.cc.jsl.listener;

import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * <p>事件監聽者（Event Listener）</p>
 *
 * @author CC
 * @since 2023/10/10
 */
@Component
public class ReceiveListener {

    /**
     * 打電話 - 接收普通JavaBean參數
     */
    @Async
    @EventListener
    public void sendCall(String msg) {
        //發送郵件邏輯
        System.out.println("打電話！-普通-> " + msg);
    }

    /**
     * 發送郵件 - 接收字元串參數
     */
    @Async
    @EventListener
    public void sendEmail(String msg) {
        //發送郵件邏輯
        System.out.println("發送郵件！-普通-> " + msg);
    }
}

2、單個發送（推薦）

  • 每個發送都自定義一個唯一的類，並且繼承ApplicationEvent

2.1、事件（Event）

  • 繼承ApplicationEvent
  • 繼承ApplicationEvent的好處是可以利用Spring框架提供的事件傳遞機制，簡化了觀察者模式的實現。同時，還可以利用Spring框架提供的其他特性，如事務管理、AOP等。
package com.cc.jsl.event;

import lombok.Getter;
import lombok.Setter;
import org.springframework.context.ApplicationEvent;

/**
 * <p>發郵件專屬的唯一事件</p>
 * <p>需要實現set方法</p>
 *
 * @author CC
 * @since 2023/10/10
 */
@Getter
@Setter
public class EmailEvent extends ApplicationEvent {

    /**
     * 參數1
     */
    private String name;

    /**
     * 參數2
     */
    private Integer age;

    public EmailEvent(Object source, String name, Integer age) {
        super(source);
        this.name = name;
        this.age = age;
    }
}

2.2、事件發佈者（Event Publisher）

package com.cc.jsl.service.impl;

import com.cc.jsl.event.EmailEvent;
import com.cc.jsl.service.ILoginService;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * <p>事件發佈者（Event Publisher）</p>
 *
 * @author CC
 * @since 2023/10/10
 */
@Service
public class LoginServiceImpl implements ILoginService {

    @Resource
    private ApplicationEventPublisher eventPublisher;

    @Override
    public void login(){
        //登陸邏輯...

        //事件發佈
        // 1、可以直接發送JavaBean的參數：如String、自定義類
//        eventPublisher.publishEvent("字元串參數！");
//        eventPublisher.publishEvent(new UserCs("cs" , 18));
//        eventPublisher.publishEvent(34);

        // 2、發送事件參數（繼承了ApplicationEvent的類）
        EmailEvent emailEvent = new EmailEvent(this, "cc", 18);
        eventPublisher.publishEvent(emailEvent);
    }
}

2.3、事件監聽者（Event Listener）

package com.cc.jsl.listener;

import com.cc.jsl.event.EmailEvent;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * <p>事件監聽者（Event Listener）</p>
 *
 * @author CC
 * @since 2023/10/10
 */
@Component
public class ReceiveListener {

    /**
     * 打電話 - 接收普通JavaBean參數
     */
    @Async
    @EventListener
    public void sendCall(String msg) {
        //發送郵件邏輯
        System.out.println("打電話！-普通-> " + msg);
    }

    /**
     * 發送郵件 - 接收字元串參數
     */
    @Async
    @EventListener
    public void sendEmail(String msg) {
        //發送郵件邏輯
        System.out.println("發送郵件！-普通-> " + msg);
    }

    /**
     * 發送郵件 - 接收唯一事件
     */
    @Async
    @EventListener(EmailEvent.class)
    public void sendEmail(EmailEvent emailEvent) {
        //發送郵件邏輯
        System.out.println("發送郵件！-事件-> " + emailEvent);
    }
}
  • 發送郵件！-事件-> 除了這個以外的所有監聽者都不會監聽到消息
  • 經過測試，不使用事件，直接使用自定義類，只有監聽了這個類的接受者才能接收到，所以相當於實現了一對一。
  • 自定義事件的好處：可以利用Spring框架提供的事件傳遞機制，簡化了觀察者模式的實現。同時，還可以利用Spring框架提供的其他特性，如事務管理、AOP等。
  • 接收到的消息：
    image

四、總結

參考：https://blog.csdn.net/weixin_43745998/article/details/127301003


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

-Advertisement-
Play Games
更多相關文章
  • 【動畫進階】神奇的背景，生化危機4日食 Loading 動畫還原
    最近，在 Steam 玩一款老游戲（生化危機 4 重置版），其中，每當游戲轉場的過程中，都有這麼一個有趣的 Loading 動畫： 整個效果有點類似於日食效果，中間一圈黑色，向外散髮著太陽般的光芒。 本文，我們將嘗試使用 CSS，還原這個效果。 整個效果做出來，類似於如下兩個動畫效果這樣： 實現主體 ...
  • JavaScript 浮點數運算的精度問題
    本篇文章主要是使用 NestJs + Sequelize + MySQL 完成基礎運行， 帶大家瞭解 Node 服務端的基礎搭建，也可以順便看看 Java SpringBoot 項目的基礎結構，它倆真的非常相似，不信你去問服務端開發同學。 ...
  • 交易履約之結算平臺實踐
    本文從系統建設的背景、設計細節、已支撐案例及適用業務場景多個層面進行詳細闡述。讀者可以關註文中所講的系統實踐過程，進而對結算領域系統設計能力提升，具有一定的參考價值。 ...
  • 你真的瞭解TDD和BDD嗎
    今天我們來談一談TDD 和 BDD 兩項實踐。我們先來說說 TDD，也就是測試驅動開發（Test Drvien Development）。 TDD 的節奏 或許你已經迫不及待地要舉手了：“TDD 我知道，就是先寫測試，後寫代碼。”但真的是這樣嗎？嚴格地說，“先寫測試、後寫代碼”的做法叫測試先行開發（ ...
  • C靜態庫的創建與使用--為什麼要引入靜態庫？
    C源程式需要經過預處理、編譯、彙編幾個階段，得到各自源文件對應的可重定位目標文件，可重定位目標文件就是各個源文件的二進位機器代碼，一般是.o格式。比如：util1.c、util2.c及main.c三個C源文件，經過預處理器、編譯器、彙編器的處理，就可以得到各自的目標文件util1.o，util2.o ...
  • 身為底層碼農，你見過最無理需求是啥？
    案例一 20萬的項目，已經花了六十萬了，客戶突然又新提要求做一套百度的搜索系統，我尿了，一頓冥思苦想，然後做了一個搜索頁面，把幾百張表的每個欄位都like一遍在搜索頁面輸入的查詢內容，一次搜索要半小時才出結果，再告訴客戶百度能秒出結果是因為他們有一套幾十億的超級電腦，咱只有一臺不到十個大不溜的服務 ...
  • 組合，反射，魔術方法
    組合，反射，魔術方法 組合 反射 魔術方法 組合 什麼是組合? 組合就是，一個對象擁有一個屬性，該屬性的值是另外一個對象. """什麼場景下使用繼承? 什麼場景下使用組合?""" 繼承一般情況用在：什麼是什麼的情況 is 組合一般用在：什麼有什麼的情況 has class Foo: def __in ...
  • fasthttp + `page partial gziped cache`: 頁面輸出服務性能提升20%
    作者:張富春(ahfuzhang)，轉載時請註明作者和引用鏈接，謝謝！ cnblogs博客 zhihu Github 公眾號:一本正經的瞎扯 接上一篇：http 中使用 gzip 輸出內容時，如何預先壓縮前一半頁面？ 經過實測，對線上一個輸出 html 的服務進行了改造，通過預先壓縮頁面前半部分的方 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類