Mqadmin命令介绍|学习笔记

简介: 快速学习Mqadmin命令介绍

开发者学堂课程【RocketMQ知识精讲与项目实战(第一阶段)Mqadmin命令介绍】学习笔记,与课程紧密联系,让用户快速学习知识

课程地址:https://developer.aliyun.com/learning/course/702/detail/12373


Mqadmin命令介绍


内容介绍:

一、使用方式

二、命令介绍

三、注意事项

 

一、使用方式

进入 RocketMQ 安装位置,在 bin 目录下执行./mqadmin {command} {args}

 

二、命令介绍

1Topic相关

Topic 可以简单理解为消息的类别(作为了解)

在发送消息的时候,要先创建消息的类别,并且指定哪个 Broker 负责当前这一类消息。

Update Topic 也就是创建更新 Topic 配置,包括-b 表示 Broker地址,表示 topic 所在 Broker,只支持单台 Broker,地址为 ip:port;-c表示 cluster 名称,表示 topic 所在集群(集群可通过clusterList查询);

-h-表示打印帮助;

Delete Topic 删除 Topic

topicList 查看 Topic 列表信息

topicRoute 查看 Topic 路由信息

topicStatus 查看 Topic 消息列队 offset

topicClusterList 查看 Topic 所在集群列表

(2)集群相关

clusterList 查看集群信息,集群、BrokerName、Brokerld、TPS 等信息。

-m 表示打印更多信息(增加打印出如下信息#InTotalYest,#OutTotalYest,#InTotalToday,#OutTotalToday)

clusterRT 发送消息检测集群各 BrokerRT。

消息发往${BrokerName} Topic。 

(3)消息相关

可以通过 id 查看消息,可以通过关键字 key 查看消息,或者通过偏移量查看消息。

(4)消费者、消费组相关

和消费者、消费组相关的,也就是和 consumer 相关的几个命令也有很多,图表中有具体的说明

(5)连接相关

和连接相关的,查看当前 consumer 的网络连接和 producer 的网络连接的信息。

(6)NameServer相关

包括更新 NameServer 的 kv 配置,目前还未使用,删除 NameServer 的 kv 配置,获取 NameServer 配置

(7)其他

最后一个其他方面,开启监控进程,监控信息误删、重试对列消息数等等。


三、注意事项

(1)几乎所有命令都需要配置-n 表示 NameServer 地址,格式为 ip:port

(2)几乎所有命令都可以通过-h 获取帮助

(3)如果既有 Broker 地址(-b)配置项又有 clusterName (-c)配置项,则优先以Broker 地址执行命令;如果不配置 Broker地址,则对集群中所有主机执行命令

相关文章
|
消息中间件 Java Maven
一文搞懂Spring Boot整合RocketMQ
一文搞懂Spring Boot整合RocketMQ
584 0
|
消息中间件 数据可视化 Java
Linxu下RocketMq及可视化界面的搭建
Linxu下RocketMq配置信息及可视化界面的搭建
2297 0
|
存储 消息中间件 数据安全/隐私保护
RocketMq Topic创建和删除
RocketMq Topic创建和删除
5847 0
|
消息中间件 Shell 数据处理
rocket mq 查看消费进度,消息堆积,清除堆积数据命令
该内容是关于RocketMQ的消费进度管理和堆积数据处理的指导。首先,需进入RocketMQ的bin目录,然后使用`mqadmin consumerProgress`命令查看消费者或生产者的消费进度。`broker offset`和`consumer offset`的差值表示未消费消息。通过`resetOffsetByTime`命令可重置消费位点来清除堆积数据,未消费消息默认3天后会被丢弃。此外,`CONSUME_FROM WHERE`枚举类定义了消费起点选项,包括从最后、最开始或指定时间点消费。
4158 3
|
消息中间件 存储 Kubernetes
k8s快速部署rocketMq及rocketMq-console-ng
k8s快速部署rocketMq及rocketMq-console-ng
1876 0
|
消息中间件 负载均衡 Apache
【RocketMQ系列七】消费者和生产者的实现细节
【RocketMQ系列七】消费者和生产者的实现细节
547 1
|
消息中间件 容灾 物联网
【RocketMQ系列十四】RocketMQ中消息堆积如何处理
【RocketMQ系列十四】RocketMQ中消息堆积如何处理
2900 3
|
消息中间件 监控 网络安全
在RocketMQ中,生产者提交数据导致连接不上问题
【6月更文挑战第19天】在RocketMQ中,生产者提交数据导致连接不上问题
582 1