AxonFramework命令模型

在一个基于CQRS的应用程序中,领域模型(由Eric Evans和Martin Fowler定义)可以是一个非常强大的机制,来驾驭在验证和执行状态的变化时所涉及的复杂性,虽然典型的领域模型提供了大量的构建块,但当在CQRS中应用命令处理时有一个构件起着主导性的作用:聚合。

应用程序中的一个状态的改变,始于一个命令。命令不但是表达意图(描述你想要做什么)的组合,而且是基于这一意图采取行动所需的信息。命令模型用于处理传入的命令,以验证并定义它的结果。在这个模型中,一个命令处理器负责处理某种类型的命令,并根据它包含的信息采取行动。

聚合
聚合是一个总是保持一致性状态的实体或一组实体。聚合根是聚合树顶部负责维护这个一致性状态的对象。这使得聚合主要构件在任何基于CQRS应用中实现命令模型。

注意
“聚合”指的是埃文斯在领域驱动设计中所定义的聚合:
”作为数据变更的一个单元来处理的一组相关联的对象。在外部只能引用聚合的聚合根对象。在聚合边界内使用一组一致性规则。”

例如,“联系人”聚合可以包含两个实体:联系人和地址。若要保持整个聚合处于一致性状态,向联系人添加地址时应通过联系人实体完成。在这种情况下,联系人实体是约定的聚合根。

在Axon中,聚合由聚合标识符标识。这可能是任何对象,但也有一些标识符良好实现的指导原则。
标识符必须:

  • 实现equals和hashCode来保证与其他实例进行相等比较,
  • 实现一个提供一致结果的toString()方法(相等的标识符,toString()方法的结果也应该相等),
  • 并且最好是可序列化的。

当聚合使用不兼容标识符时,测试固件(见测试)将验证这些条件并使测试失败。 字符串类型的标识符,UUID和数值类型都适用。 不要使用原始类型作为标识符,因为它们不允许进行延迟初始化。在某些情况下,Axon可能会错误地假设原始类型的默认值是标识符的值。

注意
一个经过深思熟虑的好实践是使用随机生成的标识符,而不是使用序列。使用序列会大大降低应用程序的可伸缩性,因为机器需要保持彼此最后一次使用的最新的序列号。UUID冲突的机率非常地小(假如你生成8.2乘以10的11次方个UUID,冲突的机率也只有10的负15次方)。

此外,聚合应小心地使用函数式标识符。因为它们有变化的倾向,使得它很难适应相应的应用程序。

聚合的实现
聚合总是通过一个称为聚合根的实体访问。通常,这个实体的名称和聚合完全一样。例如,Order聚合可能由Order实体引用几个Orderline实体组合而成。Order 和Orderline一起形成聚合。

一个聚合是一个合乎规范的对象,其中包含状态和和改变这个状态的方法。虽然根据CQRS原则并不完全正确,也可能通过访问器方法暴露出聚合的状态。

聚合根必须声明一个包含聚合标识符的字段。这个标识符字段必须最迟在第一个事件发布时初始化。这个标识符字段必须由@AggregateIdentifier来注解。如果你在聚合上使用JPA注解,Axon也可以使用由JPA提供的@Id注解。

聚合可以使用AggregateLifecycle.apply()方法来注册发布的事件。与EventBus不同,这些信息需要被包装在一个EventMessage中,apply()允许你直接传递负载对象。

@Entity // Mark this aggregate as a JPA Entity
public class MyAggregate {
@Id // When annotating with JPA @Id, the @AggregateIdentifier annotation is not ne
cessary
private String id;
// fields containing state...
@CommandHandler
public MyAggregate(CreateMyAggregateCommand command) {
// ... update state
apply(new MyAggregateCreatedEvent(...));
}
// constructor needed by JPA
protected MyAggregate() {
}
}

通过定义一个带@EventHandler注解的方法,聚合内的实体能监听聚合发布的事件。当一个EventMessage发布时这些方法将被调用(在任何外部处理器被发布之前)。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,921评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,635评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,393评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,836评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,833评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,685评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,043评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,694评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,671评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,670评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,779评论 1 332
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,424评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,027评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,984评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,214评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,108评论 2 351
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,517评论 2 343

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,598评论 18 139
  • Spring Boot 参考指南 介绍 转载自:https://www.gitbook.com/book/qbgb...
    毛宇鹏阅读 46,739评论 6 342
  • 前几日已备好了酒,是给外婆捎的,满满三大箱,可够她喝一阵子。外婆是喜爱喝酒的,已是高龄,自然不管不劝,吃喝全是福气...
    青蛙他爷爷阅读 363评论 0 1
  • 祝愿大家在新的一年 365天天天开开心心 8760小时时时快快乐乐 525600分分分健健康康 31536000秒...
    小橡皮树阅读 274评论 0 0
  • 看过《基督山伯爵》的朋友们,你们还记得基督山的复仇之路走了多少年?不记得也没关系,毕竟今天并不打算说他。我一向不是...
    一知忙狗阅读 330评论 0 1