?【Alibaba中间件技术系列】「RocketMQ技术专题」让我们一起总结梳理一下RocketMQ的broker的指令分析

RocketMQ的控制台

RocketMQ 提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker 等信息的管理；

登录控制台

首先进入RocketMQ 工程，进入/RocketMQ/bin，在该目录下有个mqadmin 脚本，在mqadmin 下可以查看有哪些命令

sh mqadmin

查看具体命令的使用

sh mqadmin help 命令名称

例如，查看updateTopic 的使用`

sh mqadmin help updateTopic

创建Topic

• 指令：updateTopic

• 类路径 ：com.alibaba.rocketmq.tools.command.topic.UpdateTopicSubCommand

删除Topic

• 指令；deleteTopic

• 类路径：com.alibaba.rocketmq.tools.command.topic.DeleteTopicSubCommand

创建（修订）订阅组

• 指令：updateSubGroup

• 类路径：com.alibaba.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand

删除订阅组配置

• 指令：deleteSubGroup

• 类路径：com.alibaba.rocketmq.tools.command.consumer.DeleteSubscriptionGroupCommand

  

更新Broker 配置文件

• 指令：updateBrokerConfig

• 类路径：com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand

查看Topic 列表信息

• 指令：topicList

• 类路径：com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand

  

查看Topic 路由信息

• 指令：topicRoute

• 类路径：com.alibaba.rocketmq.tools.command.topic.TopicRouteSubCommand

查看Broker 统计信息

• 指令：brokerStats

• 类路径：com.alibaba.rocketmq.tools.command.broker.BrokerStatsSubCommanD

根据消息ID 查询消息

• 指令：queryMsgById

• 类路径：com.alibaba.rocketmq.tools.command.message.QueryMsgByIdSubCommand

根据消息Key 查询消息

• 指令：queryMsgByKey

• 类路径：com.alibaba.rocketmq.tools.command.message.QueryMsgByKeySubCommand

根据Offset 查询消息

• 指令：queryMsgByOffset

• 类路径：com.alibaba.rocketmq.tools.command.message.QueryMsgByOffsetSubCommand

查询Producer 的网络连接

• 指令：queryMsgByOffset

• 类路径：com.alibaba.rocketmq.tools.command.message.QueryMsgByOffsetSubCommand

查询Consumer 的网络连接

该命令只打印当前与cluster 连接的consumer 网络连接信息

• 指令 ：consumerConnection

• 类路径：com.alibaba.rocketmq.tools.command.connection.ConsumerConnectionSubCommand

  

查看订阅组消费状态

• 指令：consumerProgress

• 类路径：com.alibaba.rocketmq.tools.command.consumer.ConsumerProgressSubCommand

查看集群消息

• 指令 ：clusterList

• 类路径：com.alibaba.rocketmq.tools.command.cluster.ClusterListSubCommand

添加（更新）KV 配置信息

• 指令 ：updateKvConfig

• 类路径：com.alibaba.rocketmq.tools.command.namesrv.UpdateKvConfigCommand

获取Consumer消费进度

该命令只打印当前与cluster 连接的consumer 的消费进度

• 指令 ：getConsumerStatus

• 类路径 ：com.alibaba.rocketmq.tools.command.offset.GetConsumerStatusCommand