我正在使用同时使用JMS和Hibernate的独立应用程序。
该文档建议,如果我想同时使用这两种资源进行事务处理,则必须使用JTA。
但是,现在使用带有@Transaction注释的DAO方法(和HibernateTransactionManager),这似乎已经可以工作。当我在JmsTemplate上调用send()时,消息不会立即发送,而是随着方法的返回,使用Hibernate会话提交了JMS会话。
我不知道没有JtaTransactionManager怎么可能,所以我检查了源代码。事实证明,Hibernate的包装器和JmsTemplate都向TransactionSynchronizationManager注册了会话,并且在Hibernate会话提交时将提交JMS会话。
此交易与JTA交易有何不同?我可以用它代替后者吗?
简而言之,没有JTATransactionManager和XA感知数据源,您将无法获得对两阶段提交的支持。
您看到的是两个仅支持1阶段提交的 本地事务 的协调。大致执行此一系列事件…
首先将包装嵌套的JDBC事务开始JMS事务,以便在Hibernate / JDBC提交失败时JMS队列将回滚。您的JMS侦听器容器应设置为 不发送
acknowledge="auto"
,而是等待Hibernate事务完成后再发送确认。
如果只有这两个资源,那么您将要考虑的问题是Hibernate成功进行驻留时,您将获得一个Exception,然后才能确认JMS服务器。这不是一个大问题,因为JMS消息不会丢失,您将再次阅读它。
然而
您必须编写MessageListener来处理来自服务器的重复消息
您还必须处理由于数据错误而无法处理的消息,并最终导致尝试使用该消息的无限循环。在这种情况下,服务器可以配置为将消息移至“死消息队列”,或者您可以在MessageListener中自己处理
其他选项和进一步阅读
如果您的JMS服务器不支持XA(全局)事务,则这几乎是您唯一的解决方案。
如果JMS服务器确实支持XA事务,但是JDBC不支持,则可以使用JTATransactionManager并使用LastResourceCommitOptimisation。您可以使用像JOTM这样的开源JTATransactionManager
这篇JavaWorld文章详细介绍了您的问题空间。
我正在通过/
我们需要将JMS队列中的消息持久化到事务中的数据库中,以确保在DB持久化期间抛出任何错误时不会确认JMS消息。基于此处提供的解决方案——使用消息驱动通道适配器时的事务处理 请确认理解是否正确。此外,还有以下问题 在这种情况下是否需要TransactionAware ConnectionFactoryProxy JMS Queue和JDBC是两个独立的事务资源。如本例所示,将jdbc事务管理器注入J
我想要将kafka事务与存储库事务同步: 如果我能获得一个简单的kafka事务与存储库事务同步的示例和一个解释,我会真正帮助我。
我们都知道,在spring-Hibernate应用程序中不使用@transactional注释会产生一个Hibernate异常: 线程“main”org.hibernate.hibernateException异常:无法获取当前线程的事务同步会话 我想知道“事务同步会话”是什么意思?
我制作了一个POC,其中包含Spring-boot-starter-data-jpa和Spring-boot-starter-active emq。当提交jpa事务时,我想在代理(activeMQ)上推送jms消息。 我的代码: UtilsateurService具有"主"事务: “管理”Jms消息的SendMessage类: 我的主要班级: 在抛出异常之前,JMS消息被推送到activeMq代理
我正在使用JMS模板和Spring Boot同步发送/接收JMS队列调用。我查看了JMS模板的正式spring文档,但没有任何帮助。 我不太确定具体调用receive()方法,否则一旦调用send(),它就会自动接收消息。因为这是同步调用,所以我只需要接收我发送的消息(带有相关Id)。 下面是我的spring boot代码。 JMSSConfig.java 发送方和接收方代码