在上文中，我介绍了事件驱动型架构的一种简单的实现，并演示了一个完整的事件派发、订阅和处理的流程。这种实现太简单了，百十行代码就展示了一个基本工作原理。然而，要将这样的解决方案运用到实际生产环境，还有很长的路要走。今天，我们就研究一下在事件处理器中，对象生命周期的管理问题。
事实上，不仅仅是在事件处理器中，我们需要关心对象的生命周期，在整个ASP.NET Core Web API的应用程序里，我们需要理解并仔细推敲被注册到IoC容器中的服务，它们的生命周期应该是个怎样的情形，这也是服务端应用程序设计必须认真考虑的内容。因为如果生命周期管理不合理，程序申请的资源无法合理释放，最后便会带来内存泄漏、程序崩溃等各种问题，然而这样的问题对于服务端应用程序来说，是非常严重的。
记得在上一篇文章的结束部分，我给大家留下一个练习，就是让大家在CustomerCreatedEventHandler事件处理器的HandleAsync方法中，填入自己的代码，以便对获得的事件消息做进一步的处理。作为本文的引子，我们首先将这部分工作做完，然后再进一步分析生命周期的问题。
Event StoreEvent Store是CQRS体系结构模式中最为重要的一个组成部分，它的主要职责就是保存发生于领域模型中的领域事件，并对事件数据进行归档。当仓储需要获取领域模型对象时，Event Store也会配合快照数据库一起，根据领域事件的发生顺序，逐步回放并重塑领域模型对象。事实上，Event Store的实现是非常复杂的，虽然从它的职责上来看并不算太复杂，然而它所需要解决的事件同步、快照、性能、消息派发等问题，使得CQRS体系结构的实现变得非常复杂。在实际应用中，已经有一些比较成熟的框架和工具集，能够帮助我们在CQRS中很方便地实现Event Store，比如GetEventStore就是一个很好的开源Event Store框架，它是基于.NET开发的，在微软官方的eShopOnContainers说明文档中，也提到了这个框架，推荐大家上他们的官网（https://eventstore.org/）了解一下。在这里我们就先不深入研究Event Store应该如何实现，我们先做一个简单的Event Store，以便展示我们需要讨论的问题。
延续着上一版的代码库（https://github.com/daxnet/edasample/tree/chapter_1），我们首先在EdaSample.Common.Events命名空间下，定义一个IEventStore的接口，这个接口非常简单，仅仅包含一个保存事件的方法，代码如下：
public interface IEventStore : IDisposable { Task SaveEventAsync<TEvent>(TEvent @event) where TEvent : IEvent; }SaveEventAsync方法仅有一个参数：由泛型类型TEvent绑定的@event对象。泛型约束表示SaveEventAsync方法仅能接受IEvent接口及其实现类型的对象作为参数传入。接口定义好了，下一步就是实现这个接口，对传入的事件对象进行保存。为了实现过程的简单，我们使用Dapper，将事件数据保存到SQL Server数据库中，来模拟Event Store对事件的保存操作。
Note：为什么IEventStore接口的SaveEventAsync方法签名中，没有CancellationToken参数？严格来说，支持async/await异步编程模型的方法定义上，是需要带上CancellationToken参数的，以便调用方请求取消操作的时候，方法内部可以根据情况对操作进行取消。然而有些情况下取消操作并不是那么合理，或者方法内部所使用的API并没有提供更深层的取消支持，因此也就没有必要在方法定义上增加CancellationToken参数。在此处，为了保证接口的简单，没有引入CancellationToken的参数。
接下来，我们实现这个接口，并用Dapper将事件数据保存到SQL Server中。出于框架设计的考虑，我们新建一个Net Standard Class Library项目，在这个新的项目中实现IEventStore接口，这么做的原因已经在上文中介绍过了。代码如下：
public class DapperEventStore : IEventStore { private readonly string connectionString; public DapperEventStore(string connectionString) { this.connectionString = connectionString; } public async Task SaveEventAsync<TEvent>(TEvent @event) where TEvent : IEvent { const string sql = @"INSERT INTO [dbo].[Events] ([EventId], [EventPayload], [EventTimestamp]) VALUES (@eventId, @eventPayload, @eventTimestamp)"; using (var connection = new SqlConnection(this.connectionString)) { await connection.ExecuteAsync(sql, new { eventId = @event.Id, eventPayload = JsonConvert.SerializeObject(@event), eventTimestamp = @event.Timestamp }); } } #region IDisposable Support // 此处省略 #endregion }IDisposable接口的实现部分暂且省略，可以看到，实现还是非常简单的：通过构造函数传入数据库的连接字符串，在SaveEventAsyc方法中，基于SqlConnection对象执行Dapper的扩展方法来完成事件数据的保存。