ActiveMQ挂起消息

Question

我对ActiveMQ有一个类似的问题：http://activemq.2283324.n4.nabble.com/Messages-stuck-in-pending-td4617979.html已经尝试了这里发布的解决方案。

有些消息似乎卡在队列上，可以在那里坐几天而不被消费。我有足够多的消费者大部分时间都是免费的，所以这不是消费者“饱和”的问题。

重新启动ActiveMQ后，一些待处理的消息会立即被消耗。就在刚才，我遇到了这样的情况，我有25个免费消费者可用于排队（他们在管理面板中可见），其中7个“卡住”消息。其中4个被立即消耗，但其他3个仍然卡住。另一个奇怪的事情是——新消息不断进入队列并立即被消耗，而3个旧消息仍然卡住。

在消费者方面，我在Spring的配置如下所示：

<jms:listener-container concurrency="${activemq.concurrent.consumers}" prefetch="1">
    <jms:listener destination="queue.request" response-destination="queue.response" ref="requestConsumer" method="onRequest"/>
</jms:listener-container>

<bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
        <property name="queuePrefetch" value="1" />
</bean>

<bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
    <property name="brokerURL" value="${activemq.broker.url}?initialReconnectDelay=100&amp;maxReconnectDelay=10000&amp;startupMaxReconnectAttempts=3"/>
    <property name="prefetchPolicy" ref="prefetchPolicy"/>
</bean>

Answer 1

“卡住”的消息可能被认为是“正在传递”，重新启动代理将关闭连接，并且由于消息尚未被确认，代理将认为它们未传递并将再次传递。

可能有几个问题会导致这种情况，最常见的问题是事务/确认配置中的问题、消费者端错误/确认管理不好（消息已被消费但从未确认）或消费者陷入无休止的操作中（例如，阻止对第三方资源的调用，该资源没有响应，也没有超时处理）。