在没有慢速消费者的情况下，什么会导致大量挂起的消息？

Question

我将ActiveMQ与Apache Camel一起使用。现在我遇到了这个问题，在ActiveMQ中有大量挂起的消息。消息处于挂起状态，出列过程非常缓慢。

我的理解正确吗？通常情况下，为了有那么多待处理的消息，每个消费者的调度队列的大小应该已经接近默认的预取限制（即1000）？但每个消费者只有20-80美元？

我对ActiveMq了解不多。那么我应该从哪里了解如何解决这个问题呢？

连接配置01是活动的，02处于待机模式

failover:(tcp://mq01:61616,tcp://mq02:61616)

连接工厂第一个用于大多数队列，第二个用于具有大量负载的任务。

<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
    <property name="connectionFactory" ref="my-connectionFactory" />
    <property name="idleTimeout" value="0"/>
    <property name="maxConnections" value="5" />
</bean>

<bean id="consumerPooledConnectionFactory"
      class="org.apache.activemq.pool.PooledConnectionFactory" init-method="start" destroy-method="stop">
    <property name="maxConnections" value="2" />
    <property name="connectionFactory" ref="my-connectionFactory" />
</bean>

Answer 1

我想更新一下，我发现，在我的例子中，问题是因为我有ActiveMQ的连接池，它在ActiveMQ生产者和消费者之间共享，这在某种程度上造成了对池中可用连接的竞争。

因此，我们学到的教训是，始终分离生产者和消费者之间的连接池。