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
Linxu下RocketMq及可视化界面的搭建
Linxu下RocketMq配置信息及可视化界面的搭建
1926 0
|
6月前
|
消息中间件 存储 Kafka
一文带你从入门到实战全面掌握RocketMQ核心概念、架构部署、实践应用和高级特性
本文详细介绍了分布式消息中间件RocketMQ的核心概念、部署方式及使用方法。RocketMQ由阿里研发并开源,具有高性能、高可靠性和分布式特性,广泛应用于金融、互联网等领域。文章从环境搭建到消息类型的实战(普通消息、延迟消息、顺序消息和事务消息)进行了全面解析,并对比了三种消费者类型(PushConsumer、SimpleConsumer和PullConsumer)的特点与适用场景。最后总结了使用RocketMQ时的关键注意事项,如Topic和Tag的设计、监控告警的重要性以及性能与可靠性的平衡。通过学习本文,读者可掌握RocketMQ的使用精髓并灵活应用于实际项目中。
5028 9
 一文带你从入门到实战全面掌握RocketMQ核心概念、架构部署、实践应用和高级特性
|
12月前
|
存储 Java Linux
【Maven】——基础入门,插件安装、配置和简单使用,Maven如何设置国内源
Maven插件安装,Maven项目构建,依赖管理,Haven Help插件,Maven仓库,Maven如何设置国内源
|
存储 消息中间件 数据安全/隐私保护
RocketMq Topic创建和删除
RocketMq Topic创建和删除
5766 0
|
消息中间件 存储 Java
消息队列 MQ使用问题之如何将RocketMQ中某个集群的topic迁移到另一个集群
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
消息中间件 RocketMQ
2024最全RocketMQ集群方案汇总
在研究RocketMQ集群方案时,发现网上存在诸多不一致之处,如组件包含NameServer、Broker、Proxy等。通过查阅官方文档,了解到v4.x和v5.x版本的差异。v4.x部署模式包括单主、多主、多主多从(异步复制、同步双写),而v5.x新增Local与Cluster模式,主要区别在于Broker和Proxy是否同进程部署。Local模式适合平滑升级,Cluster模式适合高可用需求。不同模式下,集群部署方案大致相同,涵盖单主、多主、多主多从等模式,以满足不同的高可用性和性能需求。
1706 0
|
消息中间件 Shell 数据处理
rocket mq 查看消费进度,消息堆积,清除堆积数据命令
该内容是关于RocketMQ的消费进度管理和堆积数据处理的指导。首先,需进入RocketMQ的bin目录,然后使用`mqadmin consumerProgress`命令查看消费者或生产者的消费进度。`broker offset`和`consumer offset`的差值表示未消费消息。通过`resetOffsetByTime`命令可重置消费位点来清除堆积数据,未消费消息默认3天后会被丢弃。此外,`CONSUME_FROM WHERE`枚举类定义了消费起点选项,包括从最后、最开始或指定时间点消费。
3920 3
|
消息中间件 负载均衡 API
RocketMQ生产者负载均衡(轮询机制)核心原理
文章深入分析了RocketMQ生产者的负载均衡机制,特别是轮询机制的实现原理,揭示了如何通过`ThreadLocal`技术和消息队列的选播策略来确保消息在多个队列之间均衡发送,以及如何通过灵活的API支持自定义负载均衡策略。
|
消息中间件 存储 Kubernetes
k8s快速部署rocketMq及rocketMq-console-ng
k8s快速部署rocketMq及rocketMq-console-ng
1734 0