1

我一直在关注AxonBank 示例，以了解 Saga 在 Axon 框架中的实现，并使用类似这样的代码来启动和结束 saga

@Saga
public class MoneyTransferSaga {
    @Inject
    private transient CommandGateway commandGateway;

    private String targetAccount;
    private String transferId;

    @StartSaga
    @SagaEventHandler(associationProperty = "transferId")
    public void on(MoneyTransferRequestedEvent event) {
        System.out.println("Inside start saga for money transfer event");
        targetAccount = event.getTargetAccount();
        transferId = event.getTransferId();
        SagaLifecycle.associateWith("transactionId", transferId);
        System.out.println("## These are the params going into WMC : sourceAccount: " + event.getSourceAccount()
                + " transferID: " + transferId + " event.getAmount: " + event.getAmount());
        commandGateway.send(new WithdrawMoneyCommand(event.getSourceAccount(), transferId, event.getAmount()),
                new CommandCallback<WithdrawMoneyCommand, Object>() {
                    @Override
                    public void onSuccess(CommandMessage<? extends WithdrawMoneyCommand> commandMessage,
                            Object result) {

                    }

                    @Override
                    public void onFailure(CommandMessage<? extends WithdrawMoneyCommand> commandMessage,
                            Throwable cause) {
                        System.out.println("On failure of withdraw money command inside saga ");
                        System.out.println("###################### Cause of failure = " + cause);
                        commandGateway.send(new CancelMoneyTransferCommand(event.getTransferId()));
                    }
                });
    }

    @SagaEventHandler(associationProperty = "transactionId")
    public void on(MoneyWithdrawnEvent event) {
        System.out.println("Inside saga event handler for monney withdrawnevent");
        commandGateway.send(new DepositMoneyCommand(targetAccount, event.getTransactionId(), event.getAmount()),
                LoggingCallback.INSTANCE);
    }

    @SagaEventHandler(associationProperty = "transactionId")
    public void on(MoneyDepositedEvent event) {
        System.out.println("Inside saga event handler for money deposited event");
        commandGateway.send(new CompleteMoneyTransferCommand(transferId), LoggingCallback.INSTANCE);
    }

    @EndSaga
    @SagaEventHandler(associationProperty = "transferId")
    public void on(MoneyTransferCompletedEvent event) {
        System.out.println("Inside Endsaga for money transfer complete event");
    }

    @SagaEventHandler(associationProperty = "transferId")
    public void on(MoneyTransferCancelledEvent event) {
        end();
    }
}

在通过 REST API 执行汇款后，所有这些代码都会被执行，因为我可以看到我的日志打印到控制台并且所有交易都存储在帐户表中。

domain_event_entry 中也存在所有条目，但是无论事务是成功还是失败，saga_entry 和 association_value_entry 表都保持为空。

最初我认为这可能是因为 saga 存储配置错误，所以我配置了 saga 存储，MongoSagaStore但 Saga 的集合仍然是空的。

那么我在这里遗漏了什么，或者轴突只是在传奇完成后从这些表中删除了数据？

4

1 回答 1

3

当 AxonFramework 结束时，它将自动从其存储中删除一个 Saga 条目，包括任何关联。所以你只会在那里看到活动实例的信息。

在示例应用程序中，所有总线组件都使用“Simple...”实现，这基本上意味着所有活动都在同一个线程中执行。因此，一旦您收到OK或NotOK，Saga的所有活动也将结束。如果您要用异步或分布式实现替换它们，则不再是这种情况。在整个过程完成之前，您将返回 OK。

于 2018-08-02T10:23:17.503 回答