ActiveMQ的消息重发与死信处理

亦凉 2022-02-22 16:50 420阅读 0赞

## 概述 ##

在发生以下情形时，消息会给重发给客户端：

1.  使用了一个事务性的会话且调用了rollback()方法。
2.  在调用commit()方法前一个事务性的会话被关闭了。
3.  一个会话使用**CLIENT\_ACKNOWLEDGE**的ACK模式，且调用了Session.recover()方法。
4.  一个客户端连接超时（可能正被执行的代码执行的时间超过配置的超时时间）。

客户端可以通过`ActiveMQConnection.getRedeliveryPolicy()` 或 `ActiveMQConnectionFactory.getRedeliveryPolicyMap()`来覆盖策略设置。

方法：

RedeliveryPolicy policy = connection.getRedeliveryPolicy();
    policy.setInitialRedeliveryDelay(500);
    policy.setBackOffMultiplier(2);
    policy.setUseExponentialBackOff(true);
    policy.setMaximumRedeliveries(2);

当一个消息被redelivered超过maximumRedeliveries(缺省为6次，具体设置请参考后面的链接)次数时，会给broker发送一个"Poison ack"，这个消息被认为是a poison pill，这时broker会将这个消息发送到DLQ，以便后续处理。

缺省的死信队列是ActiveMQ.DLQ，所有不能投递的消息都会被发送到这个队列，这将会导致难以管理。你可以在activemq.xml这个配置文件的`destinationPolicy`配置`individualDeadLetterStrategy` ，它可以让给为一个给定的queue或topic指定特定的死信队列前缀。如果你希望所有的queue都拥有自己的死信队列，你可以使用通配符。

示例：

<broker>
       
      <destinationPolicy>
        <policyMap>
          <policyEntries>
            
            <policyEntry queue=">">
              <deadLetterStrategy>
                
                <individualDeadLetterStrategy queuePrefix="DLQ." useQueueForQueueMessages="true"/>
              </deadLetterStrategy>
            </policyEntry>
          </policyEntries>
        </policyMap>
      </destinationPolicy>
       
    </broker>

## 自动丢弃过期消息 ##

如果你只想丢弃过期的消息，不想发送到死信队列，你可以在一个死信队列策略中配置`processExpired=false`。

<broker>
       
      <destinationPolicy>
       <policyMap>
         <policyEntries>
           
           <policyEntry queue=">">
             
             <deadLetterStrategy>
               <sharedDeadLetterStrategy processExpired="false" />
             </deadLetterStrategy>
           </policyEntry>
         </policyEntries>
       </policyMap>
      </destinationPolicy>
       
    </broker>

## 非持久消息保存到死信队列 ##

默认情况下，ActiveMQ不会将不能投递的非持久消息放到死信队列。如果你希望将非持久消息存储到死信队列，你可以在死信队列的策略中设置`processNonPersistent="true"`。

<broker>
       
      <destinationPolicy>
       <policyMap>
         <policyEntries>
           
           <policyEntry queue=">">
             
             <deadLetterStrategy>
               <sharedDeadLetterStrategy processNonPersistent="true" />
             </deadLetterStrategy>
           </policyEntry>
         </policyEntries>
       </policyMap>
      </destinationPolicy>
       
    </broker>

## 设置死信队列中消息的过期时间 ##

默认情况下，ActiveMQ永远不会使发送到DLQ的消息失效。 但是，在ActiveMQ 5.12中，deadLetterStrategy支持到期属性，其值以毫秒为单位。

## DLQ丢弃插件 ##

从ActiveMQ5.9开始，一个Destination的`policyEntry`支持丢弃的deadLetterStrategy。

这个与丢弃插件的功能相同，但这个是基于每个Destination的。丢弃插件支持正则表达式匹配，这在某些情况下很有用。

此插件允许全部或基于Java SE的正则表达式匹配的queue和topic，丢弃发送到DLQ中的消息。这在使用ConstantPendingMessageLimit策略或其他逐出规则，但不想有一个其他的消费者来清理DLQ时很有用。

下面是一个丢弃所有内容的一个基本配置：

下面是一个稍微复杂点的例子：

这个例子中，只针对指定的queue和topic有效。各个destination用空格隔开。  
reportInterval属性用于表示我们输出丢弃的消息的频率 - 使用0来禁用。

下面是一个使用正则表达式的例子：

这里匹配的是以000~999结尾的目的地。

## Broker消息重发插件 ##