purge和delete有什么区别呢

我们看到管理界面的queue里有purge和delete，而且注意：只有queue有purge。

他们的区别很简单：

purge: 只是清空队列里的消息，并把消息放入已经出队里
delete: 删除这个queue，在列表里会消失

为什么要删除过期的queue或topic？

因为，如果不删除不仅占空间，而且堆积太多会导致管理界面卡顿。

通过配置定时清理

官方文档：http://activemq.apache.org/delete-inactive-destinations

配置有以下几个：

schedulePeriodForDestinationPurge="60000",代表每60秒清理一次,默认为0
gcInactiveDestinations="true"，代表回收不活跃目标，默认是false
inactiveTimeoutBeforeGC="30000",当目标限制30秒删除，默认60秒

    <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" useJmx="true" dataDirectory="${activemq.data}" schedulePeriodForDestinationPurge="60000"><destinationPolicy><policyMap><policyEntries><policyEntry topic=">" ><pendingMessageLimitStrategy><constantPendingMessageLimitStrategy limit="1000"/></pendingMessageLimitStrategy></policyEntry><policyEntry queue=">" gcInactiveDestinations="true" inactiveTimeoutBeforeGC="30000"/></policyEntries></policyMap></destinationPolicy>

结果示例：

2020-04-07 16:09:16,619 | INFO  | 0c2f8e32-3a4b-449a-807f-086012425188 Inactive for longer than 30000 ms - removing ... | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost] Scheduler
2020-04-07 16:09:16,620 | INFO  | b3004cb2-d625-44e3-b18a-33e857a6b69d Inactive for longer than 30000 ms - removing ... | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost] Scheduler
2020-04-07 16:09:16,621 | INFO  | 32d7e194-15ba-458b-a4f9-91a41d37fb32 Inactive for longer than 30000 ms - removing ... | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost] Scheduler
2020-04-07 16:09:16,622 | INFO  | 8ffa6724-0ec9-4128-93bb-0955e0066a8c Inactive for longer than 30000 ms - removing ... | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost] Scheduler

命令行清理

purge是清理，比如清理一个queue的所有或部分消息

# bin/activemq purge 00015a7f-5bc4-4a76-aab3-366dee279320...
INFO: Purging all messages in queue: 00015a7f-5bc4-4a76-aab3-366dee279320

正则匹配删除：可以选择性地清理某些queue/topic里满足条件地message：

Examples:Main purge FOO.BAR- Delete all the messages in queue FOO.BARMain purge --msgsel "JMSMessageID='*:10',JMSPriority>5" FOO.*- Delete all the messages in the destinations that matches FOO.* and has a JMSMessageID inthe header field that matches the wildcard *:10, and has a JMSPriority field > 5 in thequeue FOO.BAR.SLQ92 syntax is also supported.* To use wildcard queries, the field must be a string and the query enclosed in ''Use double quotes "" around the entire message selector string.

比如：清理000开始的queue的消息

# bin/activemq purge 000*

命令行我没找到删除功能,通过上面的配置可以定时移除。

activemq消息清理相关推荐

ActiveMQ—消息特性（延迟和定时消息投递）
ActiveMQ消息特性:延迟和定时消息投递(Delay and Schedule Message Delivery) 转自:http://blog.csdn.net/kimmking/article ...
【转】ActiveMQ消息传送机制以及ACK机制详解
2019独角兽企业重金招聘Python工程师标准>>> 本文转载自 http://shift-alt-ctrl.iteye.com/blog/2020182 AcitveMQ是作为一 ...
ActiveMQ消息传送机制以及ACK机制详解
2019独角兽企业重金招聘Python工程师标准>>> AcitveMQ是作为一种消息存储和分发组件,涉及到client与broker端数据交互的方方面面,它不仅要担保消息的存储安全 ...
activemq消息持久化_ActiveMQ 5.x中的消息持久性
activemq消息持久化我被问了很多关于ActiveMQ如何存储消息(或在某些情况下不存储)的基本知识. 这是它的高级解释. 注意,上下文在JMS中. 如果您使用ActiveMQ的非JMS客户端( ...
activemq消息持久化_将ActiveMQ持久消息传递性能提高25倍
activemq消息持久化 Apache ActiveMQ,JBoss A-MQ和Red Hat Apache ActiveMQ是一个非常受欢迎的开源消息传递代理,由创建(和从事) Apache Ka ...
ActiveMQ消息优先级：工作原理
关于ActiveMQ的消息优先级支持 , 邮件列表上通常会不断出现一些问题,以及有关观察到的行为和"真正支持什么"的好问题? 我希望可以帮助您了解幕后情况以及可以支持的优先级. 详 ...
JMS学习六（ActiveMQ消息传送模型）
JMS学习六(ActiveMQ消息传送模型) ActiveMQ 支持两种截然不同的消息传送模型:PTP(即点对点模型)和Pub/Sub(即发布 /订阅模型),分别称作:PTP Domain 和Pub/ ...
JMS学习八（ActiveMQ消息持久化）
JMS学习八(ActiveMQ消息持久化) ActiveMQ的消息持久化机制有JDBC,AMQ,KahaDB和LevelDB,还有一种内存存储的方式,由于内存不属于持久化范畴,而且如果使用内存队列,可 ...
SpringBoot集成ActiveMq消息队列实现即时和延迟处理
原文链接:https://blog.csdn.net/My_harbor/article/details/81328727 一.安装ActiveMq 具体安装步骤:自己谷歌去二.新建springbo ...

activemq消息清理

purge和delete有什么区别呢

为什么要删除过期的queue或topic？

通过配置定时清理

命令行清理

activemq消息清理相关推荐

最新文章

热门文章