Rafy中的EventBus

时间：2017-09-20 10:21:29 阅读：104 评论：0 收藏：0 [点我收藏+]

标签：结构 bsp mode count publish 基于监听 http 执行

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这个接口提供了四个功能

发布事件
订阅事件
取消订阅事件
查询事件的监听者

看完这个接口，如果我们想要实现自己的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);
}