DDD事件總線的實現

基本思路：

（1）       在事件總線內部維護着一個事件與事件處理程序相映射的字典。

（2）       利用反射，事件總線會將實現了IEventHandler的處理程序與相應事件關聯到一起，相當於實現了事件處理程序對事件的訂閱。

（3）       當發布事件時，事件總線會從字典中找出相應的事件處理程序，然后利用反射去調用事件處理程序中的方法。

 

核心類（事件總線類）

using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;


namespace Framework.EventBus
{
    public class EventBus
    {

        private static EventBus _eventBus = null;

        private static Dictionary<Type, List<Type>> _eventMapping = new Dictionary<Type, List<Type>>();  // 在這個字典中，key存儲的是事件，而value中存儲的是事件處理程序


        private EventBus() { }
        /// <summary>
        /// 單例
        /// </summary>
        /// <returns></returns>
        public static EventBus Instance()
        {
            if (_eventBus == null)
            {
                _eventBus = new EventBus();
                MapEvent2Handler();
            }
            return _eventBus;
        }



        /// <summary>
        /// 發布
        /// 這里沒有用到隊列之類的東西，使用的是直接調用的方式
        /// </summary>
        /// <param name="eventData"></param>
        public void Publish(BaseEvent eventData)
        {
            // 找出這個事件對應的處理者
            Type eventType = eventData.GetType();

            if (_eventMapping.ContainsKey(eventType) == true)
            {
                foreach (Type item in _eventMapping[eventType])
                {
                    MethodInfo mi = item.GetMethod("Handle");
                    if (mi != null)
                    {
                        object o = Activator.CreateInstance(item);
                        mi.Invoke(o, new object[] { eventData });
                    }
                }

            }
        }





        /// <summary>
        /// 將事件與事件處理程序映射到一起
        /// 使用元數據來進行注冊
        /// </summary>
        static void MapEvent2Handler()
        {
            Assembly assembly = Assembly.GetExecutingAssembly();
            Type[] types = assembly.GetTypes();

            foreach (Type type in types)
            {
                Type handlerInterfaceType = type.GetInterface("IEventHandler`1");  // 事件處理者

                if (handlerInterfaceType != null) // 若是事件處理者，則以其泛型參數為key，事件處理者的集合為value添加到映射中
                {
                    Type eventType = handlerInterfaceType.GetGenericArguments()[0]; // 這里只有一個
                    // 查找是否存在key
                    if (_eventMapping.Keys.Contains(eventType))
                    {
                        List<Type> handlerTypes = _eventMapping[eventType];
                        handlerTypes.Add(type);
                        _eventMapping[eventType] = handlerTypes;
                    }
                    else // 存在則添加
                    {
                        List<Type> handlerTypes = new List<Type>();
                        handlerTypes.Add(type);
                        _eventMapping.Add(eventType, handlerTypes);
                    }
                }
            }
        }

    }
}

 

核心類（事件基類）

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace Framework.EventBus
{
    public class BaseEvent
    {

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

        /// <summary>
        /// 事件源
        /// </summary>
        public object EventSource { get; set; }


    }
}

核心類（事件處理程序接口）

namespace Framework.EventBus
{
    public interface IEventHandler<T>
        where T : BaseEvent
    {
        void Handle(T eventData);
    }
}

 

使用方法

實現接口IEventHandler<T>

using System;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
 

namespace Framework.EventBus
{
    /// <summary>
    /// 實現了IEventHandler<OrderAddedEvent>接口，就是訂閱了OrderAddedEvent事件
    /// </summary>
    public class OrderAddedEventHandler1 : IEventHandler<OrderAddedEvent>
    {
        public void Handle(OrderAddedEvent eventData)
        {

            Console.WriteLine("\r\n");
            Console.WriteLine("訂單的數據是：" );
            Console.WriteLine("  訂單號：" + eventData.Order.OrderId);
            Console.WriteLine("  訂單金額：" + eventData.Order.OrderAmount);
            Console.WriteLine("  下單時間：" + eventData.Order.OrderDateTime);

        }
    }
}

注：實現了IEventHandler<OrderAddedEvent>接口，就是訂閱了OrderAddedEvent事件

訂單類

public class OrderEntity
{

    /// <summary>
    /// 訂單編號
    /// </summary>
    public string OrderId { get; set; }


    /// <summary>
    /// 下單日期
    /// </summary>
    public DateTime OrderDateTime { get; set; }


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

}

 

 

發布事件

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;


namespace Framework.EventBus
{
    class Program
    {
        static void Main(string[] args)
        {
            EventBus bus = EventBus.Instance();

            OrderEntity order = new OrderEntity() { OrderId = "20151017001", OrderDateTime = DateTime.Now, OrderAmount = 500 };
            bus.Publish(new OrderAddedEvent() { EventTime = DateTime.Now, Order = order }); // 發布OrderAddedEvent事件,

            Console.Read();
        }

    }
}

 

 運行結果

 

 

改進

（1）實現基於msmq的事件總線，使得系統能夠進行分布式的事件訂閱和發布。

 

下載

示例代碼

 

 

參考資料

aspnetboilerplate 

https://github.com/aspnetboilerplate/aspnetboilerplate

 

分享一個分布式消息總線，基於.NET Socket Tcp的發布-訂閱框架

http://www.cxyclub.cn/n/53667/

 

Guava - EventBus(事件總線)

http://greengerong.com/blog/2014/11/27/guava-eventbus/

 

DDD~領域事件與事件總線

http://www.cnblogs.com/lori/p/3476703.html

 

事件總線 EventBus的設計

http://www.cnblogs.com/MartinChen999/archive/2011/12/21/2294034.html