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>
我在使用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>
相关文章推荐
- springmvc 生成pdf,并下载
- 记录:使用IDEA编辑Spring配置文件profile属性时产生的命名重复问题
- 记录:使用IDEA编辑Spring配置文件profile属性时产生的命名重复问题
- Java初识面向对象
- myeclipse 上安装 Maven3
- Java的重载和重写
- Java中弹出对话框中的几种方式
- java P2P JXTA-JXSE学习(一)
- Blobstore Java API overview
- Java并发编程-06-Synchronize关键字同步机制
- 解决java压缩图片透明背景变黑色的问题
- 解决java压缩图片透明背景变黑色的问题
- java对象的强引用,软引用,弱引用和虚引用
- eclipse常用插件
- 黑马程序元----集合框架
- java 框架基础知识(3)----PropertyEditor-->Spring IoC
- 初学Java之基本类型
- spring实战二之Bean的自动装配(非注解方式)
- 初学Java之基本类型
- 初学Java之AAWT组件库2