JMS与数据库事务

Posted 2020-08-22

发送消息时的事务

THREAD系统中使用spring的JmsTemplate组件来发送消息。这是我们THREAD系统中的配置：

<beanid="newJmsTemplate"class="org.springframework.jms.core.JmsTemplate"> <propertyname="connectionFactory"ref="jmsConnectionFactory"/> <propertyname="sessionTransacted"value="true"/> <propertyname="explicitQosEnabled"value="${activemq.explicitQosEnabled}"/> <propertyname="timeToLive"value="86400000"/> bean>

其中“”这一行就是发送消息时的事务配置。有了这个配置之后，Jms消息发送就与事务绑定上了。

而它在事务中的行为还与transactionManager有关。这是我们THREAD系统中的transactionManager配置：

<beanid="transactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager"> <propertyname="sessionFactory"ref="sessionFactory"/> <propertyname="nestedTransactionAllowed"value="true"/> <propertyname="globalRollbackOnParticipationFailure"value="false"/> bean>

在这个transactionManager配置下，Jms消息会在afterCommit()操作中提交。如下图所示。

根据网上的文章，如果要保证jms操作和数据库操作真正做到“同生共死”，必须使用JTATransactionManager。但是这个东东的性能一直是个问题。

<tx:jta-transaction-manager/>

接收消息时的重发机制

接收消息后的重发机制与数据库事务之间的关系，并没有像发送消息时那样严格的绑定在一起。也就是说，接收消息后是否重试与数据库事务没有必然的关系。

一般来说，做到以下两点，就可以实现重试。

首先，在listener的配置中增加“acknowledge="transacted"”，如下所示。

<jms:listener-containerdestination-type="queue" concurrency="4"acknowledge="transacted"connection-factory="connectionFactory"> <jms:listenerdestination="queue.thread.autopay"ref="autoPayListener"/> jms:listener-container>

第二，当消息处理失败后，抛出异常。

@Override publicvoidonMessage(Message message) { try{ // 省略业务处理代码 } catch(Exception e) { // 省略日志、监控邮件等代码 // 抛出异常，让MQ重发一次消息。 throwe instanceofRuntimeException ? (RuntimeException) e : newRuntimeException(e); } }

默认的消息重发规则配置在org.apache.activemq.RedeliveryPolicy类中。从代码上看，默认会重发6次。如果需要修改默认配置，可以参考THREAD中spring-modules.xml文件中的配置：

<amq:connectionFactoryid="connectionFactory"brokerURL="tcp://${jms.url}:61616"> <amq:redeliveryPolicyMap> <amq:redeliveryPolicyMap> <amq:defaultEntry> <amq:redeliveryPolicymaximumRedeliveries="5"initialRedeliveryDelay="30000"/> amq:defaultEntry> <amq:redeliveryPolicyEntries> <amq:redeliveryPolicyqueue="queue.thread.autopay"maximumRedeliveries="5" initialRedeliveryDelay="10000"/> <amq:redeliveryPolicyqueue="queue.thread.instantUnionpay"maximumRedeliveries="5" initialRedeliveryDelay="90000"/> amq:redeliveryPolicyEntries> amq:redeliveryPolicyMap> amq:redeliveryPolicyMap> amq:connectionFactory>

如果重试次数超过上限，MQ会将消息转到另一个“投递失败队列”（Dead Letter Queue）中。“投递失败队列”的名称一般就是“DLQ.原队列名”。

本文出自 “编程的摩羯男” 博客，请务必保留此出处http://winters1224.blog.51cto.com/3021203/1879786