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
?
更重要的是,是否有一些习惯用法/默认方式来执行事务重放?
最佳答案
正确的模式是:
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 中没有重试事务的功能
关于java - 如何在 Infinispan 中使用 JTA 事务?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10624975/