JDBC和JMS的Spring事务同步

我有一个在jboss上运行的spring web app,当前配置为使用HibernateTransactionManager进行db事务,JmsTransactionManager用于jms。 对于jms,我们使用Camel和ActiveMQ,我们的数据库是DB2。 在一个事务中,我需要将一些记录写入数据库并发送两个异步jms消息。 jms消息是事件通知,我只希望在数据库事务提交时发送它们。

我愿意接受在jdbc事务已经提交之后与代理通信失败的风险(因此没有发送消息但是db已经提交)所以我认为我不需要正确的XA。

我相信我需要的是使用spring transaction同步的“尽力而为”的事务管理。

Spring文档提示了spring将同步两个事务并仅在jdbc事务提交后提交jms事务这一事实 – 但我不认为它非常清楚。 这里的spring文档http://static.springsource.org/spring/docs/3.0.x/spring-framework-reference/html/transaction.html#tx-resource-synchronization没有详细介绍它是如何工作的。

我发现了一些其他的消息来源说spring会做我想要的,包括下面的一些javadoc,我已经编写了一些集成测试,也显示了它。

http://static.springsource.org/spring/docs/3.0.x/api/org/springframework/jms/support/JmsAccessor.html#setSessionTransacted%28boolean%29这里的setSessionTransacted上的javadoc听起来就像我想要的那样。

从我所看到的,我认为创建Camel JmsConfiguration并将事务处理设置为true就足够了:

     

然而,我需要说服我工作的人有点怀疑并且认为我的集成测试只能起作用,因为副作用很少而不是有意的弹簧特征。

所以我的问题是 – 我是否正确可以依赖Spring来同步事务并始终在jdbc事务之后提交jms事务,或者这不是我应该依赖的东西,你能否指出我所说的任何官方文档那清楚吗? 我想一般来说这是一个很好的方法,或者我们应该以不同的方式管理这些交易吗?

本文可能对Spring中的分布式事务有帮助,无论是否有XA 。 我不认为它具体涵盖了你的情况 – 发送消息+更新数据库。

官方Spring Boot存储库包含JTA示例,这些示例将JMS与基于Atomikos , Bitronix或Java EE服务器JBoss WildFly的 JDBC相结合。

另外,我还创建了一些位于我的Github存储库中的示例。 这也包含非Spring Boot(纯Spring)示例。

如果您正在使用本地事务并且用例保存到数据库然后发送到jms

然后可能有三种情况:

  1. 收到后的exception(在DB和JMS之前)

没问题一切都会回滚

  1. 保存到DB后,我们有例外

如果存在插入操作,则由于重试,DB中将存在多行。每次重试时,都将执行插入。对于JMS,消息将转到DeadLetterQueue

  1. 保存到DB并发送到JMS后,我们有一个例外

    如果存在插入操作,则由于重试,DB中将存在多行。每次重试时,都将执行插入。对于JMS,消息将转到DeadLetterQueue

现在你不想使用XA,所以解决方案可能是

1)检查If(message.getJmsRedelivered(){…}

如果没有,请处理它

如果重新传送,请检查您是否已经处理过

根据消息中的详细信息检查数据是否在数据库中

请注意,重新交付很少,因此,此检查也很少,并且没有开销

2)如果你的方法是幂等的,那么你不需要这个检查

对于XA,XA保证只传递一次消息并在多个资源之间同步事务

但是对于XA,你有开销

因此,如果你可以在没有XA的情况下进行管理,那就更好