Rafy中的EventBus

EventBus主要是幹嗎使的，直接翻譯叫事件總線。

 

是觀察者模型的實現，利用它你既能夠實現觀察者模型的業務場景，還能夠基於它的事件驅動機制來實現應用程序內組件之間的解耦與通訊。

 

咱們來看看有EventBus的總線結構圖，以下：

Rafy中的EventBus使用入口是基於上圖中Composer組件組合器，使用的時候都是

經過 操做 Composer.EventBus 來控制事件的註冊與發佈。

 

因此Composer起到了橋樑的做用，經過它外界能夠操做EventBus,那麼EventBus是什麼呢

 

原來當咱們調用Composer.EventBus的時候,Composer只是給咱們返回了一個IEventBus接口的實現，若是IOC容器裏面有這樣的實現，就找出來返給調用者，若是沒有的話，就返回Rafy內部默認的IEventBus的實現。

 

先讓咱們來看下，IEventBus內部都提供了什麼接口

 

/// <summary>
    /// 事件總線
    /// </summary>
    public interface IEventBus
    {
        /// <summary>
        /// 向總線發佈一個指定的事件。
        /// </summary>
        /// <param name="eventModel"></param>
        void Publish(object eventModel);

        /// <summary>
        /// 向總線發佈一個指定的事件。
        /// </summary>
        /// <typeparam name="TEvent"></typeparam>
        /// <param name="eventModel"></param>
        void Publish<TEvent>(TEvent eventModel);

        /// <summary>
        /// 向總線訂閱一個指定的事件。
        /// </summary>
        /// <typeparam name="TEvent">事件類型。</typeparam>
        /// <param name="owner">事件的監聽者。</param>
        /// <param name="handler">監聽函數。</param>
        void Subscribe<TEvent>(object owner, Action<TEvent> handler);

        /// <summary>
        /// 向總線取消一個指定的事件的訂閱。
        /// </summary>
        /// <typeparam name="TEvent">事件類型。</typeparam>
        /// <param name="owner">事件的監聽者。</param>
        void Unsubscribe<TEvent>(object owner);

        /// <summary>
        /// 獲取指定事件的全部監聽者。
        /// </summary>
        /// <typeparam name="TEvent">指定的事件類型。</typeparam>
        /// <returns></returns>
        IEventSubscribers GetSubscribers<TEvent>();
    }

IEventBus這個接口提供了四個功能

1. 發佈事件
2. 訂閱事件
3. 取消訂閱事件
4. 查詢事件的監聽者

 

看完這個接口，若是咱們想要實現本身的EventBus的放，應該怎麼作呢？

 

前幾天咱們看到Rafy內部的IOC實現，Composer.ObjectContainer,對外提供了IOC容器

 

經過查詢IOC容器接口：

咱們只須要，添加本身的實例，而後經過IObjectCcontainer的RegisterInstance方法，把咱們的IEventBus實現，註冊進容器，當用戶調用Composer.EventBus 系統會優先返給它咱們實現的IEventBus對象。

 

那麼接下，讓咱們看看，Rafy提供的IEventBus默認實例是怎麼實現的

EventBus訂議了一個私有的變量_SubScribers 字典，key 爲對象類型，值爲實現了IEventSubscribers接口的對象

    /// <summary>
    /// 某個事件的處理者列表。
    /// </summary>
    public interface IEventSubscribers
    {
        /// <summary>
        /// 對應的事件類型。
        /// </summary>
        Type EventType { get; }

        /// <summary>
        /// 返回當前已有的監聽者個數。
        /// </summary>
        int Count { get; }

        /// <summary>
        /// 直接向全部監聽者發佈該事件。
        /// </summary>
        /// <param name="eventModel"></param>
        void Publish(object eventModel);
} 

當咱們經過 Subscribe方法來訂閱事件的時候，查看原碼

發現方法內部，把訂閱者和回調函數都存在了訂閱者列表裏面.

 

當調用者發佈指定類型事件的時候，發佈方法(Publish)會通知訂閱者列表裏面的每個監聽者.

訂閱發佈咱們都知道了，用戶怎麼使用事件總線呢？

其中訂閱方法SubScribe裏面

 

EventBusArgs就是指事件訂閱類型

This指當前訂閱對象

E對應的回調函數，就是此類事件發佈時要執行的動做

 

Publish new EventBusArgs 指定了要發佈的事件類型，全部監聽此事件的監聽者

都會執行此自動的動做。