清空rocketmq訊息方法

2021-09-02 16:57:58 字數 808 閱讀 7209

1. 停止rocketmq

可以使用kill -9 命令強制停止rocketmq

程序2. 刪除rocketmq日誌

rm -rf /root/logs/rocketmqlogs/*

3. 刪除rocketmq中topic等資訊

rm -rf /root/store/*

4. [可選] 手工清空

mq裡剩餘的topic,示例命令如下:

cd alibaba-rocketmq/bin

sh mqadmin topiclist -n 192.168.1.167:9876

sh mqadmin deletetopic -c hostname -n 192.168.1.167:9876 -t ordertopic

5. 重新啟動rocketmq,示例命令如下:

cd alibaba-rocketmq/bin

nohup sh mqnamesrv -n 192.168.1.167:9876 > /dev/null 2>&1 &

nohup sh mqbroker -n 192.168.1.167:9876 > /dev/null 2>&1 &

ps:1. 順序必須是先停止rocketmq,再清空

資料;如果順序錯誤,可能會導致訊息

無法正常清除、rocketmq無法啟動等問題

2. 刪除topic不是必須的,但是刪除的時候需要指定 -c,可以用伺服器的hostname試試

清空rocketmq訊息方法

1.停止rocketmq 可以使用kill 9 命令強制停止rocketmq程序 2.刪除rocketmq日誌 rm rf root logs rocketmqlogs 3.刪除rocketmq中topic等資訊 rm rf root store 4.可選 手工清空mq裡剩餘的topic,示例命令如...

RocketMQ訊息型別

普通資訊也叫做無序訊息,簡單來說就是沒有順序的訊息,producer 只管傳送訊息,consumer 只管接收訊息,至於訊息和訊息之間的順序並沒 可能先傳送的訊息先消費,也可能先傳送的訊息後消費。舉個簡單例子,producer 依次傳送 order id 為 1 2 3 的訊息到 broker,co...

RocketMQ 事務訊息

一 事務訊息實現方式 應用使用事務訊息的步驟 1 應用傳送訊息,使用prepare欄位標示準備訊息 2 應用執行本地業務邏輯 3 應用傳送事務提交或回滾訊息 broker收到prepare訊息後會將topic替換為rmq sys trans half topic,queueid替換為0,然後寫入co...