使用EventBus + Redis發佈訂閱模式提升業務執行性能

来源:https://www.cnblogs.com/hunanzp/archive/2020/03/03/12402769.html
-Advertisement-
Play Games

前言 最近一直奔波於面試，面了幾家公司的研發。有讓我受益頗多的面試經驗，也有讓我感覺浪費時間的面試經歷~因為疫情原因，最近宅在家裡也沒事，就想著使用Redis配合事件匯流排去實現下具體的業務。 需求 一個簡單的電商，有幾個重要的需求點 商品下單後TODO 存儲訂單信息 鎖定商品庫存 消息推送商家端 訂 ...


前言

最近一直奔波於面試，面了幾家公司的研發。有讓我受益頗多的面試經驗，也有讓我感覺浪費時間的面試經歷~
因為疫情原因，最近宅在家裡也沒事，就想著使用Redis配合事件匯流排去實現下具體的業務。  

  • 需求

    一個簡單的電商，有幾個重要的需求點

    商品下單後TODO

    • 存儲訂單信息
    • 鎖定商品庫存
    • 消息推送商家端

    訂單支付後TODO

    • 存儲訂單支付信息
    • 商品庫存減少
    • 消息推送商家端
    • 會員積分調整

技術思路

這裡用控制台實現上面的業務功能外，自行編寫一個基於C#反射特性的事件匯流排，方便具體業務事件的後續擴展，比如訂單支付後後續還要加會員消息推送啥的。使用Redis的發佈訂閱模式對事件處理進行非同步化，提升執行性能。
所以最終技術架構就是 事件匯流排+Redis發佈訂閱。

完成事件匯流排

這裡先不急著將上面的訂單、支付、會員 等進行建模。先將事件匯流排的架子搭好。首先需要理解事件匯流排在業務系統的目的是什麼。
事件匯流排存在目的最重要的就是解耦 。我們需要實現的效果就是針對指定事件源對象觸發事件後，但凡註冊了該事件參數的事件處理類則開始執行相關代碼。

下圖可以看出我們的事件處理類均需要引用事件參數，所有事件處理類都是基於對事件參數處理的需求上來的。

9d8bb75ee6ad2747e082d625ce99549f.png

但是！並不是意味創建了事件處理類就一定會去執行！能否執行除了取決於事件源的觸發外就是必須有一層註冊(也可稱映射)。
在WinForm程式里處處可見事件的綁定，如 this.button1.OnClick+=button1OnClick；
那麼在這裡我將綁定事件放置到一個字典里。C#的字典Dictionary是個key value的鍵值對數據集合，鍵和值都可以是任意數據類型。
我們可以將事件處理類EventHandle和事件參數EventData作為鍵和值存儲到字典里。在事件源觸發時根據EventData反向找出所有的EventHandle

思路就是這樣，開始編碼了。
定義事件參數介面，後續具體業務的事件參數介面均要繼承它。

    /// <summary>
    /// 事件參數介面
    /// </summary>
    public interface IEventData
    {
        /// <summary>
        /// 事件源對象
        /// </summary>
        object Source { get; set; }

        ///// <summary>
        ///// 事件發生的數據
        ///// </summary>
        //TDataModel Data { get; set; }

        /// <summary>
        /// 事件發生時間
        /// </summary>
        DateTime Time { get; set; }
    }

　　

需要一個事件處理介面，後續具體業務的事件處理介面均需要繼承它

    /// <summary>
    /// 事件實現介面
    /// </summary>
    public interface IEventHandle<T> where T : IEventData
    {
        /// <summary>
        /// 處理等級
        /// 方便事件匯流排觸發時候可以有序的執行相應
        /// </summary>
        /// <returns></returns>
        int ExecuteLevel { get; }

        /// <summary>
        /// 事件執行
        /// </summary>
        /// <param name="eventData">事件參數</param>
        void Execute(T eventData);
    }

　　

現在已經將事件參數和事件處理都抽象出來了，接下來是要實現上面說的註冊容器的實現了。

   /// <summary>
    /// 事件倉庫
    /// </summary>
    public interface IEventStore
    {
        /// <summary>
        /// 事件註冊
        /// </summary>
        /// <param name="handle">事件實現對象</param>
        /// <param name="data">事件參數</param>
        void EventRegister(Type handle, Type data);

        /// <summary>
        /// 事件取消註冊
        /// </summary>
        /// <param name="handle">事件實現對象</param>
        void EventUnRegister(Type handle);

        /// <summary>
        /// 獲取事件處理對象
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        Type GetEventHandle(Type data);

        /// <summary>
        /// 根據事件參數獲取事件處理集合
        /// </summary>
        /// <typeparam name="TEventData">事件參數類型</typeparam>
        /// <param name="data">事件參數</param>
        /// <returns></returns>
        IEnumerable<Type> GetEventHandleList<TEventData>(TEventData data);
    }

　　

實現上面的介面

    /// <summary>
    /// 基於反射實現的事件倉儲
    /// 存儲事件處理對象和事件參數
    /// </summary>
    public class ReflectEventStore : IEventStore
    {
        private static Dictionary<Type, Type> StoreLst;

        public ReflectEventStore()
        {
            StoreLst = new Dictionary<Type, Type>();
        }

        public void EventRegister(Type handle, Type data)
        {
            if (handle == null || data == null) throw new NullReferenceException();
            if (StoreLst.Keys.Contains(handle))
                throw new ArgumentException($"事件匯流排已註冊類型為{nameof(handle)} !");

            if (!StoreLst.TryAdd(handle, data))
                throw new Exception($"註冊{nameof(handle)}類型到事件匯流排失敗！");
        }


        public void EventUnRegister(Type handle)
        {
            if (handle == null) throw new NullReferenceException();
            StoreLst.Remove(handle);
        }

        public Type GetEventHandle(Type data)
        {
            if (data == null) throw new NullReferenceException();
            Type handle = StoreLst.FirstOrDefault(p => p.Value == data).Key;
            return handle;
        }

        public IEnumerable<Type> GetEventHandleList<TEventData>(TEventData data)
        {
            if (data == null) throw new NullReferenceException();
            var items = StoreLst.Where(p => p.Value == data.GetType())
                                  .Select(k => k.Key);
            return items;
        }
    }

　　

根據上面代碼可以看出來，我們存儲到Dictionary內的是Type類型，GetEventHandleList方法最終獲取的是一個List<Type>的集合。
我們需要在下麵創建的EventBus類里迴圈List<Type>並且執行這個事件處理類的Execute方法。

實現EventBus

    /// <summary>
    /// 事件匯流排服務
    /// </summary>
    public class EventBus : ReflectEventStore
    {

        public void Trigger<TEventData>(TEventData data, SortType sort = SortType.Asc) where TEventData : IEventData
        {
            // 這裡如需保證順序執行則必須迴圈兩次 - -....
            var items = GetEventHandleList(data).ToList();
            Dictionary<object, Tuple<Type, int>> ds = new Dictionary<object, Tuple<Type, int>>();

            foreach (var item in items)
            {
                var instance = Activator.CreateInstance(item);
                MethodInfo method = item.GetMethod("get_ExecuteLevel");
                int value = (int)method.Invoke(instance, null);
                ds.Add(instance, new Tuple<Type, int>(item, value));
            }

            var lst = sort == SortType.Asc ? ds.OrderBy(p => p.Value.Item2).ToList() : ds.OrderByDescending(p => p.Value.Item2).ToList();

            foreach (var k in lst)
            {
                MethodInfo method = k.Value.Item1.GetMethod("Execute");
                method.Invoke(k.Key, new object[] { data });
            }
        }
    }

　　

上面可以看到，我們的事件匯流排是支持對綁定的事件處理對象進行有序處理，需要依賴下麵這個枚舉

    /// <summary>
    /// 排序類型
    /// </summary>
    public enum SortType
    {
        /// <summary>
        /// 升序
        /// </summary>
        Asc = 1,
        /// <summary>
        /// 降序
        /// </summary>
        Desc = 2
    }

　　

好了，至此，我們的簡易版的事件匯流排就出來了~ 接下來就是去建模、實現相應的事件參數和事件處理類了。
創建訂單模型：

   /// <summary>
    /// 訂單模型
    /// </summary>
    public class OrderModel
    {
        /// <summary>
        /// 訂單ID
        /// </summary>
        public Guid Id { get; set; }

        /// <summary>
        /// 用戶ID
        /// </summary>
        public Guid UserId { get; set; }

        /// <summary>
        /// 訂單創建時間
        /// </summary>
        public DateTime CreateTime { get; set; }

        /// <summary>
        /// 商品名稱
        /// </summary>
        public string ProductName { get; set; }

        /// <summary>
        /// 購買數量
        /// </summary>
        public int Number { get; set; }

        /// <summary>
        /// 訂單金額
        /// </summary>
        public decimal Money { get; set; }
    }

　　

創建訂單下單事件參數

    public interface IOrderCreateEventData : IEventData
    {
        /// <summary>
        /// 訂單信息
        /// </summary>
        OrderModel Order { get; set; }
    }

    /// <summary>
    /// 訂單創建事件參數
    /// </summary>
    public class OrderCreateEventData : IOrderCreateEventData
    {
        public OrderModel Order { get; set; }
        public object Source { get; set; }
        public DateTime Time { get; set; }
    }

OK~接下來就是實現我們上面需求上的那些功能了。

  • 存儲訂單信息
  • 鎖定商品庫存
  • 消息推送商家端
    這裡我不實現存儲訂單信息的事件處理對象，我預設此業務必須同步處理，至於後面兩個則可以採取非同步處理。通過下麵代碼創建相應的事件處理類。
    訂單創建事件之消息推送商家端處理類。
    /// <summary>
    /// 訂單創建事件之消息處理類
    /// </summary>
    public class OrderCreateEventNotifyHandle : IEventHandle<IOrderCreateEventData>
    {
        public int ExecuteLevel { get; private set; }

        public OrderCreateEventNotifyHandle()
        {
            Console.WriteLine($"創建OrderCreateEventNotifyHandle對象");
            this.ExecuteLevel = 2;
        }

        public void Execute(IOrderCreateEventData eventData)
        {
            Thread.Sleep(1000);
            Console.WriteLine($"執行訂單創建事件之消息推送!訂單ID:{eventData.Order.Id.ToString()},商品名稱:{eventData.Order.ProductName}");
        }
       
    }

　　

訂單創建消息之鎖定庫存處理類

   /// <summary>
    /// 訂單創建事件 鎖定庫存 處理類
    /// </summary>
    public class OrderCreateEventStockLockHandle : IEventHandle<IOrderCreateEventData>
    {
        public int ExecuteLevel { get; private set; }

        public OrderCreateEventStockLockHandle()
        {
            Console.WriteLine($"創建OrderCreateEventStockLockHandle對象");
            this.ExecuteLevel = 1;
        }


        public void Execute(IOrderCreateEventData eventData)
        {
            Thread.Sleep(1000);
            Console.WriteLine($"執行訂單創建事件之庫存鎖定!訂單ID:{eventData.Order.Id.ToString()},商品名稱:{eventData.Order.ProductName}");
        }
    }

　　

OK~ 到main方法下開始執行訂單創建相關代碼。

        static void Main(string[] args)
        {
          
            Guid userId = Guid.NewGuid();
            Stopwatch stopwatch = new Stopwatch();
            stopwatch.Start();
            EventBus eventBus = new EventBus();
            eventBus.EventRegister(typeof(OrderCreateEventNotifyHandle), typeof(OrderCreateEventData));
            eventBus.EventRegister(typeof(OrderCreateEventStockLockHandle), typeof(OrderCreateEventData));
            var order = new Order.OrderModel()
            {
                CreateTime = DateTime.Now,
                Id = Guid.NewGuid(),
                Money = (decimal)300.00,
                Number = 1,
                ProductName = "鮮花一束",
                UserId = userId
            };
            Console.WriteLine($"模擬存儲訂單");
            Thread.Sleep(1000);
            eventBus.Trigger(new OrderCreateEventData()
            {
                Order = order
            });
            stopwatch.Stop();
            Console.WriteLine($"下單總耗時:{stopwatch.ElapsedMilliseconds}毫秒");
            Console.ReadLine();
        }

　　至此，我們採取事件匯流排的方式成功將需求實現了，執行後結果如下:

 

 

可以看到我們的下單總耗時是3038毫秒，如您所見，我們解決了代碼的耦合性但是沒有解決代碼的執行效率。
下一章，將我們的Redis的發佈訂閱模式再加入進來，看是否能改善我們的代碼執行效率~~

源碼在下一篇博客上提供下載地址(畢竟現在才完成一半~)


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

-Advertisement-
Play Games
更多相關文章
  • Ⅱ：python入門
    一、編程語言介紹 編程語言的分類： 機器語言（奴隸的母語）：直接用二進位數0,1構成的指令去編寫程式，即用電腦能夠直接理解的二進位指令編寫程式，電腦可以無障礙理解。 優點：執行效率最高 缺點：開發效率最低、跨平臺性差 彙編語言：用英文標簽取代二進位去編寫程式 優點：執行效率高 缺點：開發效率低、 ...
  • bottle
    Bottle是一個快速、簡潔、輕量級的基於WSIG的微型Web框架，此框架只由一個 .py 文件，除了Python的標準庫外，其不依賴任何其他模塊。 1 pip install bottle 2 easy_install bottle 3 apt-get install python-bottle ...
  • C++標準庫中copy演算法的使用
    [TOC] std::copy是C++標準庫中的演算法介面，主要用於兩個容器間的複製，據說其效率要優於自己用for迴圈逐個複製。之前一直非常混淆其中的用法，這裡總結了幾個例子如下： cpp include include include include using namespace std; int ...
  • Python裡面如何拷貝一個對象？
    Python裡面如何拷貝一個對象？ http://blog.csdn.net/sharkw/article/details/1934090 標準庫中的copy模塊提供了兩個方法來實現拷貝.一個方法是copy,它返回和參數包含內容一樣的對象. 使用deepcopy方法,對象中的屬性也被覆制 Pytho ...
  • WPF一種本地化的方法
    使用 resx 文件，可以動態切換語言，使用如下類： public class LanguageManager : INotifyPropertyChanged { private readonly ResourceManager _resourceManager; private static r ...
  • 【c#.Net】面試題庫總結50題
    1、簡述 private、 protected、 public、 internal 修飾符的訪問許可權。private : 私有成員, 在類的內部才可以訪問。protected : 保護成員，該類內部和繼承類中可以訪問。public : 公共成員，完全公開，沒有訪問限制。internal: 當前程式集 ...
  • 【WPF學習】第五十三章 動畫類型回顧
    創建動畫面臨的第一個挑戰是為動畫選擇正確的屬性。期望的結果（例如，在視窗中移動元素）與需要使用的屬性（在這種情況下是Canvas.Left和Canvas.Top屬性）之間的關係並不總是很直觀。下麵是一些指導原則： 如果希望使用動畫來使元素顯示和消失，不要使用Visibility屬性(該屬性只能在完全 ...
  • 淺談ConcurrentDictionary與Dictionary
    在.NET4.0之前，如果我們需要在多線程環境下使用Dictionary類，除了自己實現線程同步來保證線程安全外，我們沒有其他選擇。很多開發人員肯定都實現過類似的線程安全方案，可能是通過創建全新的線程安全字典，或者僅是簡單的用一個類封裝一個Dictionary對象，併在所有方法中加上鎖機制，我們稱這 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類