ActiveMQ处理积压的消息

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

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

1
2
3
4
<plugins>
<!-- 86,400,000 ms = 1 day -->
<timeStampingBrokerPlugin ttlCeiling="86400000" zeroExpirationOverride="86400000"/>
</plugins>

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

配置消息过期丢弃策略

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
<borker>
<destinationPolicy>
<policyMap>
<policyEntries>
<!--expireMessagesPeriod=60000表示每隔60s检查消息是否过期-->
<!--topic=>表示对所有topic都生效-->
<policyEntry topic=">" expireMessagesPeriod="60000">
<deadLetterStrategy>
<!--processExpired为false表示过期消息不进入死信队列,即执行删除操作-->
<sharedDeadLetterStrategy processExpired="false" />
</deadLetterStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
</borker>

删除空的Queue和Topic

1
2
3
4
5
6
7
8
9
10
11
<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

Donny wechat
欢迎关注我的个人公众号
打赏,是超越赞的一种表达。
Show comments from Gitment