带有JTA事务的Axon ReplayingCluster

Question

对于我的Java (7)项目，我想使用Axon框架。Axon ReplayingCluster的一个参数是TransactionManager，但是Axon只支持NoTransactionManager和SpringTransactionManager。

但是，如果我没有弄错JTA，事务已经由EntityManager中的应用服务器管理(我已经将其存储在JpaEventStore中)。

我的问题是:当我将ReplayingCluster与NoTransactionManager结合使用时，这是否意味着JTA仍将提供事务功能？

Answer 1

事件重播可能涉及数千(如果不是数百万)事件。因此，在单个事务中管理单个重放通常是不可行的(假设您的事件侦听器进行了需要事务的更改)。

每次重播一批事件时，轴突都会使用TransactionManager来提交更改。此批处理的大小可以使用commitThreshold参数进行配置。

现在，我没有使用JTA的经验，但我的理解是，当bean方法被调用并在该方法返回时提交时，事务将自动创建。这意味着当您触发一个重播时，它将在一个事务中这样做。

因此，我的建议是向ReplayingCluster提供您自己的实现。在EJB服务器上，这个实现可能如下所示：

class JtaTransactionManager implements TransactionManager<UserTransaction> {

    @Resource
    private SessionContext ctx;

    @Override
    public UserTransaction startTransaction() {
        UserTransaction utx = ctx.getUserTransaction();
        utx.begin();
        return utx;
    }

    @Override
    public void commitTransaction(UserTransaction utx) {
        utx.commit();
    }

    @Override
    public void rollbackTransaction(UserTransaction utx) {
        utx.rollback();
    }

}

然后，您可以注释启动@TransactionManagement(BEAN)重放的bean，以通知应用程序您将自己管理这些事务(这不会影响其他地方的事务管理)。