如何在 Infinispan 中使用 JTA 事务？答案

【问题标题】：How to use JTA transactions with Infinispan?如何在 Infinispan 中使用 JTA 事务？
【发布时间】：2012-05-24 09:29:40
【问题描述】：

Infinispan documentation 说了很多关于其锁定方案的内容，乐观和悲观，但没有详细说明如何使用事务。大概是假设知道，因为它使用Java的默认API，但如果是这样，我也没有找到关于JTA使用模式的信息。

我假设，当使用乐观事务时，它将被提交或回滚，这取决于对数据的并发访问，如果它被回滚，我将能够重播事务，希望现在它将在其他并发访问之前完成并且会成功。我在 TransactionManager 上有 begin()、commit() 和 rollback() 方法，以及记录不充分的异常，我不确定它们何时会被抛出。有了这些信息，我编写了以下代码：

public void transactionSum(Key key, Long delta) {
    boolean redo;
    do{
        redo = false;
        try {
            tm.begin();
            try {
                Long value = cache.get(key);
                // Some processing:
                value += delta;
                cache.put(key, value);
                tm.commit();
            } catch(CacheException e) {
                tm.rollback();
                throw new RollbackException();
            }
        } catch (RollbackException e) {
            redo = true;
            logger.debug("Cache transaction collision, replaying it.");
        } catch (Exception e) {
            logger.error(e.getMessage());
        }
    } while(redo);
}

这段代码正确吗？执行一个应该很常见的操作似乎过于复杂，因此我怀疑我做错了什么......如果cache.put() 失败，会抛出一些CacheException 吗？如果是这样，我应该明确调用tm.rollback()吗？如果我在finally 子句中调用tm.commit() 会怎样？什么时候会抛出RollbackException？

更重要的是，是否有一些惯用语/默认方式来执行事务重放？

【问题讨论】：

标签： java concurrency transactions jta infinispan

【解决方案1】：

正确的模式是：

Transaction tx = tm.begin();
try
{
// DO SOMETHING
}
catch (Exception e)
{
   tx.setRollbackOnly(); // Force a rollback for this error
   throw e;
}
finally
{
   if (tx.getStatus() == Status.STATUS_ACTIVE)
      tx.commit();
   else
      tx.rollback();
}

如果没有函数式语言，使用它的最简单方法是通过可调用对象或类似模式，即https://github.com/galderz/infinispan/blob/master/core/src/test/java/org/infinispan/test/TestingUtil.java#L1307

更新：在 Infinispan 中没有重试事务的功能

【讨论】：

顺便说一句，状态真的是：javax.transaction.Status