返回 登录
3

RabbitMQ的事件总线

事件总线的重构

根据前面的结论,事件总线的执行需要依赖于事件处理器执行上下文,也就是上面类图中PassThroughEventBus对于IEventHandlerExecutionContext的引用。更具体些,是在事件总线订阅某种类型的事件时,需要将事件处理器注册到IEventHandlerExecutionContext中。那么在实现RabbitMQ时,也会有着类似的设计需求,即RabbitMQEventBus也需要依赖IEventHandlerExecutionContext接口,以保证事件处理器生命周期的合理性。

为此,我们新建一个基类:BaseEventBus,并将这部分公共的代码提取出来,需要注意以下几点:
1.通过BaseEventBus的构造函数传入IEventHandlerExecutionContext实例,也就限定了所有子类的实现中,必须在构造函数中传入IEventHandlerExecutionContext实例,这对于框架的设计非常有利:在实现新的事件总线时,框架的使用者无需查看API文档,即可知道事件总线与IEventHandlerExecutionContext之间的关系,这符合SOLID原则中的Open/Closed Principle
2.BaseEventBus的实现应该放在EdaSample.Common程序集中,更确切地说,它应该放在EdaSample.Common.Events命名空间下,因为它是属于框架级别的组件,并且不会依赖任何基础结构层的组件

BaseEventBus的代码如下:

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

public abstract class BaseEventBus : IEventBus

{
protected readonly IEventHandlerExecutionContext eventHandlerExecutionContext;

protected BaseEventBus(IEventHandlerExecutionContext eventHandlerExecutionContext)

{

this.eventHandlerExecutionContext = eventHandlerExecutionContext;

}

public abstract Task PublishAsync(TEvent @event, CancellationToken cancellationToken = default) where TEvent : IEvent;

public abstract void Subscribe

评论