转载

ENode 2.6 架构与设计简介以及全新案例分享

前言

ENode是一个应用开发框架，为开发人员提供了一整套基于DDD+CQRS+ES+EDA架构风格的解决方案。ENode从发布1.0开始到现在，我几乎每周都在更新设计或实现代码。以至于从来没有一个稳定的版本可以提供给大家，非常惭愧。但我相信，随着时间的推移和我的努力的积累，ENode一定会越来越稳定和成熟的。我觉得我此刻很幸福，因为我有自己的兴趣且有机会为了自己的兴趣而奋斗。

ENode开源地址： https://github.com/tangxuehua/enode

今天是个开心的日子，因为我终于使用ENode开发出了一个比较有说服力的真实案例，一个在线会议位置管理与订购系统。该案例与微软的 Microfost CQRS Journey案例的功能一致，只是是用ENode开发完成的。目的是为了展示：

如何使用ENode支持DDD领域层的实现；
如何使用ENode实现CQRS+ES的架构；
如何使用ENode实现事件驱动的架构（EDA）；

另外，在案例开发过程中，也不断发现了ENode, EQueue的很多问题。所以，通过做这个案例，也帮助ENode, EQueue完善了很多。真是要实践才能进步啊！

ENode架构简介

ENode目前的架构已经和最初的1.0版本有较大的差别了。比如，没有了对Redis的依赖，增加了Command Store的设计。最新版本的ENode架构图如下：

ENode 2.6 架构与设计简介以及全新案例分享

熟悉CQRS架构的人应该对这个图不太陌生。需要强调的有两点：

新版的架构图中，Domain Aggregate是常驻内存的；聚合根的职责就是封装状态、业务规则，同时产生领域事件；
新增了一个Command Store，用于实现Command的幂等处理；

关于图中的其他部分的介绍，请参看我之前写的关于ENode系列的文章。

ENode关键特性

实现了CQRS架构，支持分布式，基于队列的水平扩展，框架设计之初就考虑了架构的各个节点的水平扩展；
面向高并发设计；架构层面，充分考虑到了如何解决并发问题；通过用EQueue实现服务器之间的消息路由、通过单机内部实现类似Actor Mailbox的设计，从而避免并发的产生。提高CQRS架构C端的整体写入吞吐量；即便在某些极端情况下出现并发问题，也支持自动的乐观检测，并自动重试；另外，架构层面，规定一个command只能涉及一个聚合根的修改，从而规范应用开发者必须严格按照消息驱动的思路来实现复杂的业务流程，而不能使用工作单元的方式，以事务的方式实现数据的强一致性；
严谨的消息幂等处理支持；由于ENode是消息驱动的架构，所以对消息的幂等性处理，是框架关注的一个重要的方面，并在架构层面做了支持。这使得应用开发人员不必担心消息的重复处理带来的问题。
Domain Aggregate常驻内存；这个设计可以提高C端command的处理性能。因为我们不必像传统的方式那样先把聚合根从db取出来，再修改，再保存回去了；
框架为开发人员展示了如何更好的实现Sagas，在CQRS架构中，Sagas指基于消息驱动的业务流程；一个Saga包含若干个聚合根以及一个（通常）流程管理器（Process Manager）；聚合根维护流程中的所有参与者对象的状态以及流程本身的状态，流程管理器负责定义和实现流程控制逻辑，无状态；流程管理器的实现是通过响应事件、异常、应用层消息，然后发送相应的命令，从而实现消息驱动的流程；
采用Event Sourcing（简称ES）的方式来持久化聚合根状态；通过ES实现聚合根状态的还原以及通用的并发控制，通过聚合根ID+事件版本号作为唯一索引的思路实现乐观并发控制；
消息除了command, domain event外，还支持exception message, application message；这两种消息是我们在遇到有些消息不适合用domain event来表达时需要使用到；比如聚合里有时我们要修改某个状态前会先做业务规则的检查判断，如果不合法，通常会抛异常，然后这个异常我们又希望可以让流程管理器知道，从而流程管理器可以做后面的回滚或补偿措施；另外，我们有时可能会在应用层面（command handler里）和其他外部系统发生交互，那交互的结果，使用应用层的消息更合理；ENode在架构层面，对上面这些消息做了统一的支持；
框架提供返回单个command执行结果以及阻塞等待command执行结果的支持，这个对于开发者希望同步执行command并知道command执行结果的时候，非常有帮助；这样开发者就不用自己去轮训了。
除了对消息的幂等处理的支持外，ENode对domain event的顺序处理，也做了充分的考虑和支持，确保当C端产生的domain event同步到Q端时，Q端处理时，框架层面能确保Q端的处理顺序不会乱序。从而保证C,Q两端的数据是最终一致的；
保证消息能至少被处理一次；主要思路是确保消息的：1）持久化；2）消息ACK后才认为已消费；
支持一个聚合根一次可以产生多个domain event；虽然大部分情况，一个聚合根一次只会产生一个domain event，但有些场景，可能会产生两个或多个。此时，这些事件会以一个事件流的方式一起apply到当前聚合根；同时，在Q端，框架也会通过必要的手段，与用户代码一起保证了事件流中的事件的处理顺序的正确性；
ENode所使用的分布式消息队列EQueue，参考了阿里的RocketMQ的架构思想，具有高性能、可扩展、轻量级的特性，支持不受限于机器内存大小的消息堆积能力，而且是纯C#开发。同时还提供了简单实用的管理控制台，可以让我们轻松的管理消息队列。比如可以方便的动态增加、禁用、启用、删除队列，查询消息内容、消息消费进度，等信息；目前，EQueue也已经经过多个迭代，并且已经有真实用户进行使用，功能基本趋于成熟稳定。