activemq慢速消费者阻止生产者，尽管producerFlowControl为false

Question

出于测试原因，我指定了low memoryusage limit low(35MB)以使问题apear更快，但实际情况是，当activemq的问题出现时，我最终需要它来删除旧消息。

我发现了一个不令人满意的解决方案，即在ActiveMQConnectionFactory中设置useasyncsEnd=true，并指定sendtimeout。这使得producer不会被阻塞，但通过这种方式，最新的消息被删除，而不是旧的消息。

最后，我说的是非持久的话题。

        <destinationPolicy>
        <policyMap>
            <policyEntries>
                <policyEntry topic=">" producerFlowControl="false" memoryLimit="35 Mb">
               <pendingSubscriberPolicy>
                   <vmCursor />
                </pendingSubscriberPolicy>
                    <messageEvictionStrategy>
                        <oldestMessageEvictionStrategy/>
                    </messageEvictionStrategy>
                    <pendingMessageLimitStrategy>
                        <constantPendingMessageLimitStrategy limit="10"/>
                    </pendingMessageLimitStrategy>
                </policyEntry>
            </policyEntries>
        </policyMap>
    </destinationPolicy>

    <systemUsage>
        <systemUsage sendFailIfNoSpace="true">
            <memoryUsage>
                <memoryUsage limit="35 mb"/>
            </memoryUsage>
            <storeUsage>
                <storeUsage limit="1 gb"/>
            </storeUsage>
            <tempUsage>
                <tempUsage limit="5000 mb"/>
            </tempUsage>
        </systemUsage>
    </systemUsage>  

    <bean class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="pooledJmsConnectionFactory"/>
    <property name="timeToLive" value="100"/>
</bean>

我传输javax.jms.ObjectMessage，大小相对较小。

我在customer Premissions中发现了这个问题我的应用程序中有许多toppics，但设法在本地复制了它，从1个线程发送不间断的消息，总是连续地发送到同一个主题。发送的消息只是一个小字符串。

我只有一个生产者，当我有一个（或更多）缓慢的消费者时，问题似乎就出现了--但一个缓慢的消费者就足够了--。如果不存在慢消费，问题就不会出现。

       <transportConnectors>
       <transportConnector name="openwire" uri="nio://0.0.0.0:33029?wireFormat.maxInactivityDuration=60000&amp;wireFormat.maxInactivityDurationInitalDelay=60000"/>
    </transportConnectors>

Answer 1

我怎样才能重新创建这个？有多少生产者/消费者依附于这个主题？只有一个话题吗？

您的设置看起来不错，但不需要在策略中设置MemoryLimit=35MB。将其设置为与整个系统使用相同是没有意义的。其思想是，所有主题的内存限制总和将等于系统内存限制。例如，如果您有两个主题，每个主题将使用35MB(2*35==70MB)，这将超过整个系统内存设置。我不认为这是你所看到的具体原因，而是要记住的事情。

另外，这是什么版本的ActiveMQ？如果您已经编写了一些测试，可以产生这个，让我知道。