是否可以在JTA（Atomikos）中设置并行事务

Question

我有两个事务资源：数据库和消息队列。所以我使用 Atomikos 作为 XA 事务管理器。

在交易（tx1）内，是否可以并行打开另一个单独的交易（tx2）？

在tx2中，它会将一些数据提交到db中，即使tx1最终也可能失败并回滚。

并且 tx2 必须在 tx1 内部完成，就好像 tx2 中发生错误一样，也应该回滚 tx1。

有人知道我怎样才能实现这一目标吗？

谢谢。

Answer 1

是的，您可以实现这一目标。你谈论所谓的“嵌套”交易
首先，对于 Atomikis，您必须指定属性 com.atomikos.icatch.serial_jta_transactions=false

如果您直接使用 TransactionManager 进行操作，则必须在开始 tx2 之前暂停 tx1 (TransactionManager.suspend())。提交事务 tx2 后，您必须恢复 tx1。如果执行 tx2 时出现错误，您必须回滚 tx2、恢复 tx1 并回滚 tx1：

示例

TransactionManager tm=...

tm.begin();
Transaction tx1 = tm.getTransaction();
//do somethins in tx1;
tm.suspend(tx1);
tm.begin();
Transaction tx2 = tm.getTransaction();

try{
  //do something in tx2
  tm.commit() ;// try to commit tx2
}cath(Throwable e){
   tx2.rollback();
   tm.resume(tx1)
   tx1.rollback();
   tx1 = null;
}

if(tx1!=null){
  tm.resume(tx1);
  tm.commit();
}