使用 Artemis、JBoss EAP 7.1 和 last-value-queue答案

【问题标题】：Using Artemis, JBoss EAP 7.1, and last-value-queue使用 Artemis、JBoss EAP 7.1 和 last-value-queue
【发布时间】：2020-03-02 11:50:52
【问题描述】：

我们在 JBoss EAP 7.1 和 Spring 4.3.10 上使用 JMS 队列。

我们想设置一个特定的队列为“last-value-queue”，详见here。

如果我们注释掉消费者配置，即队列没有附加消费者，它作为最后值队列工作，因此具有相同 _AMQ_LVQ_NAME 值的传入消息将替换预先存在的消息并且消息不会积累。

如果我们保留消费者配置并使用Thread.sleep() 模拟长时间运行的进程，以便不立即消费第一个以外的消息，则具有相同_AMQ_LVQ_NAME 值的消息不会被丢弃，而是会累积到队列中。

你有什么线索吗？

我们在standalone.xml中的JBoss配置：

<?xml version="1.0" encoding="UTF-8"?>
<subsystem xmlns="urn:jboss:domain:messaging-activemq:2.0">
   <server name="default">
    ...
      <security-setting name="#">
         <role name="guest" send="true" consume="true" create-non-durable-queue="true" delete-non-durable-queue="true" />
      </security-setting>
      ...
      <address-setting name="jms.queue.NgedeRequestQueue" last-value-queue="true" address-full-policy="BLOCK" />
      <address-setting name="#" dead-letter-address="jms.queue.DLQ" expiry-address="jms.queue.ExpiryQueue" max-size-bytes="10485760" page-size-bytes="2097152" message-counter-history-day-limit="10" redistribution-delay="1000" />
      <jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue" />
      <jms-queue name="DLQ" entries="java:/jms/queue/DLQ" />
      <jms-queue name="NgedeRequestQueue" entries="java:/jms/queue/NgedeRequestQueue" durable="true" />
      ...
      <connection-factory name="InVmConnectionFactory" entries="java:/ConnectionFactory" connectors="in-vm" />
      <connection-factory name="RemoteConnectionFactory" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector" ha="true" block-on-acknowledge="true" reconnect-attempts="-1" />
      <connection-factory name="NgedeConnectionFactory" entries="java:jboss/exported/jms/NgedeConnectionFactory" connectors="http-connector" />
      <pooled-connection-factory name="activemq-ra" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm" transaction="xa" />
   </server>
</subsystem>

我们的 Spring 消费者配置：

<!-- Listener Definition -->
<bean id="messageListenerRequest" class="it.eng.ngede.jms.consumer.NationalApplicationRequestConsumer"/>

<bean id="NgedeRequestQueue" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="java:/jms/queue/NgedeRequestQueue" />
    <property name="jndiTemplate" ref="jnditemplate" />
</bean>

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

<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>
        </props>
    </property>
</bean>

<!-- JmsContainer Definition -->
<bean id="jmsContainerRequest" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="destination" ref="NgedeRequestQueue" />
    <property name="messageListener" ref="messageListenerRequest" />
    <property name="concurrentConsumers" value="1" />
</bean>

【问题讨论】：

标签： java spring activemq-artemis jboss-eap-7

【解决方案1】：

您看到了预期的行为。如果连接了消费者，则默认情况下，由于消息缓冲，发送到代理的消息将立即分派给消费者。发送给消费者的消息被认为是“传递中”（即它们已发送给客户端但尚未得到确认）。 “正在传递”的消息不能被“最后一个值”替换，因为此时它们基本上不受代理的控制。

如果您想要不同的行为，那么我建议您在连接 URL 上设置consumerWindowSize=0，这样消费者就不会缓冲消息。当然，这可能会降低消息吞吐量，但这对您的用例来说甚至可能无关紧要。

【讨论】：