?2016-2026 Matools All rights reserved,
粵ICP備17059708號
前言
最近一直奔波于面試，面了幾家公司的研發(fā)。有讓我受益頗多的面試經(jīng)驗，也有讓我感覺浪費(fèi)時間的面試經(jīng)歷~
因為疫情原因，最近宅在家里也沒事，就想著使用Redis配合事件總線去實(shí)現(xiàn)下具體的業(yè)務(wù)。??
*
需求
一個簡單的電商，有幾個重要的需求點(diǎn)
商品下單后TODO
* 存儲訂單信息
* 鎖定商品庫存
* 消息推送商家端
訂單支付后TODO
* 存儲訂單支付信息
* 商品庫存減少
* 消息推送商家端
* 會員積分調(diào)整
技術(shù)思路
這里用控制臺實(shí)現(xiàn)上面的業(yè)務(wù)功能外，自行編寫一個基于C#反射特性的事件總線，方便具體業(yè)務(wù)事件的后續(xù)擴(kuò)展，比如訂單支付后后續(xù)還要加會員消息推送啥的。使用Redis的發(fā)布訂閱模式對事件處理進(jìn)行異步化，提升執(zhí)行性能。
所以最終技術(shù)架構(gòu)就是 事件總線+Redis發(fā)布訂閱。
完成事件總線
這里先不急著將上面的訂單、支付、會員 等進(jìn)行建模。先將事件總線的架子搭好。首先需要理解事件總線在業(yè)務(wù)系統(tǒng)的目的是什么。
事件總線存在目的最重要的就是解耦 。我們需要實(shí)現(xiàn)的效果就是針對指定事件源對象觸發(fā)事件后，但凡注冊了該事件參數(shù)的事件處理類則開始執(zhí)行相關(guān)代碼。
下圖可以看出我們的事件處理類均需要引用事件參數(shù)，所有事件處理類都是基于對事件參數(shù)處理的需求上來的。
但是！并不是意味創(chuàng)建了事件處理類就一定會去執(zhí)行！能否執(zhí)行除了取決于事件源的觸發(fā)外就是必須有一層注冊(也可稱映射)。
在WinForm程序里處處可見事件的綁定，如 this.button1.OnClick+=button1OnClick；
那么在這里我將綁定事件放置到一個字典里。C#的字典Dictionary是個key value的鍵值對數(shù)據(jù)集合，鍵和值都可以是任意數(shù)據(jù)類型。
我們可以將事件處理類EventHandle和事件參數(shù)EventData作為鍵和值存儲到字典里。在事件源觸發(fā)時根據(jù)EventData反向找出所有的EventHandle
思路就是這樣，開始編碼了。
定義事件參數(shù)接口，后續(xù)具體業(yè)務(wù)的事件參數(shù)接口均要繼承它。
/// <summary> /// 事件參數(shù)接口 /// </summary> public interface IEventData { ///
<summary> /// 事件源對象 /// </summary> object Source { get; set; } ///// <summary>
///// 事件發(fā)生的數(shù)據(jù) ///// </summary> //TDataModel Data { get; set; } /// <summary>
/// 事件發(fā)生時間 /// </summary> DateTime Time { get; set; } }
需要一個事件處理接口，后續(xù)具體業(yè)務(wù)的事件處理接口均需要繼承它
/// <summary> /// 事件實(shí)現(xiàn)接口 /// </summary> public interface IEventHandle<T>
where T : IEventData { /// <summary> /// 處理等級 /// 方便事件總線觸發(fā)時候可以有序的執(zhí)行相應(yīng) ///
</summary> /// <returns></returns> int ExecuteLevel { get; } /// <summary> ///
事件執(zhí)行 /// </summary> /// <param name="eventData">事件參數(shù)</param> void Execute(T
eventData); }
現(xiàn)在已經(jīng)將事件參數(shù)和事件處理都抽象出來了，接下來是要實(shí)現(xiàn)上面說的注冊容器的實(shí)現(xiàn)了。
/// <summary> /// 事件倉庫 /// </summary> public interface IEventStore { ///
<summary> /// 事件注冊 /// </summary> /// <param name="handle">事件實(shí)現(xiàn)對象</param> ///
<param name="data">事件參數(shù)</param> void EventRegister(Type handle, Type data); ///
<summary> /// 事件取消注冊 /// </summary> /// <param name="handle">事件實(shí)現(xiàn)對象</param>
void EventUnRegister(Type handle); /// <summary> /// 獲取事件處理對象 /// </summary>
/// <param name="data"></param> /// <returns></returns> Type
GetEventHandle(Type data); /// <summary> /// 根據(jù)事件參數(shù)獲取事件處理集合 /// </summary> ///
<typeparam name="TEventData">事件參數(shù)類型</typeparam> /// <param
name="data">事件參數(shù)</param> /// <returns></returns> IEnumerable<Type>
GetEventHandleList<TEventData>(TEventData data); }
實(shí)現(xiàn)上面的接口
/// <summary> /// 基于反射實(shí)現(xiàn)的事件倉儲 /// 存儲事件處理對象和事件參數(shù) /// </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; } }
根據(jù)上面代碼可以看出來，我們存儲到Dictionary內(nèi)的是Type類型，GetEventHandleList方法最終獲取的是一個List<Type>的集合。
我們需要在下面創(chuàng)建的EventBus類里循環(huán)List<Type>并且執(zhí)行這個事件處理類的Execute方法。
實(shí)現(xiàn)EventBus
/// <summary> /// 事件總線服務(wù) /// </summary> public class EventBus :
ReflectEventStore { public void Trigger<TEventData>(TEventData data, SortType
sort = SortType.Asc) where TEventData : IEventData { // 這里如需保證順序執(zhí)行則必須循環(huán)兩次 -
-.... 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
}); } } }
上面可以看到，我們的事件總線是支持對綁定的事件處理對象進(jìn)行有序處理，需要依賴下面這個枚舉
/// <summary> /// 排序類型 /// </summary> public enum SortType { /// <summary>
/// 升序 /// </summary> Asc = 1, /// <summary> /// 降序 /// </summary> Desc = 2 }
好了，至此，我們的簡易版的事件總線就出來了~ 接下來就是去建模、實(shí)現(xiàn)相應(yīng)的事件參數(shù)和事件處理類了。
創(chuàng)建訂單模型：
/// <summary> /// 訂單模型 /// </summary> public class OrderModel { /// <summary>
/// 訂單ID /// </summary> public Guid Id { get; set; } /// <summary> /// 用戶ID ///
</summary> public Guid UserId { get; set; } /// <summary> /// 訂單創(chuàng)建時間 ///
</summary> public DateTime CreateTime { get; set; } /// <summary> /// 商品名稱 ///
</summary> public string ProductName { get; set; } /// <summary> /// 購買數(shù)量 ///
</summary> public int Number { get; set; } /// <summary> /// 訂單金額 ///
</summary> public decimal Money { get; set; } }
創(chuàng)建訂單下單事件參數(shù)
public interface IOrderCreateEventData : IEventData { /// <summary> /// 訂單信息
/// </summary> OrderModel Order { get; set; } } /// <summary> /// 訂單創(chuàng)建事件參數(shù) ///
</summary> public class OrderCreateEventData : IOrderCreateEventData { public
OrderModel Order { get; set; } public object Source { get; set; } public
DateTime Time { get; set; } }
OK~接下來就是實(shí)現(xiàn)我們上面需求上的那些功能了。
* 存儲訂單信息
* 鎖定商品庫存
* 消息推送商家端
這里我不實(shí)現(xiàn)存儲訂單信息的事件處理對象，我默認(rèn)此業(yè)務(wù)必須同步處理，至于后面兩個則可以采取異步處理。通過下面代碼創(chuàng)建相應(yīng)的事件處理類。
訂單創(chuàng)建事件之消息推送商家端處理類。 /// <summary> /// 訂單創(chuàng)建事件之消息處理類 /// </summary> public
class OrderCreateEventNotifyHandle : IEventHandle<IOrderCreateEventData> {
public int ExecuteLevel { get; private set; } public
OrderCreateEventNotifyHandle() {
Console.WriteLine($"創(chuàng)建OrderCreateEventNotifyHandle對象"); this.ExecuteLevel = 2;
} public void Execute(IOrderCreateEventData eventData) { Thread.Sleep(1000);
Console.WriteLine($"執(zhí)行訂單創(chuàng)建事件之消息推送!訂單ID:{eventData.Order.Id.ToString()},商品名稱:{eventData.Order.ProductName}");
} }
訂單創(chuàng)建消息之鎖定庫存處理類
/// <summary> /// 訂單創(chuàng)建事件 鎖定庫存 處理類 /// </summary> public class
OrderCreateEventStockLockHandle : IEventHandle<IOrderCreateEventData> { public
int ExecuteLevel { get; private set; } public OrderCreateEventStockLockHandle()
{ Console.WriteLine($"創(chuàng)建OrderCreateEventStockLockHandle對象"); this.ExecuteLevel
= 1; } public void Execute(IOrderCreateEventData eventData) {
Thread.Sleep(1000);
Console.WriteLine($"執(zhí)行訂單創(chuàng)建事件之庫存鎖定!訂單ID:{eventData.Order.Id.ToString()},商品名稱:{eventData.Order.ProductName}");
} }
OK~ 到main方法下開始執(zhí)行訂單創(chuàng)建相關(guān)代碼。
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(); }
至此，我們采取事件總線的方式成功將需求實(shí)現(xiàn)了，執(zhí)行后結(jié)果如下:
?
?
可以看到我們的下單總耗時是3038毫秒，如您所見，我們解決了代碼的耦合性但是沒有解決代碼的執(zhí)行效率。
下一章，將我們的Redis的發(fā)布訂閱模式再加入進(jìn)來，看是否能改善我們的代碼執(zhí)行效率~~
源碼在下一篇博客上提供下載地址(畢竟現(xiàn)在才完成一半~)
熱門工具 換一換