AxonFramework命令模型
在一个基于CQRS的应用程序中,领域模型(由Eric Evans和Martin Fowler定义)可以是一个非常强大的机制,来驾驭在验证和执行状态的变化时所涉及的复杂性,虽然典型的领域模型提供了大量的构建块,但当在CQRS中应用命令处理时有一个构件起着主导性的作用:聚合。
应用程序中的一个状态的改变,始于一个命令。命令不但是表达意图(描述你想要做什么)的组合,而且是基于这一意图采取行动所需的信息。命令模型用于处理传入的命令,以验证并定义它的结果。在这个模型中,一个命令处理器负责处理某种类型的命令,并根据它包含的信息采取行动。
聚合
聚合是一个总是保持一致性状态的实体或一组实体。聚合根是聚合树顶部负责维护这个一致性状态的对象。这使得聚合主要构件在任何基于CQRS应用中实现命令模型。
注意例如,“联系人”聚合可以包含两个实体:联系人和地址。若要保持整个聚合处于一致性状态,向联系人添加地址时应通过联系人实体完成。在这种情况下,联系人实体是约定的聚合根。
“聚合”指的是埃文斯在领域驱动设计中所定义的聚合:
”作为数据变更的一个单元来处理的一组相关联的对象。在外部只能引用聚合的聚合根对象。在聚合边界内使用一组一致性规则。”
【AxonFramework命令模型】在Axon中,聚合由聚合标识符标识。这可能是任何对象,但也有一些标识符良好实现的指导原则。
标识符必须:
- 实现equals和hashCode来保证与其他实例进行相等比较,
- 实现一个提供一致结果的toString()方法(相等的标识符,toString()方法的结果也应该相等),
- 并且最好是可序列化的。
注意此外,聚合应小心地使用函数式标识符。因为它们有变化的倾向,使得它很难适应相应的应用程序。
一个经过深思熟虑的好实践是使用随机生成的标识符,而不是使用序列。使用序列会大大降低应用程序的可伸缩性,因为机器需要保持彼此最后一次使用的最新的序列号。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发布时这些方法将被调用(在任何外部处理器被发布之前)。
推荐阅读
- 你命令我爱你吧(原创)
- Flutter的ListView
- 一般模型化关系——从模型是什么到如何起作用的基本答案
- 常用git命令总结
- 用Go构建区块链——3.持久化和命令行
- 《读_Head_First_有感》_“命令模式”
- locate搜索
- Pytorch学习|sklearn-SVM 模型保存、交叉验证与网格搜索
- 旅途碎碎念
- Linux|Linux 服务器nginx相关命令