java - 消息卡在 activemq 队列中

Question

Activemq版本:5.14.3
Java版本1.7

1个队列有8个消费者，消息卡在部分消费者中。

在上图中，消息被困在前 4 个消费者的调度队列中。
这是我的 spring 配置文件。

       <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="failover:(tcp://localhost:61616,tcp://localhost:61617)?randomize=false"/>
    </bean>

    <bean id="cachingFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
        <property name="targetConnectionFactory" ref="connectionFactory"/>
    </bean>

    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory"/>
        <property name="defaultDestinationName" value="queue/WebHookProcessingQueue"/>
    </bean>

    <bean id="myMessageSender" class="com.omoto.jms.sender.MyMessageSender">
        <property name="jmsTemplate">
            <ref bean="jmsTemplate"/>
        </property>
    </bean>

  <bean id="responseJsonMessageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="cachingFactory"/>
        <property name="destinationName" value="/queue/ResponseJsonProcessingQueue"/>
        <property name="concurrentConsumers" value="8"/>
        <property name="messageListener" ref="responseJsonServiceListner"/>
    </bean>

我是activemq的新手，请帮我解决这个问题。

Answer 1

我们在使用 DefaultMessageListenerContainer 时遇到了与 CachingConnectionFactory 类似的问题，从 DefaultMessageListenerContainer 中删除 CachingConnectionFactory 后问题得到解决。或者，您可以从 CachingConnectionFactory 禁用使用者缓存。请参阅此线程以获取更多信息 Why DefaultMessageListenerContainer should not use CachingConnectionFactory? .