AxonFramework管理复杂的业务事务

并不是每个命令都能够在一个ACID事务中完全执行。现金转账事务是一个很常见频繁出现的例子,用来作为论据。通常认为,把钱从一个账户转移到另一个账户,绝对需要原子性和一致性。其实并非如此,相反,这是完全不可能的。如果钱从A银行的帐户转移到B银行的帐户怎么办?A银行要获得B银行数据库的锁吗?如果转账正在进行的时候,A银行已经扣除了金额,但B银行并没收到它,这不是很奇怪吗?事实上不是,这是“正在进行”。另一方面,如果在向B银行的帐户中存资金时出现错误,A银行的客户就想要他的钱回退。所以我们需要某种形式的最终一致性。

虽然ACID事务在某些情况下不是必需的甚至是不可能的,但仍然需要某种形式的事务管理。通常,这些事务称为BASE事务:基本的可用性,软性状态,最终一致性。 与ACID相反,BASE事务无法轻松回滚。 要回滚,需要采取补偿措施来恢复作为事务一部分发生的任何事情。 在汇款的例子中,如果没有把钱存入B银行,将把钱退还给A银行。
在CQRS中,Sagas可用于管理这些BASE事务。 他们对事件做出响应,并可能调度命令,调用外部应用程序等。在领域驱动设计的上下文中,将Sagas用作多个限界上下文之间的协调机制并不罕见。

Saga
一个saga是一种特殊类型的事件监听器:用来管理业务事务。一些事务可能运行数天甚至数周,而另一些则在几毫秒内完成。在Axon中,saga的每个实例负责管理一个业务事务。这意味着saga维护状态必须管理事务,持续或采取补偿动作回滚已经被采取任何动作。通常情况下,与常规的事件监听器相反,saga有一个起点和终点,都由事件触发。虽然saga的起点通常是非常明确的,但可能有多种方式结束一个saga。

在Axon中,Sagas是定义了一个或多个@SagaEventHandler方法的类。与常规事件处理器不同,在任何时间可能存在多个saga的实例。Saga由一个Processor管理(跟踪或订阅),Processor通过事件致力于处理特定saga类型。

生命周期
一个单独的saga实例负责管理一个单独的事务。这意味着你需要能够标示一个saga生命周期的开始和结束。

在一个saga中,事件处理器用@SagaEventHandler注解。如果一个特定的事件标志着开始一个事务,在同一个方法上添加另一个注解:@StartSaga。这个注解将创建一个新的saga,并且当匹配事件后布后调用它的事件处理器方法。

默认情况下,只有在找不到匹配的saga时才能开启一个新的saga。你也可以强行创建一个新的saga实例,通过把@StartSaga注解上的forceNew属性设置为true。

结束一个saga可以以两种方式完成。如果一个特定的事件总是标示saga生命周期的结束,在saga上用@EndSaga注解事件的处理器。在调用处理器后,saga的生命周期将结束。作为一种选择,你可以调用end()从saga内部去结束生命周期。这允许你有条件地结束saga。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 173,455评论 25 708
  • 很多人喜欢这篇文章,特此同步过来 由浅入深谈论spring事务 前言 这篇其实也要归纳到《常识》系列中,但这重点又...
    码农戏码阅读 4,785评论 2 59
  • 犯罪意识 在这里我感觉更好的表述应该是所谓的“罪恶感”。比如说谎之后的那种感觉。这里面当然不是指真的犯罪了,而是说...
    胆小的鳄鱼阅读 202评论 0 2
  • 1、油性肌肤做面膜需冷藏; 油皮的脸上总是因为油脂变得暗沉甚至长痘。最好要选择具有补水控油效果的面膜,并在敷面膜之...
    muyanggirl阅读 240评论 0 0
  • 忽然得知老家的一个爷爷去世的消息,是在一次普通的电话中。 我不过随口问一句家中最近有什么事么,得到了电话那端父亲有...
    Lain_M阅读 229评论 0 0