一、準備工作
在創建新的RocketMQ Topic之前,我們必須先準備好以下內容:
1. RocketMQ服務的IP地址以及端口號。
2. 互聯網連接(也稱為服務憑據),這是訪問RocketMQ服務的用戶名和密碼。
在準備好了以上內容之後,我們就可以開始創建新的RocketMQ Topic了。
二、創建新的RocketMQ Topic
要創建新的RocketMQ Topic,我們需要使用RocketMQ提供的命令工具。
1. 首先打開命令行終端(Windows下為CMD,Linux下為Terminal):
$ cd /usr/local/rocketmq/bin/ $ ./mqadmin updateTopic -n localhost:9876 -t new_topic -c DefaultCluster -r 1 -o true
2. 然後執行以下命令進行創建,其中-n參數表示RocketMQ服務的IP地址以及端口號,-t參數表示新Topic的名稱,-c參數表示新Topic所屬的Cluster名稱,-r參數表示新Topic的初始隊列數量,-o參數表示是否自動創建Broker的配置文件。
執行成功後,會返回類似下面這種格式的消息:
update topic success. -n localhost:9876 -c DefaultCluster
這就說明我們已經成功創建了新的RocketMQ Topic了。
三、查看RocketMQ Topic列表
如果我們想要查看已經存在的RocketMQ Topic列表,可以使用以下命令:
$ ./mqadmin topicList -n localhost:9876
執行成功後,會返回RocketMQ服務上已存在的Topic列表,例如:
new_topic test_topic test_topic2
四、修改RocketMQ Topic配置
如果我們需要修改已經存在的RocketMQ Topic的配置,可以使用以下命令:
$ ./mqadmin updateTopic -n localhost:9876 -t new_topic -o false
執行成功後,會返回類似下面這種格式的消息:
update topic success. -n localhost:9876
這裡我們將new_topic的自動創建Broker配置改為了false。
五、刪除RocketMQ Topic
如果我們需要刪除一個RocketMQ Topic,可以使用以下命令進行刪除:
$ ./mqadmin deleteTopic -n localhost:9876 -t new_topic
執行成功後,會返回類似下面這種格式的消息:
delete topic by name[new_topic] success.
這裡我們成功刪除了名為new_topic的RocketMQ Topic。
原創文章,作者:小藍,如若轉載,請註明出處:https://www.506064.com/zh-hant/n/201178.html