Spring JMS 监听器中的事务管理

Posted 2023-02-16

【中文标题】Spring JMS 监听器中的事务管理

【英文标题】：Transaction Management in Spring JMS listener

【发布时间】：2015-02-28 10:13:46

【问题描述】：

我有一个 spring JMS 侦听器正在侦听 queue 。一旦消息到达输入队列，它会对消息进行一定的处理，并将消息放到多个其他队列中进行进一步处理（我们可以将这些其他队列称为输出队列）。当它发布到其他输出队列时，如果将消息发布到输出队列之一可能由于任何原因而失败，我想确保在失败之前完成的输出队列的其他帖子得到回滚。基本上我想确保它是原子操作。 侦听器/容器上是否有任何注释/配置可用于在单个事务中实现此目的。？

这是我正在使用的配置

<jms:listener-container acknowledge="transacted" cache="session" connection-factory="jmsSecurityFactory" concurrency="1" container-type="default" container-class="abc.xyz">
<jms:listener id="listenerId" destination="inputQueue" ref="" />
</jms:listener-container>
<beans:bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<beans:property name="sessionTransacted" value="true"></beans:property>
<beans:property name="connectionFactory" ref="inCachingConnectionFactory"></beans:property>
</beans:bean>
<beans:bean id="inCachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <beans:property name="targetConnectionFactory" ref="jmsSecurityFactory" />
</beans:bean>
<beans:bean id="jmsSecurityFactory"
    class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
    <beans:property name="targetConnectionFactory" ref="jmsConnectionFactory" />
    <beans:property name="username" value=" " />
    <beans:property name="password" value=" " />
</beans:bean>
<beans:bean id="jmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
    <beans:property name="hostName" value="$mq.conn.hostName" />
    <beans:property name="port" value="$mq.conn.hostPort" />
    <beans:property name="queueManager" value="$mq.conn.queueManager" />
    <beans:property name="channel" value="$mq.conn.channel" />
    <beans:property name="transportType" value="$mq.conn.transportType" />
    <beans:property name="useConnectionPooling" value="true"></beans:property>
</beans:bean>

看起来 JMS 模板和侦听器容器都引用同一个连接工厂 bean (jmsConnectionFactory)

【参考方案1】：

在监听容器上设置acknowledge="transacted"；同一线程上的任何下游操作，使用JmsTemplate（配置相同的连接工厂）将使用容器的Session，任何失败都会导致所有JMS操作回滚。会话将由容器在成功时提交。

【讨论】：

谢谢加里。我已经发布了配置。看起来确认属性已按预期设置，并且 JMS 模板和容器都使用相同的连接工厂。你觉得那里有什么问题吗？

"Ulitmately" 没有删减它；它必须是对相同连接工厂的引用，模板才能使用容器的会话。

谢谢加里。删除 CachingConnectionFactory 并将 JMSTemplate 和侦听器指向相同的 conn 工厂（上述配置中的 jmsSecurityFactory ）有效。

您可能需要考虑保留CCF，以便可以缓存JmsTemplate 生产者（为了提高效率）。但是，您必须将 cacheConsumers 设置为 false，尤其是在容器上使用变量并发时。您不想在 CCF 中缓存消费者，但缓存生产者有很大的好处。