觀察者模式最佳實踐,構建自己的一套事件分發系統

来源:https://www.cnblogs.com/iwiniwin/archive/2020/04/03/12624090.html
-Advertisement-
Play Games

基於觀察者模式,構建自己的一套事件分發系統。由常見的引用耦合問題,引出觀察者模式,進而利用觀察者模式的最佳實踐,事件分發系統來解決耦合問題。文章詳細解讀了事件分發系統的實現步驟,以及需要註意的一些坑。 ...


前言

試想這樣一個問題,當某個事件發生時,比如在游戲中A模塊修改了用戶的金幣數,而B模塊和C模塊提供的功能都依賴於用戶的金幣數,那麼,A模塊在修改金幣數的同時,就需要通知B模塊和C模塊。常規的方法就是A模塊持有B模塊和C模塊的對象,然後分別通過調用對象介面的方式告訴它們,“嘿,我修改了用戶的金幣數,改成了10金幣”。
但這樣就帶來了許多問題:

  • A模塊引用了B模塊和C模塊,耦合嚴重
  • A模塊修改金幣數的方法中調用了B,C模塊的方法,當這兩個模塊發生變化時(比如B模塊接收金幣數的介面名稱改變了,或是C模塊不再需要知道金幣數改變了),A模塊也要修改
  • 當又出現一個D模塊也需要知道金幣數的變化時,同樣需要修改A模塊以適應這種需求

為瞭解決上面的問題,我們自然想到了觀察者模式。

觀察者模式

這裡簡單說一下什麼是觀察者模式:定義對象之間的一對多依賴,這樣一來,當一個對象改變狀態時,它的所有依賴者(稱之為觀察者)都會接收到通知並自動更新。
觀察者模式的好處是,對象之間是松耦合的,當一個對象改變狀態時,它並不需要知道自己的觀察者是誰,只需要發佈通知即可。任何時候都可以增加或刪除觀察者,不會影響到發佈通知的對象。
而事件分發系統就是觀察者模式的一個具體實現

事件分發系統

事件分發系統核心需要提供的功能主要包括以下幾個部分:

  • 當一個對象發生改變時,可以認為此時產生了一個事件,提供一個派發事件的介面,以通知所有的觀察者
  • 需要提供註冊監聽事件的介面,以讓觀察者可以訂閱自己需要接收的事件
  • 還需提供反註冊監聽事件介面,以讓觀察者可以取消自己的訂閱
  • 最好還能在訂閱的時候設置優先順序,優先順序越高的可以越先被通知

使用事件分發系統解決問題

首先,來看看使用事件分發系統處理上面提到的問題,會是什麼樣的效果。
A模塊只需要派發金幣修改事件,B,C模塊只需要訂閱金幣修改事件,之後便可以收到通知了。是不是很簡單呢

local B = class()
function B:on_money_change( money )
    print(money, "B receive event")
end
-- 訂閱金幣修改事件
EventSystem:on(Event.MoneyChanged, B.on_money_change, {target = B})

local C = class()
function C:on_money_change( money )
    print(money, "C receive event")
end
EventSystem:on(Event.MoneyChanged, C.on_money_change, {target = C})
-- 在A模塊中派發金幣修改事件,當前金幣為10
EventSystem:emit(Event.MoneyChanged, 10)

接下來會仔細解讀一下這個EventSystem事件分發系統的Lua實現代碼。
實現事件分發系統時,需要小心一些特殊情況,比如有以下幾個坑,讀者可以留意一下代碼中對這幾個坑的處理

  • 在事件派發的過程中訂閱該事件,訂閱還有優先順序,需要小心處理排序問題
  • 在事件派發的過程中取消訂閱該事件,需要採用標記移除,不能直接移除
  • 在事件派發的過程中又派發了該事件,如何確定事件派發完成

為了便於講解,下麵的代碼省略了一些非關鍵性的代碼,用--- ...代替。

註冊監聽事件介面

function EventSystem:on( event, func, params )
    --- ...
    local event_listener = self._listeners[event]
    params = params or {}
    local priority = params.priority or 0
    local target = params.target
    --- ...
    local cb = {target = target, func = func, id = id, priority = priority}
    table.insert(event_listener.list, cb)
    id = id + 1
    if priority > 0 then
        event_listener.need_sort = true
        self:sort(event_listener)
    end
end

on方法中event參數表示要註冊監聽的事件名稱,func參數表示當事件發生時要觸發的回調函數,params表示額外參數,可以設置註冊監聽的目標target(可以利用它反註冊所有與其相關的監聽),也可以設置要註冊監聽的優先順序,優先順序越高的越先執行
on方法的實現還是比較簡單的,主要就是將註冊的相關信息插入到event_listener表中,但是明明註冊的監聽是有優先順序的,卻仍然只是調用table.insert將信息插入到表的末尾,這是為什麼呢?讀者可以先留意一下,後面會有詳細解釋。
還需要格外註意的是sort方法

function EventSystem:sort( listener )
    if listener.need_sort == true and listener.emit_count == 0 then
        table.sort(listener.list, function ( a, b )
            if a.priority == b.priority then
                return a.id < b.id
            else
                return a.priority > b.priority
            end
        end)
        listener.need_sort = false;
    end
end

可以看到sort方法必須在listener.emit_count == 0時才會進行排序,listener.emit_count == 0表示的是當前的事件沒有處於派髮狀態,後面講到派發介面時會詳細解釋,這裡讀者只需要知道其表示的含義即可。
事件處於派髮狀態時不能進行優先順序排序原因是可能會造成回調的重覆觸發。
比如當前事件有4個回調 a, b, c, d,派發事件是順序執行回調,當執行到第3個回調c時
如果在c回調中又註冊了一個優先順序最高的回調e,立刻排序的話,e插入到第一位,c會被擠到第4位,順序執行到第4個回調時,導致c又被調用一次

反註冊事件監聽介面

function EventSystem:off( event, func, params )
    --- ...
    local event_listener = self._listeners[event]
    params = params or {}
    for i,cb in ipairs(event_listener.list) do
        if cb.func == func and cb.target == params.target then
            if event_listener.emit_count > 0 then
                -- 派發過程中只進行標記刪除
                cb.need_remove = true
                event_listener.need_clean = true
            else
                table.remove(event_listener.list, i)
            end
            break;
        end
    end
end

off方法用於取消事件監聽,當事件未處於派發過程中時,直接調用table.remove移除註冊信息即可,但當事件處於派發過程中時,不能直接移除,只能先進行標記
在事件處於派發過程中時不能直接移除的原因是可能導致遺漏觸發某些回調
比如當前事件有5個回調 a, b, c, d, e,順序執行到第3個回調c時
如果在c回調中調用了off方法取消自己的監聽,此時直接移除c的話,會導致d回調移動到第3位,e移動到第4位,順序執行到第4個回調時,調用的是e而遺漏了d

事件派發介面

function EventSystem:emit( event, ... )
    --- ...
    local event_listener = self._listeners[event]
    local interrupt = false
    local length = #event_listener.list
    -- 這裡不能使用ipairs,確保不會觸發在派發過程中註冊的事件
    -- 只取當前已經註冊的事件數量,如果在派發過程中再註冊(調用了table.insert),本次派發也不會調用
    for i = 1, length do
        if interrupt == true then
            break
        end
        local cb = event_listener.list[i]
        if cb.func and cb.need_remove ~= true then
            event_listener.emit_count = event_listener.emit_count + 1
            if cb.target then
                interrupt = cb.func(cb.target, ...)
            else
                interrupt = cb.func(...)
            end
            event_listener.emit_count = event_listener.emit_count - 1
        end
    end
    self:sort(event_listener);
    self:clean(event_listener);
    return interrupt
end

emit方法負責派發一個事件,順序執行event_listener中註冊的回調。事件的派發支持中斷,當執行某個回調時,如果這個回調返回了true則可以中斷當前事件的派發。
值得一提的是,代碼通過對應的event_listener.emit_count = event_listener.emit_count + 1event_listener.emit_count = event_listener.emit_count - 1來記錄事件的派髮狀態,當emit_count > 0則表明事件還在派發過程中。當emit_count == 0則表明事件派發完成。
不能使用event_listener.is_emiting = trueevent_listener.is_emiting = false代替的原因是如果在觸發的回調中又派發了事件,形成了遞歸,那麼二次派發事件結束時會直接將event_listener.is_emiting置為flase,導致一次派發事件對應的派髮狀態被標記錯誤

更多

事件分發系統的完整源碼可以點擊這裡查看,測試用例可以點擊這裡查看
更多Lua相關的設計與使用,比如面向對象(代碼中用到的class關鍵字),組件系統,分模塊載入等等,可以查看GitHub倉庫LuaKit


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

-Advertisement-
Play Games
更多相關文章
  • 網頁設計中經常用到標題之間的分隔符的樣式,即用短豎線分隔幾個關鍵詞,最近發現了一種簡單可行的方式,即通過vertical-align屬性來實現分隔符樣式,在這邊分享給大家: <!DOCTYPE html> <html> <head> <title></title> <style> div { hei ...
  • 前言 前端的小伙伴在面試的時候,幾乎都會遇到一道這樣的面試題: add(1)(2)(3)(4)輸出結果為10。在第一次看到這道面試題的時候,很多小伙伴感到了迷茫!借用王寶強在《人在囧途》中的表演:啥啥啥,這寫的都是啥?下麵胡哥為各位小伙伴帶來這道題的揭秘。 一、核心點 基礎函數的變種 函數柯里化 我 ...
  • vertical-align屬性主要用於改變行內元素的對齊方式,對於行內佈局影響很大,如果不瞭解的話,我們開發調整樣式的時候很容易出錯。 網上關於這個屬性的原理說得很是複雜,看一眼就讓人覺得望而生畏,而且大可不必完全理解其原理,只要懂得其規律,我們足夠使用即可,下麵把我的理解分享給大家: 基線 要了 ...
  • 目前室內三維地圖如何輕量化,能夠在手機微信、電腦瀏覽器等平臺快速顯示地圖,顯示的地圖性能好,轉動地圖不卡是大家都要面對的問題, 使用室內三維地圖引擎ESMap後目前可以不用操心這方面的問題,開發只需要關心設備如何加到地圖上進行管理,本文章主要介紹攝像頭圖層、消防設備圖層和人員軌跡圖層進行介紹,方便大... ...
  • JavaScript 是基於面向對象和事件驅動的一門語言,事件模型是 DOM 中至關重要的內容,理解事件驅動機制、事件反饋、事件冒泡、事件捕獲以及事件委托能幫助我們更好的處理事件,寫出更優的代碼 ...
  • 01. 聊 啥 關註“一猿小講”的都知道,我們之前分享過應用架構、應用監控、日誌歸集以及程式員日常內心的那些小揪揪,幾乎成了小講、雜談的一畝三分地。 說實話,挺神奇,我也不知道每次會給大家帶來什麼驚喜。 今天的分享也不例外,你們肯定也意想不到,今天我分享的主題居然是:矛與盾,如何做好系統之盾;說人話 ...
  • 默默在看新機會的你,是不是面試的時候,偶爾被問起“能不能簡單介紹一下項目的應用系統架構”? 沉迷於業務開發的你們,有沒有考慮過“用戶訪問到你開發的業務功能,到底經過了哪些環節”? 今天我將結合這些年的一些認知理解,開壇設法給大家講一講應用系統架構的從 0 到 1。 01. 如何造一個大泥球? 產品汪 ...
  • 基本定義 裝飾者模式屬於 結構型模式 ,它可以 動態的 將新功能 附加到對象上 ,同時又 不改變其結構 。在對象功能擴展方面,它比繼承更有彈性,裝飾者模式也體現了開閉原則(OCP)。 模式結構 裝飾者和被裝飾者有 相同的超類型 ,因為裝飾者和被裝飾者必須是一樣的類型, 利用繼承是為了達到類型的匹配, ...
一周排行
    -Advertisement-
    Play Games
  • Timer是什麼 Timer 是一種用於創建定期粒度行為的機制。 與標準的 .NET System.Threading.Timer 類相似,Orleans 的 Timer 允許在一段時間後執行特定的操作,或者在特定的時間間隔內重覆執行操作。 它在分散式系統中具有重要作用,特別是在處理需要周期性執行的 ...
  • 前言 相信很多做WPF開發的小伙伴都遇到過表格類的需求,雖然現有的Grid控制項也能實現,但是使用起來的體驗感並不好,比如要實現一個Excel中的表格效果,估計你能想到的第一個方法就是套Border控制項,用這種方法你需要控制每個Border的邊框,並且在一堆Bordr中找到Grid.Row,Grid. ...
  • .NET C#程式啟動閃退,目錄導致的問題 這是第2次踩這個坑了,很小的編程細節,容易忽略,所以寫個博客,分享給大家。 1.第一次坑:是windows 系統把程式運行成服務,找不到配置文件,原因是以服務運行它的工作目錄是在C:\Windows\System32 2.本次坑:WPF桌面程式通過註冊表設 ...
  • 在分散式系統中,數據的持久化是至關重要的一環。 Orleans 7 引入了強大的持久化功能,使得在分散式環境下管理數據變得更加輕鬆和可靠。 本文將介紹什麼是 Orleans 7 的持久化,如何設置它以及相應的代碼示例。 什麼是 Orleans 7 的持久化? Orleans 7 的持久化是指將 Or ...
  • 前言 .NET Feature Management 是一個用於管理應用程式功能的庫,它可以幫助開發人員在應用程式中輕鬆地添加、移除和管理功能。使用 Feature Management,開發人員可以根據不同用戶、環境或其他條件來動態地控制應用程式中的功能。這使得開發人員可以更靈活地管理應用程式的功 ...
  • 在 WPF 應用程式中,拖放操作是實現用戶交互的重要組成部分。通過拖放操作,用戶可以輕鬆地將數據從一個位置移動到另一個位置,或者將控制項從一個容器移動到另一個容器。然而,WPF 中預設的拖放操作可能並不是那麼好用。為瞭解決這個問題,我們可以自定義一個 Panel 來實現更簡單的拖拽操作。 自定義 Pa ...
  • 在實際使用中,由於涉及到不同編程語言之間互相調用,導致C++ 中的OpenCV與C#中的OpenCvSharp 圖像數據在不同編程語言之間難以有效傳遞。在本文中我們將結合OpenCvSharp源碼實現原理,探究兩種數據之間的通信方式。 ...
  • 一、前言 這是一篇搭建許可權管理系統的系列文章。 隨著網路的發展,信息安全對應任何企業來說都越發的重要,而本系列文章將和大家一起一步一步搭建一個全新的許可權管理系統。 說明:由於搭建一個全新的項目過於繁瑣,所有作者將挑選核心代碼和核心思路進行分享。 二、技術選擇 三、開始設計 1、自主搭建vue前端和. ...
  • Csharper中的表達式樹 這節課來瞭解一下表示式樹是什麼? 在C#中,表達式樹是一種數據結構,它可以表示一些代碼塊,如Lambda表達式或查詢表達式。表達式樹使你能夠查看和操作數據,就像你可以查看和操作代碼一樣。它們通常用於創建動態查詢和解析表達式。 一、認識表達式樹 為什麼要這樣說?它和委托有 ...
  • 在使用Django等框架來操作MySQL時,實際上底層還是通過Python來操作的,首先需要安裝一個驅動程式,在Python3中,驅動程式有多種選擇,比如有pymysql以及mysqlclient等。使用pip命令安裝mysqlclient失敗應如何解決? 安裝的python版本說明 機器同時安裝了 ...