Infinispan文档说了很多关于其锁定方案的内容,乐观和悲观,但没有详细说明如何使用事务。可能它被认为是知道的,因为它使用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);
}
这段代码正确吗?执行一个据说很常见的操作似乎过于复杂,因此我怀疑我做错了什么......如果失败CacheException
会抛出一些吗?cache.put()
如果是这样,我应该明确打电话tm.rollback()
吗?如果我tm.commit()
在finally
子句中调用怎么办?它什么时候会抛出一个RollbackException
?
更重要的是,是否有一些惯用语/默认方式来执行事务重播?