ActiveMQ处理积压的消息

小咪咪 2022-02-02 11:21 390阅读 0赞

如果消费者变为慢速消费者，那么后面可能会导致消息积压，导致生产者速度也变慢，甚至停止。我们可以配置消息的过期时间，并设置消息过期丢弃策略，以及使用死信队列来处理消息的积压。

## 为持久化消息设置过期时间 ##

ActiveMQ提供了一个timeStampingBrokerPlugin插件，通过此插件，我们可以为持久化消息设置过期时间。参考：[http://activemq.apache.org/timestampplugin.html][http_activemq.apache.org_timestampplugin.html]

zeroExpirationOverride会为没有设置过期时间的消息设置过期时间。ttlCeiling表示过期时间上限，如果程序中设置的过期时间超过此值，以此值为准。

## 配置消息过期丢弃策略 ##

<borker>
    	   <destinationPolicy>
    	       <policyMap>
    	           <policyEntries>
    					
    					
    	               <policyEntry topic=">" expireMessagesPeriod="60000">
    	                   <deadLetterStrategy>
    						   
    							<sharedDeadLetterStrategy processExpired="false" />
      	                 </deadLetterStrategy>
      	             </policyEntry>
      	         </policyEntries>
      	     </policyMap>
      	 </destinationPolicy>
    </borker>

## 删除空的Queue和Topic ##

<broker xmlns="http://activemq.apache.org/schema/core" schedulePeriodForDestinationPurge="10000">
     
      <destinationPolicy>
         <policyMap>
            <policyEntries>
               <policyEntry queue=">" gcInactiveDestinations="true" inactiveTimoutBeforeGC="30000"/>
            </policyEntries>
         </policyMap>
      </destinationPolicy>
           
    </broker>

schedulePeriodForDestinationPurge：执行清理任务的周期；  
gcInactiveDestinations=true：表示启用清理功能；  
inactiveTimoutBeforeGC：queue或topic的超时时间，在规定的时间内，无有效订阅，没有入队记录，超时后就会被清理。  
参考：[http://activemq.apache.org/delete-inactive-destinations.html][http_activemq.apache.org_delete-inactive-destinations.html]

[http_activemq.apache.org_timestampplugin.html]: http://activemq.apache.org/timestampplugin.html
[http_activemq.apache.org_delete-inactive-destinations.html]: http://activemq.apache.org/delete-inactive-destinations.html