我在使用ActiveMQ和Spring的CachingConnectionFactory
时遇到了问题。我是这样设置它们的:
<!-- A connection to ActiveMQ -->
<bean id="myConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="${jms.url}"/>
<property name="userName" value="${jms.username}"/>
<property name="password" value="${jms.password}"/>
</bean>
<!-- A cached connection to wrap the ActiveMQ connection -->
<bean id="myCachedConnectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory">
<property name="targetConnectionFactory" ref="myConnectionFactory"/>
<property name="sessionCacheSize" value="10"/>
<property name="reconnectOnException" value="true"/>
</bean>
<!-- A destination in ActiveMQ -->
<bean id="myDestination"
class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg value="${jms.queue}" />
</bean>
<!-- A JmsTemplate instance that uses the cached connection and destination -->
<bean id="myProducerTemplate"
class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="myCachedConnectionFactory"/>
<property name="defaultDestination" ref="myDestination"/>
</bean>
jms.url
正在使用故障转移传输:
failover:(tcp://firstbox:6166,tcp://secondbox:6166)?timeout=3000
我遇到的问题是,如果一个盒子出现问题,我们应该开始在另一个盒子上发送消息,但它似乎仍在使用旧连接(每次发送都超时)。如果我重新启动程序,它就会重新连接,一切正常。
我的理解是,
ActiveMQConnectionFactory
应该自己解决问题(重新连接到新盒子),而 JmsTemplate
应该每次请求一个新连接,所以这应该没问题。我想知道是否 CachingConnectionFactory
可能会做一些不好的事情(缓存与旧服务器通信的生产者?)。我是否漏掉了需要做的事情?我的设置似乎相当正常,但我找不到其他人遇到这个问题。