- RocketMQ實(shí)戰(zhàn)與原理解析
- 楊開(kāi)元
- 1041字
- 2019-01-04 22:41:02
2.4 常用管理命令
MQAdmin是RocketMQ自帶的命令行管理工具,在bin目錄下,運(yùn)行mqadmin即可執(zhí)行。使用mqadmin命令,可以進(jìn)行創(chuàng)建、修改Topic,更新Broker的配置信息,查詢特定消息等各種操作。本節(jié)將介紹幾個(gè)常用的命令。
1.創(chuàng)建/修改Topic
消息的發(fā)送和接收都要有對(duì)應(yīng)的Topic,需要向某個(gè)Topic發(fā)送或接收消息,所以在正式使用RocketMQ進(jìn)行消息發(fā)送和接收前,要先創(chuàng)建Topic,創(chuàng)建Topic的指令是updateTopic,表2-1列出了支持的參數(shù)。
表2-1 updateTopic

2.刪除Topic
與創(chuàng)建/修改Topic對(duì)應(yīng)的是刪除Topic,把RocketMQ系統(tǒng)中不用的Topic徹底清除,指令是deleteTopic,表2-2列出了支持的參數(shù)。
表2-2 deleteTopic

3.創(chuàng)建/修改訂閱組
訂閱組在提高系統(tǒng)的高可用性和吞吐量方面扮演著重要的角色,比如用Clustering模式消費(fèi)一個(gè)Topic里的消息內(nèi)容時(shí),可以啟動(dòng)多個(gè)消費(fèi)者并行消費(fèi),每個(gè)消費(fèi)者只消費(fèi)Topic里消息的一部分,以此提高消費(fèi)速度,這個(gè)時(shí)候就是通過(guò)訂閱組來(lái)指明哪些消費(fèi)者是同一組,同一組的消費(fèi)者共同消費(fèi)同一個(gè)Topic里的內(nèi)容。訂閱組可以被自動(dòng)創(chuàng)建,使用這個(gè)命令一般是用來(lái)修改訂閱組,指令是updateSubGroup,表2-3列出了支持的參數(shù)。
表2-3 updateSubGroup

4.刪除訂閱組
與創(chuàng)建或修改訂閱組相對(duì)應(yīng),這個(gè)命令刪除不再使用的訂閱組,指令是deleteSubGroup,表2-4列出了支持的參數(shù)。
表2-4 deleteSubGroup

5.更新Broker配置
Broker有很多的配置信息,在Broker啟動(dòng)時(shí),可以通過(guò)配置文件來(lái)指定配置信息。有些配置信息支持在Broker運(yùn)行的時(shí)候動(dòng)態(tài)更改,更改指令是updateBrokerConfig,表2-5列出了支持的參數(shù)。
表2-5 updateBrokerConfig

6.更新Topic的讀寫(xiě)權(quán)限
RocketMQ支持對(duì)Topic進(jìn)行權(quán)限控制,主要分為只讀的Topic和可讀寫(xiě)的Topic,權(quán)限可以通過(guò)指令updateTopicPerm來(lái)動(dòng)態(tài)改變,表2-6列出了支持的參數(shù)。
表2-6 updateTopicPerm

7.查詢Topic的路由信息
Topic的路由信息指的是某個(gè)Topic所在的Broker相關(guān)信息,客戶端可以通過(guò)NameServer來(lái)獲取這些信息,本命令一般在調(diào)試的時(shí)候使用,指令是TopicRoute,表2-7列出了支持的參數(shù)。
表2-7 TopicRoute

8.查看Topic列表信息
上面提到的TopicRoute是列出某個(gè)Topic的相關(guān)信息,還有個(gè)指令TopicList用來(lái)列出集群中所有Topic的名稱,表2-8列出了支持的參數(shù)。
表2-8 TopicList

9.查看Topic統(tǒng)計(jì)信息
在使用RocketMQ的時(shí)候,經(jīng)常需要查看某個(gè)Topic的狀態(tài),看看消息的數(shù)量,有多少未處理等,此時(shí)可以通過(guò)指令TopicStats來(lái)查詢,表2-9列出了支持的參數(shù)。
表2-9 TopicStats

10.根據(jù)時(shí)間查詢消息
一條消息被發(fā)送到RocketMQ后,默認(rèn)會(huì)帶上發(fā)送的時(shí)間戳,所以我們可以根據(jù)估計(jì)的時(shí)間來(lái)查詢消息,指令是printMsg,表2-10列出了支持的參數(shù)。
表2-10 printMsg

11.根據(jù)消息ID查詢消息
根據(jù)消息ID可以精確定位到某條消息,但是消息ID需要通過(guò)其他方式來(lái)獲取,比如可以先用時(shí)間來(lái)查詢出一些消息,然后定位到要找的具體某個(gè)消息,指令是queryMsgById,表2-11列出了支持的參數(shù)。
表2-11 queryMsgById

12.查看集群消息
指令clusterList用來(lái)列出集群的狀態(tài),看看有哪些Broker在提供服務(wù),表2-12列出了支持的參數(shù)。
表2-12 clusterList

- 極簡(jiǎn)算法史:從數(shù)學(xué)到機(jī)器的故事
- Instant Testing with CasperJS
- 編程的修煉
- 零基礎(chǔ)學(xué)Scratch少兒編程:小學(xué)課本中的Scratch創(chuàng)意編程
- Mastering Natural Language Processing with Python
- 云原生Spring實(shí)戰(zhàn)
- 差分進(jìn)化算法及其高維多目標(biāo)優(yōu)化應(yīng)用
- The DevOps 2.5 Toolkit
- 青少年學(xué)Python(第1冊(cè))
- Learning Concurrency in Kotlin
- OpenResty完全開(kāi)發(fā)指南:構(gòu)建百萬(wàn)級(jí)別并發(fā)的Web應(yīng)用
- 圖數(shù)據(jù)庫(kù)實(shí)戰(zhàn)
- Extreme C
- Building Serverless Web Applications
- Unity 5.X從入門(mén)到精通