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地址,则对集群中所有主机执行命令

相关文章
|
JavaScript API 开发者
使用 u-navbar 组件实现页面导航和布局的完全指南
使用 u-navbar 组件实现页面导航和布局的完全指南
2060 0
|
关系型数据库 MySQL 数据库
MySQL - 不使用外键约束的实操(二)
MySQL - 不使用外键约束的实操(二)
1007 0
|
网络协议 Linux 数据安全/隐私保护
如何在Windows本地快速搭建SFTP文件服务器,并通过端口映射实现公网远程访问
如何在Windows本地快速搭建SFTP文件服务器,并通过端口映射实现公网远程访问
|
12月前
|
并行计算 PyTorch TensorFlow
Ubuntu安装笔记(一):安装显卡驱动、cuda/cudnn、Anaconda、Pytorch、Tensorflow、Opencv、Visdom、FFMPEG、卸载一些不必要的预装软件
这篇文章是关于如何在Ubuntu操作系统上安装显卡驱动、CUDA、CUDNN、Anaconda、PyTorch、TensorFlow、OpenCV、FFMPEG以及卸载不必要的预装软件的详细指南。
10978 4
|
10月前
|
存储 Java Linux
【Maven】——基础入门,插件安装、配置和简单使用,Maven如何设置国内源
Maven插件安装,Maven项目构建,依赖管理,Haven Help插件,Maven仓库,Maven如何设置国内源
|
9月前
|
存储 数据采集 算法
构建AI数据管道:从数据到洞察的高效之旅最佳实践
本文探讨了大模型从数据处理、模型训练到推理的全流程解决方案,特别强调数据、算法和算力三大要素。在数据处理方面,介绍了多模态数据的高效清洗与存储优化;模型训练中,重点解决了大规模数据集和CheckPoint的高效管理;推理部分则通过P2P分布式加载等技术提升效率。案例展示了如何在云平台上实现高性能、低成本的数据处理与模型训练,确保业务场景下的最优表现。
|
存储 数据库 时序数据库
InfluxDB的安装与Python调用
InfluxDB是一个高性能的时序数据库(Time-Series Database, TSDB),用于存储和分析时间序列数据的开源数据库,它非常适合于处理大量的时间戳数据,如金融市场数据、IoT 设备数据、监控数据等,尤其适合处理大量的时序数据和高频数据。 主要特性有: • 内置HTTP接口,使用方便 • 数据可以打标记,查询可以很灵活 • 类SQL的查询语句 • 安装管理很简单,并且读写数据很高效 • 能够实时查询,数据在写入时被索引后就能够被立即查出
InfluxDB的安装与Python调用
|
消息中间件 Shell 数据处理
rocket mq 查看消费进度,消息堆积,清除堆积数据命令
该内容是关于RocketMQ的消费进度管理和堆积数据处理的指导。首先,需进入RocketMQ的bin目录,然后使用`mqadmin consumerProgress`命令查看消费者或生产者的消费进度。`broker offset`和`consumer offset`的差值表示未消费消息。通过`resetOffsetByTime`命令可重置消费位点来清除堆积数据,未消费消息默认3天后会被丢弃。此外,`CONSUME_FROM WHERE`枚举类定义了消费起点选项,包括从最后、最开始或指定时间点消费。
3407 3
|
消息中间件 存储 缓存
RocketMQ 监控告警:生产环境如何快速通过监控预警发现堆积、收发失败等问题?
本文主要向大家介绍如何利用 RocketMQ 可观测体系中的指标监控,对生产环境中典型场景:消息堆积、消息收发失败等场景配置合理的监控预警,快速发现问题,定位问题。
1918 0
RocketMQ 监控告警:生产环境如何快速通过监控预警发现堆积、收发失败等问题?