用示例程序介绍CQRS和事件溯源机制

Posted dotNET跨平台

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了用示例程序介绍CQRS和事件溯源机制相关的知识,希望对你有一定的参考价值。

Sacha Barber在提升自己对CQRS(Command Query Responsibility Segregation)设计所包含的架构和模式的理解过程中,决定构建一个包含事件溯源机制的CQRS演示程序,并撰写了一篇文章解释内部工作机制。

Barber是Microsoft C# MVP,他将CQRS描述为一种分离职责的设计,可以将没有副作用的查询类读操作和更改数据的写操作职责相互分离。他的示例中采用了Vladimir Khorikov早先定义的第三种CQRS实现模式,对于读写职责均使用不同的模型和存储方式。Barber将事件溯源定义为一种方法,应用将状态的变化存储为一系列事件,并且应用不仅仅只存储当前的状态。为了得到某个对象当前的状态,应用需要取回所有的事件,并在这个对象上顺序回放。这种方法,通过重放某一时点的事件并调整相关状态,来实现追溯应用过去的状态。

使用基于事件的写模型并将读写模型的存储分离,意味着写操作端的变化都需要通过事件机制在读模型中更新。这种更新以异步的方式执行,意味着写模式下的变化可能不会立刻在后续的读操作中反映出来,并且Barber注意到应用程序当前是处于一种确保最终一致性的状态。基于此,他认为典型的CQRS实现并不适用于请求返回类型的操作,客户期盼对请求都能有即刻正确的响应。因此,Barber认为,那些从用户的角度去看,查询和写操作就相互明确区分的业务场景,更加适用于使用CQRS。

为了加深对CQRS的理解,Barber基于.Net平台构建了一个完整的示例程序,包含了CQRS的所有部分,并使用RabbitMQ消息队列实现事件溯源的异步机制,以此作为一种读写模型之间跨进程总线的交互方式。为了简化程序,他尽可能使用内存模型,包括事件的存储实现方式,这意味着程序多次运行之间的数据并不具备持久性。整个应用包含了一个命令总线、一个领域模型、一个写操作端的事件存储、一个事件总线和一个NoSql数据库,以及读操作端的事件处理器和一个数据访问层。

人们通常认为现成的CQRS框架会对应用实现CQRS设计造成障碍,但Barber考虑到自身对于CQRS经验欠缺,所以还是基于CQRSlite构建了示例程序,而CQRSLite是对早期Greg Young实现的CQRS框架的一个扩展。


原文链接:http://www.infoq.com/cn/news/2015/06/cqrs-eventsourcing-demoapp


以上是关于用示例程序介绍CQRS和事件溯源机制的主要内容,如果未能解决你的问题,请参考以下文章

CQRS 和事件溯源指南

使用事件溯源和 CQRS 的缺点是啥?

译见 | 用 Docker,Spring Boot/Cloud 和 Axon CQRS/ES(事件溯源)来构建微服务

事件溯源和 CQRS,我错过了啥?

「事件驱动架构」事件溯源,CQRS,流处理和Kafka之间的多角关系

事件溯源/CQRS 读取模型 - 预测