9.4. 例子

例如，您需要订购一个新顺序，且您的系统中有两个不同的服务：一个用于管理该订单和一个管理学分。如果您有足够的分数，则可以在逻辑上放置一个订单。借助 Saga EIP，您可以采用 Sag y 路由作为由两种不同操作的 Saga 组成，一个用于创建顺序，另一个用于获取学分。必须执行这两个操作，否则 没有学分的订单都不能被视为不一致的结果（以及没有订单付款）。

from("direct:buy")
  .saga()
    .to("direct:newOrder")
    .to("direct:reserveCredit");

购买操作不会更改其他示例。用于对新订单和 Reserve credit 操作进行建模的不同选项如下：

from("direct:newOrder")
  .saga()
  .propagation(SagaPropagation.MANDATORY)
  .compensation("direct:cancelOrder")
    .transform().header(Exchange.SAGA_LONG_RUNNING_ACTION)
    .bean(orderManagerService, "newOrder")
    .log("Order ${body} created");

这里的传播模式被设置为 MANDATORY 意味着此路由中的任何交换流都必须是 Saga 的一部分（本例中为 Saga），因为 Saga 是在 direct:buy 路由中创建的 SANDATORY。direct:newOrder 路由声明了一个称为 direct:cancelOrder 的补偿操作，负责撤销 Saga 取消的顺序。

每个交换始终包含一个 Exchange.SAGA_LONG_RUNNING_ACTION 标头，此处用作订单的 ID。这标识了在相应的compensating 操作中删除的顺序，但这不是一个要求（选项可以作为替代解决方案使用）。direct:newOrder 的补偿操作为 direct:cancelOrder，它如下所示：

from("direct:cancelOrder")
  .transform().header(Exchange.SAGA_LONG_RUNNING_ACTION)
  .bean(orderManagerService, "cancelOrder")
  .log("Order ${body} cancelled");

当应该取消订单时，Saga EIP 实施将自动调用。它不会遇到错误。如果在 direct:cancelOrder 路由中引发错误，则 EIP 实施应定期重试，以对特定限制执行相关的操作。这意味着，任何补偿操作都必须是幂等的，因此应该考虑多次触发它，且不应在任何情况下失败。如果在所有重试重试后无法进行补偿，则 Saga 实施中应该会触发手动干预流程。

该信贷服务几乎按照与订购服务相同。

from("direct:reserveCredit")
  .saga()
  .propagation(SagaPropagation.MANDATORY)
  .compensation("direct:refundCredit")
    .transform().header(Exchange.SAGA_LONG_RUNNING_ACTION)
    .bean(creditService, "reserveCredit")
    .log("Credit ${header.amount} reserved in action ${body}");

调用compensation 操作：

from("direct:refundCredit")
  .transform().header(Exchange.SAGA_LONG_RUNNING_ACTION)
  .bean(creditService, "refundCredit")
  .log("Credit for action ${body} refunded");

此处为信用预订提供补偿操作，即退款。

from("direct:newOrder")
  .saga()
  .propagation(SagaPropagation.MANDATORY)
  .compensation("direct:cancelOrder")
  .completion("direct:completeOrder")
    .transform().header(Exchange.SAGA_LONG_RUNNING_ACTION)
    .bean(orderManagerService, "newOrder")
    .log("Order ${body} created");

from("direct:completeOrder")
  .transform().header(Exchange.SAGA_LONG_RUNNING_ACTION)
  .bean(orderManagerService, "findExternalId")
  .to("jms:prepareOrder")
  .log("Order ${body} sent for preparation");