Reface.AppStarter 中的事件总线功能是通过 Reface.EventBus 提供的。
使用 Reface.EventBus ，你可以在 Reface.AppStarter 框架外使用事件总线的功能。
Reface.EventBus 提供了两个版本的包 Reface.EventBus 、 Reface.Core.EventBus ，分别工作在 .Net Framework 和 .Net Core 平台上。
除了一些细节的不同，这两个版本的使用方法完全相同。
基本篇
下面我们一起来了解如何使用 Reface.EventBus 来 定义事件 、定义监听器 、注册监听器 、发布事件 。
定义事件
事件是一个单独类型，它继承于 Reface.EventBus.Event 或 其子类 , 我们先看看 Event 的定义
public class Event
{
public object Source { get; private set; }
public Dictionary<string, object> Context { get; private set; }
public Event(object source)
{
if (source == null)
throw new ArgumentNullException("source");
Source = source;
this.Context = new Dictionary<string, object>();
}
}
Event 要求一个 object 类型的构造函数，用来表示事件是由谁发布的，与 .Net 中的 event 模式中的 sender 含义相同。
属性 Source
从构造函数可以看出 , 可以通过属性 Source 获取到事件的发布者。
属性 Context
正如其名，是事件的上文对象，你可以向其中存取任何你希望的内容。该属性可以成为多个 监听者 之间 沟通 的桥梁。
使用该属性时需要注意 :
- 监听者模式情况下无论控制执行顺序，因此要考虑到当前监听者处理时，某些上下文的内容尚未创建
- 如果你的监听者对上下文有着严格的前后 顺序要求，请为监听器添加优先级的功能 （后文有介绍）
示例
我们定义一个事件，可以在控制台程序中，描述一个用户输入了一个命令的事件。
public class CommandReadEvent : Event
{
public string Command { get; private set; }
public CommandReadEvent(object source, string cmd) : base(source)
{
this.Command = cmd;
}
}
定义监听器
所有的监听器必须实现 IEventListener<TEvent> 接口，IEventHandler<T> 的定义如下
public interface IEventListener<TEvent>
where TEvent : Event
{
void Handle(TEvent @event);
}
泛型 TEvent
泛型指定了该监听器监听哪种事件类型的事件。
职责单一 是重要的设计思想。因此，一件监听器只能针对一个事件类型进行处理。
方法 Handler
该方法是事件处理的具体过程，参数就是事件类型。
同样，我们依照 职责单一 的原则，强烈建议一个监听器内只实现一个任务，多个任务由多个监听器实现。
监听器在哪儿 ?
EventBus 无法得知开发者把它们的 监听器 都写在哪儿，所以需要以某种方式发现它们，才能调度它们。
IEventListenerFinder 就是负责找到这些 监听器 并创建它们实例的组件。
关于 监听器 的创建
所有的 监听器 都是通过 IEventListenerFinder 创建的。
.Net Framework 版本中所有的 IEventListenerFinder 都不支持 IOC / DI , 如果你希望对 监听器 注入外部组件，可以考虑和成熟的 IOC / DI 库集成，比如 Autofac、Inject 等等。
在 .Net Core 版本中，已经实现了与 ServiceCollection 的集成，当你编写 Web
项目时，你可以在 Startup.ConfigureService 中启用 EventBus 的功能以及对程序集内的所有 监听器 的发现与注册。
以下是在 .Net Core 版本中，如何启用 EventBus 以及对 监听器 的发现与注册
services // ServiceCollection 的实例
.AddEventBus() // 注册运行 EventBus 的必要组件
.AddEventListeners(typeof(SomeClass).Assembly); // 扫描指定程序集内的 监听器 并注册到容器中
在 .Net Framework 中注册监听器
强烈建议将你的 IEventListenerFinder 与 IOC / DI 容器集成。
但是，如果你没有这样的需求，你也可以通过以下两种方式向 EventBus 注册你的 监听器
1. 通过 config 文件注册监听器
首先，将 config* 文件添加 section 节点，建议使用 eventBus 作为 name 的值。
<section name="eventBus" type="Reface.EventBus.Configuration.EventBusSection, Reface.EventBus"/>
接下来在 configuration 节点内，添加 eventBus 节点
<configuration>
<eventBus>
<listeners>
<add type="Demo.Listeners.OnConsoleStarted02, Demo" />
<add type="Demo.Listeners.OnConsoleStarted01, Demo" />
<add type="更多的监听器类型名称" />
</listeners>
</eventBus>
</configuration>
类型名称应由 类型全名+逗号+程序集名 组成。
配置文件是 EventBus 默认的选项，你不需要做任何额外的编码，就可以发布事件了。
IEventBus eventBus = new EventBus();
eventBus.Publish(new MyEvent());
当 EventBus 发布事件时，会通过 Activator.CreateInstance(Type) 的方式创建这些 监听者，因此你的 监听者 的构造函数不可以有参数。
2. 扫描程序集以发现监听器
通过这种方式，你可以指定一些程序集，EventBus 会预先扫描它们，并将实现了 IEventListener 接口的类型记录。
与 config 模块相同，监听器 是通过 Activator.CreateInstance(Type) 的方式创建的，因此 监听者 的构造函数依然不可以有参数。
发布事件
IEventBus 是发布事件的组件，它只包含一个成员，Publish 用于发布事件。
public interface IEventBus
{
void Publish(Event @event);
}
库中只有一个 IEventBus 的实现类 : EventBus。
该类是依赖 IEventListenerFinder 发现 监听器 并发布 事件。
你也可以实现属于你自己的 IEventBus ，你可以让它通过 MQ 等其它方式来发布事件。
扩展篇
监听者的执行顺序
一个 Event 可以触发多个 监听器 的执行。在正常情况下，EventBus 只以 注册的顺序 或 扫描程序集的顺序 来决定 监听器 的执行顺序。
在实际开发环境中，如果你对 监听器 的执行顺序有要求，比如，AListener 必须早于 BListener , 你可以选择以下两个解决方案
- 设计一个新的事件，当 AListener 完成后触发，BListener 监听新的事件
- 为 AListener 和 BListener 实现优先级接口，并让 AListener 优于 BListener
库内有接口 IPrioritized , 它可以让你的 监听器 额外提供一个 优先级 的属性，这是一个 int 型的属性，数值越小，就越先执行。
对于未实现 IPrioritized 的 监听器，优先级一律是 int.MaxValue 。
public class AListener : IEventListener<SomeEvent>, IPrioritized
{
public int Priority => 0;
public void Handle(SomeEvent @event)
{
Console.WriteLine("Console Started 01");
}
}
Event 的继承
使用 Reface.EventBus ，你可以设计具有继承关系的 Event 类型。
比如
// 删除数据的事件
public class DataDeletingEvent : Event {}
// 删除用户的事件
public class UserDeletingEvent : DataDeletingEvent {}
// 删除部门的事件
public class DeptDeletingEvent : DataDeletingEvent {}
当你对事件监听时，你可以编写一个 监听器 来监听 DataDeletingEvent ，
public class DataDeletingEventListener : IEventListener<DataDeletingEvent>
{
}
该处理器可以处理所有 DataDeletingEvent 及 其子类 的事件。
运行机制
当 Publish(TEvent) 时，都发生了什么事 ?
- 调用 IEventListenerFinder.CreateAllEventListeners() 获取所有事件 处理器
- 对所有的 处理器 进行排序
- 没有标记 IPrioritized 的处理器优先级为 int.MaxValue
- 排序按 Priority 从小到大排序
- 从 缓存中获取 或 分析 哪些 处理器 将参与此次 事件 的处理
- 对参与此次 事件 的 处理器 从缓存或创建 DynamicMethod 用于执行 Handle 方法 , DynamicMethod 是通过 Emit 创建的，因此执行速度是非常快的
- 执行所有的 DynamicMethod
相关链接