我们有一个 ActiveMQ/Camel 配置,之前一直使用专门的消息队列和并发消费者。
但是,我们现在引入消息主题,并发现 - 由于并发消费者 - 主题中收到的消息会被多次使用。
此场景的正确配置是什么?
即,我们希望队列上收到的消息有多个并发消费者,但只需要为某个主题上收到的消息定义一个消费者。
这是当前配置:
<amq:connectionFactory id="amqConnectionFactory"
useAsyncSend="true" brokerURL="${${ptl.Servername}.jms.cluster.uri}"
userName="${jms.username}" password="${jms.password}" sendTimeout="1000"
optimizeAcknowledge="true" disableTimeStampsByDefault="true">
</amq:connectionFactory>
<bean id="cachingConnectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory">
<property name="targetConnectionFactory" ref="amqConnectionFactory"></property>
<property name="cacheConsumers" value="true"></property>
<property name="cacheProducers" value="true"></property>
<property name="reconnectOnException" value="true"></property>
<property name="sessionCacheSize" value="${jms.sessioncachesize}"></property>
</bean>
<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
<property name="connectionFactory" ref="cachingConnectionFactory" />
<property name="transacted" value="false" />
<property name="concurrentConsumers" value="${jms.concurrentConsumer}" />
<property name="maxConcurrentConsumers" value="${jms.max.concurrentConsumer}" />
<property name="preserveMessageQos" value="true" />
<property name="timeToLive" value="${jms.timeToLive}" />
</bean>
<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="configuration" ref="jmsConfig" />
</bean>
最佳答案
您可以将任何主题消费者的并发消费者/最大并发消费者显式设置为“1”。
from("activemq:topic:myTopic?concurrentConsumers=1&maxConcurrentConsumers=1")...
或者,将 JmsConfiguration并发/maxConcurrentConsumers属性设置为“1”,然后根据需要显式启用队列的并发消费。
from("activemq:queue:myQueue?maxConcurrentConsumers=5")...
此外,您还可以使用Virtual Topics执行主题消息的并发消费而不会重复(强烈推荐传统主题)
关于java - ActiveMQ:队列(具有并发消费者)和主题的正确配置,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9881629/