DotNetCore跨平臺~服務總線_事件總線的重新設計 - lori－IT工程師數位筆記本

文章出處

理論閑話

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

事件源和處理程序

　　 /// <summary>
    /// 事件源
    /// </summary>
    public class CreateUserCommand : BusData
    {
        public string UserName { get; set; }
    }

　　 /// <summary>
    /// 事件處理程序
    /// </summary>
    public class CreateUserCommandHandler : IBusHandler<CreateUserCommand>
    {
        public void Handle(CreateUserCommand evt)
        {
            LoggerFactory.CreateLog().Logger_Debug(evt.UserName);
            Console.WriteLine("CreateUserCommandHandler");
        }
    }

關于服務總線的實現方式

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

IoCBus實現思想與組成

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

代碼實現

數據變更的定義

 　　　　/// <summary>
        /// redis key
        /// </summary>
        const string ESBKEY = "IoCESBBus";
        /// <summary>
        /// redis事件字典
        /// </summary>
        IDatabase redis = RedisManager.Instance.GetDatabase();
        /// <summary>
        /// 模式鎖
        /// </summary>
        private static object _objLock = new object();
        /// <summary>
        /// 對于事件數據的存儲，目前采用內存字典
        /// </summary>
        private readonly IContainer container = new AutofacContainer();

事件的統一訂閱

   　　　public void SubscribeAll()
        {
            var types = AssemblyHelper.GetTypesByInterfaces(typeof(IBusHandler<>));
            Dictionary<string, List<string>> keyDic = new Dictionary<string, List<string>>();
            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<string>();
                            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>(TEvent @event)
           where TEvent : class, IBusData
        {
            var keyArr = JsonConvert.DeserializeObject<List<string>>(redis.HashGet(ESBKEY, typeof(TEvent).Name));
            foreach (var key in keyArr)
            {
                var item = container.ResolveNamed<IBusHandler<TEvent>>(key);
                item.Handle(@event);
            }

        }