java - Spring - 在 JPA 事务之后提交 JMS 事务

Question

我有两个事务管理器:JpaTransactionManager (myJpaTm) 和 JmsTransactionManager (myJmsTm)。

考虑以下代码:

@Named
public class TestA {
   @Inject TestB testB;

   @Transactional(transactionManager="myJpaTm") 
   public void methoda() {
     // store stuff in db
     testB.methodb();
   }
}

@Named
public class TestB {

   @Transactional(transactionManager="myJmsTm")  
   public void methodb() {
     // send few JMS messages
   }
}

我们有外部 JPA 事务和内部 JMS 事务，两者是分开的，因为我们没有使用分布式事务。

我想在提交 JPA 事务后立即提交 JMS 事务。在这种情况下，当前的 JMS 事务需要连接到父 JPA 事务。

我不是在寻找分布式事务的替代，我只是想在将数据提交到数据库后发送 JMS 消息。

我知道我可以创建另一个可以调用 method 的类，然后调用 methodb，但我想通过将两个事务连接在一起来解决它。

Answer 1

我还发现了另一种选择 - 我们可以使用 spring-data-commons 中的 ChainedTransactionManager 来按正确的顺序链接两个事务管理器。

@Configuration
public class ChainedTransactionConfiguration {
   @Bean
    public ChainedTransactionManager chainedTransactionManager(
        @Named("myJpaTm") JpaTransactionManager myJpaTm,
        @Named("myJmsTm") JmsTransactionManager myJmsTm) {
    return new ChainedTransactionManager(myJmsTm, myJpaTm);
    }
}

现在我只需设置新的 TM:

@Named
public class TestA {
   @Inject TestB testB;

   @Transactional(transactionManager="chainedTransactionManager") 
   public void methoda() {
     // store stuff in db
     testB.methodb();
   }
}

@Named
public class TestB {

   @Transactional(transactionManager="myJmsTm")  
   public void methodb() {
     // send few JMS messages
   }
}