删除rocketmq堆积消息和topic等

 

1. 停止 rocketmq：

    优雅方法: 终端下  sh /mq安装目录/rocketmq-4.7.0/bin/mqshutdown broker
    粗暴方法: kill -9 干掉所有broker就好

 

2. 查看mq配置文件, 了解mq日志路径

    cat  /mq安装目录/rocketmq-4.7.0/conf/broker.conf   
    或者   
    cat /mq安装目录/rocketmq-4.7.0/conf/2m-2s-async/broker-a.properties
    关注里面的storePathRootDir, storePathCommitLog字段配置的日志路径

 

2. 根据日志路径, 删除mq日志      

    rm -rf /mq安装目录/rocketmq-4.7.0/logs/* 

 

3. 根据日志路径, 删除MQ堆积topic等信息     

    rm -rf /mq安装目录/rocketmq-4.7.0/store/* 
    理论上到这里已经顺利清空rocketmq堆积消息和topic等, 只要重启mq即可

 

4. 重启MQ

    sh /mq安装目录/rocketmq-4.7.0/bin/mqbroker -c /mq安装目录/rocketmq-4.7.0/conf/2m-2s-async/broker-m.properties 

 

5. [可选] 清空MQ里显示的topic         

    经过上一步后, 消息已经全部删除了, 虽然这里还是可以查询得了, 但是业务系统在收发消息时会报错, 需要手工新建topic和消费者才行, 所以为了避免干扰, 建议把显示的实际被删掉    的消息也清理掉

    如果安装了RocketMQ-Console, 可以在前端页面上操作删除topic, 否则也可以下面命令
    查询所有topic    sh /mq安装目录/rocketmq-4.7.0/bin/mqadmin topicList -n 127.0.0.1:9876           
    删除实际被删Topic    sh /mq安装目录/rocketmq-4.7.0/bin/mqadmin deleteTopic -c HOSTNAME -n 127.0.0.1:9876  -t topic123

注意事项: 

1. 先停掉rocketmq和清空顺序很关键；如果没有都清楚，rocketmq不知道从哪里还会把所有积攒的再加载回来，导致还是无法启动rocketmq
2. deleteTopic不是必须的，但是删除的时候一般都需要制定 -c，可以用hostname试试

 

参考: 如何清空rocketmq消息(包括堆积消息) - tantexian的博客空间 - OSCHINA
https://my.oschina.net/tantexian/blog/703785