Osheep

时光不回头,当下最重要。

Axon Framework管理复杂的业务事务

并不是每个命令都能够在一个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。

点赞