前言

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

需求

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

商品下單后TODO
- 存盤訂單資訊
- 鎖定商品庫存
- 訊息推送商家端
訂單支付后TODO
- 存盤訂單支付資訊
- 商品庫存減少
- 訊息推送商家端
- 會員積分調整

技術思路

這里用控制臺實作上面的業務功能外，自行撰寫一個基于C#反射特性的事件總線，方便具體業務事件的后續擴展，比如訂單支付后后續還要加會員訊息推送啥的，使用Redis的發布訂閱模式對事件處理進行異步化，提升執行性能，
所以最終技術架構就是事件總線+Redis發布訂閱，

完成事件總線

這里先不急著將上面的訂單、支付、會員等進行建模，先將事件總線的架子搭好，首先需要理解事件總線在業務系統的目的是什么，
事件總線存在目的最重要的就是解耦，我們需要實作的效果就是針對指定事件源物件觸發事件后，但凡注冊了該事件引數的事件處理類則開始執行相關代碼，

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

但是！并不是意味創建了事件處理類就一定會去執行！能否執行除了取決于事件源的觸發外就是必須有一層注冊(也可稱映射)，
在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 =https://www.cnblogs.com/hunanzp/p/= 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 =https://www.cnblogs.com/hunanzp/p/= null) throw new NullReferenceException();
            Type handle = StoreLst.FirstOrDefault(p => p.Value == data).Key;
            return handle;
        }

        public IEnumerable GetEventHandleList(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 = https://www.cnblogs.com/hunanzp/p/(int)method.Invoke(instance, null);
                ds.Add(instance, new Tuple(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的發布訂閱模式再加入進來，看是否能改善我們的代碼執行效率~~

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

轉載請註明出處，本文鏈接：https://www.uj5u.com/net/67195.html

標籤：C#

上一篇：C#的基礎知識

下一篇：淺談ConcurrentDictionary與Dictionary

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

前言

需求

技術思路

完成事件總線