您的位置:首页 > 编程语言 > Java开发

activemq与spring集成配置

2015-06-14 20:33 633 查看
对于spring与activemq集成的配置,资料已经很多,不再赘述。我只阐述本人在学习中遇到的问题。
我在使用spring与activemq集成是遇到一个问题.
问题:在使用发布/订阅模式时,消息持久化到数据库。当客户端挂掉后,然后重启客户端,然而重启后的客户端并未消费未消费的消息。
解决:在配置SimpleMessageListenerContainer的参数时,设置durableSubscriptionName属性,且值与clientId的值一致。
这时这个客户端会消费所有之前未消费的持久化消息。
大概配置如下:

<?xml version="1.0" encoding="UTF-8"?> 

<beans xmlns="http://www.springframework.org/schema/beans

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance

xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> 

<!-- 配置客户端消息工厂 --> 

<bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory"> 

<property name="connectionFactory"> 

<bean class="org.apache.activemq.ActiveMQConnectionFactory"> 

<property name="brokerURL" value="${MQ.broker.url}" /> 

<property name="userName" value="${MQ.broker.username}" /> 

<property name="password" value="${MQ.broker.password}" /> 

 <!-- 是否异步发送 -->
    <property name="useAsyncSend" value="true" />

</bean> 

</property> 

<property name="maxConnections" value="10" /> 

</bean> 

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> 

<property name="connectionFactory" ref="jmsFactory" /> 

</bean> 

<bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate"> 

<property name="connectionFactory" ref="jmsFactory" /> 
<!--发布订阅模式-->

<property name="pubSubDomain" value="true" /> 
<!--设置持久化:1,非持久化;2,持久化-->

<property name="deliveryMode" value="2" />
 <!-- deliveryMode, priority, timeToLive 的开关,要生效,必须配置为true,默认false -->

<property name="explicitQosEnabled" value="true" /> 

</bean> 

<!-- 邮件目的地配置 --> 

<bean id="emailDest" class="org.apache.activemq.command.ActiveMQQueue"> 

<constructor-arg index="0" value="${MQ.queue.email}" /> 

</bean> 

<!-- notice目的地配置 --> 

<bean id="noticeDest" class="org.apache.activemq.command.ActiveMQTopic"> 

<constructor-arg index="0" value="${MQ.topic.notice}" /> 

</bean> 

<!-- 邮件消息监听 --> 

<bean class="org.springframework.jms.listener.SimpleMessageListenerContainer"> 

<property name="connectionFactory" ref="jmsFactory" /> 

<property name="destination" ref="emailDest" /> 

<property name="messageListener" ref="mqEmailListener"> 

</property> 

</bean> 

<!-- notice消息监听 --> 
<!-- 必须配置durableSubscriptionName属性且值必须与clientId一致,否则客户端挂了以后 不会去获取未消费的数据(发布/订阅模式).
    新添加的客户端会消费以前持久化的消息
--> 
<bean class="org.springframework.jms.listener.SimpleMessageListenerContainer"> 

<property name="connectionFactory" ref="jmsFactory" /> 

<property name="destination" ref="noticeDest" /> 

<property name="messageListener" ref="mqNoticeOneListener" /> 
<property name="clientId" value="clientId_001" /> 

<property name="pubSubDomain" value="true" /> 

<property name="subscriptionDurable" value="true" /> 
<property name="durableSubscriptionName" value="clientId_001" /> 

</bean> 

<bean class="org.springframework.jms.listener.SimpleMessageListenerContainer"> 

<property name="connectionFactory" ref="jmsFactory" /> 

<property name="destination" ref="noticeDest" /> 

<property name="subscriptionDurable" value="true" /> 

<property name="messageListener" ref="mqNoticeTwoListener" /> 

<property name="clientId" value="clientId_002" /> 

<property name="pubSubDomain" value="true" /> 

<property name="durableSubscriptionName" value="clientId_002" /> 

</bean> 

</beans>
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: