当JMS队列中没有加载时，消费者数量不减少

Question

我正在使用spring-jms编写一个JMS使用者来使用来自ActiveMQ Artemis代理的消息。我正在研究3个属性的行为:ConcurrentConsumers、MaxConcurrentConsumers和IDleConsumerLimit。

预期的行为是，当队列中的负载增加时，消费者应该向上伸缩到MaxConcurrentConsumers，而当负载减少时，消费者应该向下伸缩到IDleConsumerLimit。

但是spring-jms和ActiveMQ Artemis不会发生这种情况。当队列中没有消息时，使用者计数不会减少，而是保留所有MaxConcurrentConsumers。

我正在使用spring DMLC容器

    <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destinationName" value="TestingInQueue" />
        <property name="messageListener" ref="messageListener" />
        <property name="concurrentConsumers" value="1"/>
        <property name="maxConcurrentConsumers" value="20"/>
        <property name="idleConsumerLimit" value="5"/>
    </bean>

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

    <bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
        <property name="environment">
            <props>
                <prop key="java.naming.factory.initial">org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory</prop>
                <prop key="java.naming.provider.url">tcp://localhost:61616</prop>
                <prop key="java.naming.security.principal">admin</prop>
                <prop key="java.naming.security.credentials">admin</prop>
            </props>
        </property>
    </bean>

    <bean id="connectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiTemplate" ref="jndiTemplate"/>
        <property name="jndiName" value="ConnectionFactory"/>
    </bean>

    <bean id="destinationQueue" class="org.apache.activemq.artemis.jms.client.ActiveMQQueue">
        <constructor-arg index="0" value="TestingInQueue" />
    </bean>

    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="defaultDestination" ref="destinationQueue" />
    </bean>

    <bean id="messageListener" class="com.practise.SampleListener">
        <property name="jmsTemplate" ref="jmsTemplate" />
        <property name="queue" ref="destinationQueue" />
    </bean>

    <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destinationName" value="TestingInQueue" />
        <property name="messageListener" ref="messageListener" />
        <property name="concurrentConsumers" value="1"/>
        <property name="maxConcurrentConsumers" value="20"/>
        <property name="idleConsumerLimit" value="5"/>
    </bean>
</beans>

Answer 1

注：

• MaxConcurrentConsumers:负载下的最大使用者
• ConcurrentConsumers:如果您空闲了一段时间，您最终会到达这里。（到达这里所需的时间取决于接下来的3个参数）

以下3项是为了避免使用者在MaxConcurrentConsumers和ConcurrentConsumers之间急剧地上下伸缩而没有任何时间延迟。

null

问题：

MaxMessageSperTask的默认值为-1，如果MaxMessageSperTask不大于零，IDleConsumerLimit不生效

解决方案：

null