我应该如何使用Axon框架为Saga编排运行补偿/回滚步骤？

Question

对于我想要为Axon的几个服务实现Saga编排的用例，我构建了：

• 订单服务（带有Spring boot Axon框架的saga orchestrator）
• 支付服务（微服务）
• 运输服务（微服务）

然后我有一个用@Saga注释的类，有3个步骤/事件处理程序：

• 订单已创建（首次服务）

我的问题是，如果运输服务失败，我应该如何回滚/补偿所有以前执行的步骤？

从留档我有一些疑问：

• 我需要用@Saga创建一个新类吗
• 在失败的服务上，我应该引发异常还是将错误发送到另一个命令/事件
• 我应该如何调用SagaLifecycle。end（）

如果有一个显示一些代码的解决方案，那就太好了。谢谢！

Answer 1

一个实施良好的佐贺可以处理佐贺所管理的事务中出现的任何错误场景。因此，在从传奇内部调度任何操作时，您应该能够预料到一个例外情况，您将对此做出反应。正是这种反应才是你想要的补偿作用。

现在，为了回答你的确切问题：

我需要用@Saga创建一个新类吗？

我很有信心，你不需要一个新的传奇来解决你所在领域的例外情况。所以没有。

在失败的服务上，我应该引发异常还是将错误发送到另一个命令/事件

在这里，我会选择带有异常或事件，而不是命令（因为（Axon）Saga不处理命令）。您是否选择任一路线取决于该事件是否是有价值的业务事件，因此需要在事件中无限期存储。然而，使用事件意味着您将Saga的容错行为拆分为不同的saga事件处理程序，我个人不喜欢这样。因此，我更喜欢从saga要处理的服务之一抛出异常。随后，如果您需要存储异常事件，只需在它旁边发布一个事件。

我应该如何称呼SagaLifecycle.end（）

老实说，我不确定你想问这个问题。萨伽利夫循环。一旦传奇的生命周期结束，应该调用end（）。因此，当该事务完成时。当它完成时，完全取决于您的领域，并注意到一些必要的事实，您需要调度一个补偿动作。

为了澄清我的意图，这里有一些（伪）代码显示了我将在哪里执行补偿操作：

java prettyprint-override">private transient CommandGateway commandGateway;

@SagaEventHandler(assocationProperty = "some-association)
public void on(SomeEvent event) {
    // Validate/set state if necessary
    commandGateway.send(new SomeCommand(...))
                  .exceptionally(exception -> {
                      // Dispatch compensating action through service/CommandGateway
                  });
}