ENode 2.6 架构与设计简介以及全新案例分享-阿里云开发者社区

开发者社区> shy丶gril> 正文

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

简介:
+关注继续查看

前言

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

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

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

  1. 如何使用ENode支持DDD领域层的实现;
  2. 如何使用ENode实现CQRS+ES的架构;
  3. 如何使用ENode实现事件驱动的架构(EDA);

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

ENode架构简介

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

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

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

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

ENode关键特性

  1. 实现了CQRS架构,支持分布式,基于队列的水平扩展,框架设计之初就考虑了架构的各个节点的水平扩展;
  2. 面向高并发设计;架构层面,充分考虑到了如何解决并发问题;通过用EQueue实现服务器之间的消息路由、通过单机内部实现类似Actor Mailbox的设计,从而避免并发的产生。提高CQRS架构C端的整体写入吞吐量;即便在某些极端情况下出现并发问题,也支持自动的乐观检测,并自动重试;另外,架构层面,规定一个command只能涉及一个聚合根的修改,从而规范应用开发者必须严格按照消息驱动的思路来实现复杂的业务流程,而不能使用工作单元的方式,以事务的方式实现数据的强一致性;

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

Conference案例简介

Conference是一个微软开发的,基于DDD+CQRS+ES的一个开源项目。项目主页:cqrsjourney.github.io

这个项目,对我们大家学习DDD领域驱动设计、CQRS+ES的架构,非常有帮助。

  • 该案例从业务上,实现了一个典型的电子商务系统的关键环节:商品管理、库存管理、下单、减库存、支付;
  • 该案例从技术上,很好的展示了CQRS架构的优点。比如可以在Q端定制不同的视图,以应对不同的查询需求;
  • 该案例很好的向我们展示了如何划分领域,划分边界上下文(bounded context),并如何使用不同的架构技术,实现不同的上下文,非常具有学习价值。

正是因为这个项目的以上优点,让我有兴趣使用ENode作为技术支撑,实现同样功能的系统。在重写的过程中,保留了所有非技术的东西,比如边界上下文的划分、领域层等;所有技术相关的部分,用ENode替代。

使用ENode实现的Conference开源项目地址:https://github.com/tangxuehua/conference

演示地址,后台:http://www.enode.me/conference,前台:http://www.enode.me/registration

希望有兴趣的同学,可以去下载源代码进行研究。了解ENode,最快的方法就是从案例代码开始。如果想进行交流,可以加QQ群:185916873,随时欢迎有兴趣的道友加入。

最后,贴一个Conference案例中订单处理的Sagas流程图:

不早了,实在写不下去了,就到这吧。


版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
好程序员web前端培训分享值得参考的css理论:OOCSS、SMACSS与BEM
  好程序员web前端培训分享值得参考的css理论:OOCSS、SMACSS与BEM最近在The Sass Way里看到了Modular CSS typography一文,发现文章在开头部分就提到了OOCSS、 SMACSS、 BEM、这3个词。
1222 0
LiveVideoStackCon讲师热身分享 ( 十一 ) —— 短视频APP的架构设计
LiveVideoStackCon 2018音视频技术大会是每年的多媒体技术人的盛宴,为了让参会者与大会讲师更多互动交流,我们推出了LiveVideoStackCon讲师热身分享第一季,在每周四晚19:30,邀请1名大会讲师进行线上分享技术干货,解答热点问题。
1069 0
PgSQL · 应用案例 · 经营、销售分析系统DB设计之共享充电宝
背景 共享充电宝、共享单车、共享雨伞,共享女朋友^|^,共享汽车,。。。 共享经济最近几年发展确实非常迅猛。 共享必定涉及被共享对象的管理、会员的管理等,实际上也属于一种物联网系统。 本文以共享充电宝的场景为例,分享一下共享充电宝的经营分析、销售管理系统的后台数据库的设计。(老板关心的是整体销售的业绩,以及各个渠道的透视等。销售经理关心的是他管辖片区的销售业绩,运维人员关心的是设备的状态。)
1368 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
4518 0
Silverlight & Blend动画设计系列十三:三角函数(Trigonometry)动画之飘落的雪花(Falling Snow)
原文:Silverlight & Blend动画设计系列十三:三角函数(Trigonometry)动画之飘落的雪花(Falling Snow)   平时我们所看到的雪花(Falling Snow)飘飘的效果实际上也是一个动画,是由许多的动画对象共同完成的一个界面效果。
748 0
分享一个 Node 进程互斥锁小模块 - lockman
### 介绍 lockman 是一个用于多进程的「互斥锁」, 类似一些语言中(比如 C#)的 lock 关键字可以用来确保代码块完成运行,而不会被其他进程「影响」。 它可以把一段代码定义为「互斥段」(critical section),「互斥段」在一个时刻内只允许一个进程进入执行, 而其他进程必须等待。 不同之处,C# 的 lock 关键字作用在「线程间」,lockman 作用在
4794 0
+关注
1878
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载