DotNetCore跨平台~服務匯流排 事件匯流排的重新設計

理論閑話

之前在.netFramework平台用的好好的，可升級到.net core平台之後，由於不再需要二進位序列化，導致咱們的事件機制遇到了問題，之前大叔的事件一直是將處理程序序列化後進行存儲的，處理存儲的參數為事件源，一個事件源可以由多個處理程序訂閱，當事件源被發布時，這些被序列化的代碼段會被回調執行，這是大叔之前的思路，在RedisBus和MemoryBus里已經得到了實現，讀過大叔源代碼的同學應該有所了解了。

　　 ///

public class CreateUserCommand : BusData
{
public string UserName { get; set; }
}

　　 ///

public class CreateUserCommandHandler : IBusHandler
{
public void Handle(CreateUserCommand evt)
{
LoggerFactory.CreateLog.Logger_Debug(evt.UserName);
Console.WriteLine("CreateUserCommandHandler");
}
}

關於服務匯流排的實現方式

1. RedisBus基於redis進行存儲，事件發布後，所有相關處理程序被回調，要求事件和處理程序是可序列化的
2. MemoryBus基於應用伺服器緩存進行存儲，所有相關處理程序被回調，集群環境不是很適合
3. IoCBus基於redis作為事件字典，處理程序由IoC容器進行注入，使用場合更廣

IoCBus實現思想與組成

1. 應該有一個存儲事件與處理程序對應關係的字典
2. 字典應該被持久化到中間件里
3. 應該有個容器，去管理字典值與處理程序的關係

代碼實現

數據變更的定義

　　　　///

const string ESBKEY = "IoCESBBus";
///

IDatabase redis = RedisManager.Instance.GetDatabase;
///

private static object _objLock = new object;
///

private readonly IContainer container = new AutofacContainer;

事件的統一訂閱

　　　public void SubscribeAll
{
var types = AssemblyHelper.GetTypesByInterfaces(typeof(IBusHandler<>));
Dictionary> keyDic = new Dictionary>;
foreach (var item in types)
{
if (!item.IsGenericParameter)
{

TypeInfo typeInfo = IntrospectionExtensions.GetTypeInfo(item);

foreach (var t in typeInfo.GetMethods.Where(i => i.Name == "Handle"))
{
//ioc name key
var eventKey = t.GetParameters.First.ParameterType.Name;
var key = t.GetParameters.First.ParameterType.Name + "_" + item.Name;
//eventhandler
var inter = typeof(IBusHandler<>).MakeGenericType(t.GetParameters.First.ParameterType);
container.Register(inter, item, key);

if (keyDic.ContainsKey(eventKey))
{
var oldEvent = keyDic[eventKey];
oldEvent.Add(key);
}
else
{
var newEvent = new List;
newEvent.Add(key);
keyDic.Add(eventKey, newEvent);
}
}
}
//redis存儲事件與處理程序的映射關係
foreach (var hash in keyDic)
redis.HashSet(
ESBKEY,
hash.Key.ToString,
JsonConvert.SerializeObject(hash.Value));

}

}

事件的發布，相關處理程序會從容器中取出，並執行它們的Handler方法

　　public void Publish(TEvent @event)
where TEvent : class, IBusData
{
var keyArr = JsonConvert.DeserializeObject>(redis.HashGet(ESBKEY, typeof(TEvent).Name));
foreach (var key in keyArr)
{
var item = container.ResolveNamed>(key);
item.Handle(@event);
}

}

說到這裡，大叔的服務匯流排的IoC實現方式就算是完成了，經過測試後，在.net core上表現也很不錯！

自己也驕傲一次，呵呵！

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！