一尘不染

Spring同步Hibernate和JMS事务

hibernate

我正在使用同时使用JMS和Hibernate的独立应用程序。

该文档建议,如果我想同时使用这两种资源进行事务处理,则必须使用JTA。

但是,现在使用带有@Transaction注释的DAO方法(和HibernateTransactionManager),这似乎已经可以工作。当我在JmsTemplate上调用send()时,消息不会立即发送,而是随着方法的返回,使用Hibernate会话提交了JMS会话。

我不知道没有JtaTransactionManager怎么可能,所以我检查了源代码。事实证明,Hibernate的包装器和JmsTemplate都向TransactionSynchronizationManager注册了会话,并且在Hibernate会话提交时将提交JMS会话。

此交易与JTA交易有何不同?我可以用它代替后者吗?


阅读 236

收藏
2020-06-20

共1个答案

一尘不染

简而言之,没有JTATransactionManager和XA感知数据源,您将无法获得对两阶段提交的支持。

您看到的是两个仅支持1阶段提交的 本地事务 的协调。大致执行此一系列事件…

  1. 开始JMS交易
  2. 阅读JMS消息
  3. 启动JDBC事务
  4. 写入数据库
  5. 提交JDBC事务
  6. 提交/确认JMS

首先将包装嵌套的JDBC事务开始JMS事务,以便在Hibernate / JDBC提交失败时JMS队列将回滚。您的JMS侦听器容器应设置为 不发送
acknowledge="auto",而是等待Hibernate事务完成后再发送确认。

如果只有这两个资源,那么您将要考虑的问题是Hibernate成功进行驻留时,您将获得一个Exception,然后才能确认JMS服务器。这不是一个大问题,因为JMS消息不会丢失,您将再次阅读它。

然而

  1. 您必须编写MessageListener来处理来自服务器的重复消息

  2. 您还必须处理由于数据错误而无法处理的消息,并最终导致尝试使用该消息的无限循环。在这种情况下,服务器可以配置为将消息移至“死消息队列”,或者您可以在MessageListener中自己处理

其他选项和进一步阅读

如果您的JMS服务器不支持XA(全局)事务,则这几乎是您唯一的解决方案。

如果JMS服务器确实支持XA事务,但是JDBC不支持,则可以使用JTATransactionManager并使用LastResourceCommitOptimisation。您可以使用像JOTM这样的开源JTATransactionManager

这篇JavaWorld文章详细介绍了您的问题空间。

2020-06-20