asp.net web开发 ASP.NET Core Web API下事件驱动型架构的实(8)

}

}

}

}

}

可以看到，高亮的这一行，通过Autofac创建了一个新的LifetimeScope，在这个Scope中，通过eventName来获得一个subion对象（也就是EventHandler的注册信息），进而通过scope的ResolveOptional调用来获得新的EventHandler实例。基本过程就是这样，目前也不需要纠结IDynamicIntegrationEventHandler是干什么用的，也不需要纠结为什么要使用dynamic来保存事件数据。重点是，autofac的BeginLifetimeScope方法调用创建了一个新的IoC Scope，在这个Scope中解析（resolve）了新的EventHandler实例。在eShopOnContainer案例中，EventBusRabbitMQ的设计是特定的，必须依赖于Autofac作为依赖注入框架。或许这部分设计可以进一步改善，使得EventBusRabbitMQ不会强依赖于Autofac。

接下来，我们会引入一个新的概念：事件处理器执行上下文，使用类似的方式来解决对象生命周期问题。

事件处理器执行上下文

事件处理器执行上下文（Event Handler Execution Context, EHEC）为事件处理器提供了一个完整的生命周期管理机制，在这套机制中，事件处理器及其引用的对象资源可以被正常创建和正常销毁。现在让我们一起看看，如何在EdaSample的案例代码中使用事件处理器执行上下文。

事件处理器执行上下文的接口定义如下，当然，这部分接口是放在EdaSample.Common.Events目录下，作为消息系统的框架代码提供给调用方：

public interface IEventHandlerExecutionContext

{

void RegisterHandler<TEvent, THandler>()

where TEvent : IEvent

where THandler : IEventHandler<TEvent>;

void RegisterHandler(Type eventType, Type handlerType);

bool HandlerRegistered<TEvent, THandler>()

where TEvent : IEvent

where THandler : IEventHandler<TEvent>;

bool HandlerRegistered(Type eventType, Type handlerType);

Task HandleEventAsync(IEvent @ event , CancellationToken cancellationToken = default );

}

这个接口主要包含三种方法：注册事件处理器、判断事件处理器是否已经注册，以及对接收到的事件消息进行处理。整个结构还是非常清晰简单的。现在需要实现这个接口。根据上面的分析，这个接口的实现是需要依赖于IoC容器的，目前简单起见，我们仅使用微软ASP.NET Core标准的Dependency Injection框架来实现，当然，也可以使用Autofac，取决于你怎样去实现上面这个接口。需要注意的是，由于该接口的实现是需要依赖于第三方组件的（在这里是微软的Dependency Injection框架），因此，最佳做法是新建一个类库，并引用EdaSample.Common程序集，并在这个新的类库中，依赖Dependency Injection框架来实现这个接口。

本文来自电脑杂谈，转载请注明本文网址：
https://www.pc-fly.com/a/jisuanjixue/article-60185-8.html