mqadmin命令的使用

news2024/11/26 18:22:40

mqadmin命令的使用


F:\rocketmq-all-4.9.7-bin-release\bin>mqadmin
The most commonly used mqadmin commands are:
updateTopic Update or create topic
deleteTopic Delete topic from broker and NameServer.
updateSubGroup Update or create subscription group
deleteSubGroup Delete subscription group from broker.
updateBrokerConfig Update broker’s config
updateTopicPerm Update topic perm
topicRoute Examine topic route info
topicStatus Examine topic Status info
topicClusterList get cluster info for topic
brokerStatus Fetch broker runtime status data
queryMsgById Query Message by Id
queryMsgByKey Query Message by Key
queryMsgByUniqueKey Query Message by Unique key
queryMsgByOffset Query Message by offset
queryMsgTraceById query a message trace
printMsg Print Message Detail
printMsgByQueue Print Message Detail
sendMsgStatus send msg to broker.
brokerConsumeStats Fetch broker consume stats data
producerConnection Query producer’s socket connection and client version
consumerConnection Query consumer’s socket connection, client version and subscription
consumerProgress Query consumers’s progress, speed
consumerStatus Query consumer’s internal data structure
cloneGroupOffset clone offset from other group.
producer Query producer’s instances, connection, status, etc.
clusterList List all of clusters
topicList Fetch all topic list from name server
updateKvConfig Create or update KV config.
deleteKvConfig Delete KV config.
wipeWritePerm Wipe write perm of broker in all name server you defined in the -n param
addWritePerm Add write perm of broker in all name server you defined in the -n param
resetOffsetByTime Reset consumer offset by timestamp(without client restart).
skipAccumulatedMessage Skip all messages that are accumulated (not consumed) currently
updateOrderConf Create or update or delete order conf
cleanExpiredCQ Clean expired ConsumeQueue on broker.
deleteExpiredCommitLog Delete expired CommitLog files
cleanUnusedTopic Clean unused topic on broker.
startMonitoring Start Monitoring
statsAll Topic and Consumer tps stats
allocateMQ Allocate MQ
checkMsgSendRT check message send response time
clusterRT List All clusters Message Send RT
getNamesrvConfig Get configs of name server.
updateNamesrvConfig Update configs of name server.
getBrokerConfig Get broker config by cluster or special broker!
getConsumerConfig Get consumer config by subscription group name!
queryCq Query cq command.
sendMessage Send a message
consumeMessage Consume message
updateAclConfig Update acl config yaml file in broker
deleteAclConfig Delete Acl Config Account in broker
clusterAclConfigVersion List all of acl config version information in cluster
updateGlobalWhiteAddr Update global white address for acl Config File in broker
getAclConfig List all of acl config information in cluster
exportMetadata export metadata
exportConfigs export configs
exportMetrics export metrics

See ‘mqadmin help ’ for more information on a specific command.

以下是关于 RocketMQ 中 mqadmin 命令的各种参数及其含义。RocketMQ 是阿里巴巴开源的一款分布式消息中间件。mqadmin 是 RocketMQ 提供的一个命令行工具,可以用于管理和操作 RocketMQ 集群。以下是一些常用命令的解释:

  1. updateTopic: 更新或创建主题。
  2. deleteTopic: 从 broker 和 NameServer 删除主题。
  3. updateSubGroup: 更新或创建订阅组。
  4. deleteSubGroup: 从 broker 删除订阅组。
  5. updateBrokerConfig: 更新 broker 的配置。
  6. updateTopicPerm: 更新主题权限。
  7. topicRoute: 检查主题路由信息。
  8. topicStatus: 检查主题状态信息。
  9. topicClusterList: 获取主题的集群信息。
  10. brokerStatus: 获取 broker 运行时状态数据。
  11. queryMsgById: 根据 ID 查询消息。
  12. queryMsgByKey: 根据 Key 查询消息。
  13. queryMsgByUniqueKey: 根据唯一键查询消息。
  14. queryMsgByOffset: 根据偏移量查询消息。
  15. queryMsgTraceById: 根据 ID 查询消息追踪。
  16. printMsg: 打印消息详情。
  17. printMsgByQueue: 根据队列打印消息详情。
  18. sendMsgStatus: 发送消息到 broker。
  19. brokerConsumeStats: 获取 broker 消费状态数据。
  20. producerConnection: 查询生产者的 socket 连接和客户端版本。
  21. consumerConnection: 查询消费者的 socket 连接、客户端版本和订阅。
  22. consumerProgress: 查询消费者的进度、速度。
  23. consumerStatus: 查询消费者的内部数据结构。
  24. cloneGroupOffset: 从其他组克隆 offset。
  25. producer: 查询生产者的实例、连接、状态等。
  26. clusterList: 列出所有集群。
  27. topicList: 从 name server 获取所有主题列表。
  28. updateKvConfig: 创建或更新 KV 配置。
  29. deleteKvConfig: 删除 KV 配置。
  30. wipeWritePerm: 清除在 -n 参数中定义的所有 name server 中 broker 的写权限。
  31. addWritePerm: 在 -n 参数中定义的所有 name server 中添加 broker 的写权限。
  32. resetOffsetByTime: 通过时间戳重置消费者 offset(无需客户端重启)。
  33. skipAccumulatedMessage: 跳过当前积累的(未消费的)所有消息。
  34. updateOrderConf: 创建、更新或删除 order conf。
  35. cleanExpiredCQ: 在 broker 上清理过期的 ConsumeQueue。
  36. deleteExpiredCommitLog: 删除过期的 CommitLog 文件。
  37. cleanUnusedTopic: 在 broker 上清理未使用的主题。
  38. startMonitoring: 开始监控。
  39. statsAll: 主题和消费者的 TPS 统计。
  40. allocateMQ: 分配消息队列。
  41. checkMsgSendRT: 检查消息发送响应时间。
  42. clusterRT: 列出所有集群的消息发送响应时间。
  43. getNamesrvConfig: 获取名字服务器的配置。
  44. updateNamesrvConfig: 更新名字服务器的配置。
  45. getBrokerConfig: 根据集群或特定的 broker 获取 broker 配置。
  46. getConsumerConfig: 通过订阅组名称获取消费者配置!
  47. queryCq: 查询 cq 命令。
  48. sendMessage: 发送消息。
  49. consumeMessage: 消费消息。
  50. updateAclConfig: 更新 broker 中的 acl 配置 yaml 文件。
  51. deleteAclConfig: 在 broker 中删除 Acl 配置账户。
  52. clusterAclConfigVersion: 在集群中列出所有的 acl 配置版本信息。
  53. updateGlobalWhiteAddr: 在 broker 中更新全局白名单地址以供 acl 配置文件使用。
  54. getAclConfig: 在集群中列出所有的 acl 配置信息。
  55. exportMetadata: 导出元数据。
  56. exportConfigs: 导出配置。
  57. exportMetrics: 导出指标。

如果你需要关于特定命令的更多信息,你可以使用 'mqadmin help <command>' 命令来获取。例如,如果你想知道 updateTopic 命令的更多信息,你可以运行 'mqadmin help updateTopic'


在这里插入图片描述
这是 mqadmin updateTopic 命令的帮助信息,这个命令用于更新或创建 RocketMQ 的主题。以下是参数的含义:

  • -b,--brokerAddr <arg>: 创建主题的 broker 地址。
  • -c,--clusterName <arg>: 创建主题的集群名称。
  • -h,--help: 打印帮助信息。
  • -n,--namesrvAddr <arg>: Name server 地址列表,例如:‘192.168.0.1:9876;192.168.0.2:9876’。
  • -o,--order <arg>: 设置主题的顺序 (true|false)。
  • -p,--perm <arg>: 设置主题的权限 (2|4|6),其中2代表写权限,4代表读权限,6代表读写权限。
  • -r,--readQueueNums <arg>: 设置读取队列数。
  • -s,--hasUnitSub <arg>: 是否有单元订阅 (true|false)。
  • -t,--topic <arg>: 主题名称。
  • -u,--unit <arg>: 是否是单元主题 (true|false)。
  • -w,--writeQueueNums <arg>: 设置写入队列数。

总的来说,这个命令的主要作用就是允许你创建或者更新 RocketMQ 中的主题,通过调整各种参数来调整主题的特性和性能。


在这里插入图片描述
mqadmin topicStatus 是一个命令行工具,用于检查指定主题的状态信息。以下是每个参数的详细说明:

  • -h,--help: 打印帮助信息。
  • -n,--namesrvAddr <arg>: Name server 地址列表,例如:‘192.168.0.1:9876;192.168.0.2:9876’。
  • -t,--topic <arg>: 主题名称,即你想要查询状态的主题。

例如,如果你想查询名为 “testTopic” 的主题的状态,你可以运行如下命令:

mqadmin topicStatus -n '192.168.0.1:9876' -t 'testTopic'

这将返回 “testTopic” 主题在 '192.168.0.1:9876' 这个 name server 上的状态信息。

mqadmin topicStatus 命令会返回指定主题的状态信息,包括但不限于以下数据:

  • 主题的队列分布情况。
  • 每个队列的消息积累情况。
  • 生产者和消费者的相关信息,例如:消费进度、是否存在消费延迟等。

具体的返回内容可能会因 RocketMQ 的版本和具体配置有所不同。如果想要获取具体的返回内容,你需要在具体的 RocketMQ 环境中执行该命令。

请注意,实际的返回信息可能会比较复杂,并且可能需要一定的 RocketMQ 知识才能正确解读。如果你在解读返回信息时遇到困难,我建议查阅 RocketMQ 的官方文档或者寻求社区的帮助。


在RocketMQ中,mqadmin命令行工具提供了获取消息堆积量的功能。你可以使用consumerProgress命令来获取消息堆积量。以下是具体的命令:

mqadmin consumerProgress -n {namesrvAddr} -g {consumerGroup}

在这个命令中:

  • {namesrvAddr} 是你的NameServer地址,格式为{hostname}:{port}
  • {consumerGroup} 是你想要查询的消费者组的名称。

这个命令会返回你指定的消费者组的消费进度,其中包括消费者组当前消费的队列、消费者组当前的消费偏移量以及队列的最新偏移量。消息堆积量可以通过最新偏移量减去消费偏移量得到。

请注意,你需要在运行mqadmin命令的机器上设置ROCKETMQ_HOME环境变量,并确保这个环境变量指向你的RocketMQ安装目录。同时,你需要将$ROCKETMQ_HOME/bin添加到你的PATH环境变量中,以便系统能找到mqadmin命令。


RocketMQ的mqadmin工具并不直接提供获取消息处理延迟时间的功能。消息处理延迟时间通常指的是消息从发送到被成功消费的时间。由于这个时间取决于多个因素,包括网络延迟、消费者处理速度等,因此RocketMQ并没有提供直接获取这个时间的接口。

然而,你可以使用mqadmin工具的statsAll命令来获取一些和消息处理延迟相关的统计信息,包括消息发送和消费的TPS(每秒事务数)、消息的发送和消费的延迟等。以下是具体的命令:

mqadmin statsAll -n {namesrvAddr}

在这个命令中,{namesrvAddr}是你的NameServer地址,格式为{hostname}:{port}

这个命令会返回Broker、Topic以及Consumer Group的统计信息。你可以从这些信息中获取消息的发送和消费的TPS,以及消息的发送和消费的平均延迟。请注意,这个命令返回的延迟是从消息发送到消息存储的延迟,而不是消息处理的延迟。

要获取消息处理的延迟,你可能需要在你的应用程序中自己记录消息发送和消费的时间,然后计算出消息处理的延迟。例如,你可以在消息中添加一个时间戳字段来记录消息的发送时间,然后在消费消息时获取当前时间并减去消息的发送时间,得到消息处理的延迟。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/718497.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【虚拟化】虚拟机xml文件解析

文章目录 虚拟机xml文件解析nameuuidmemory/currentMemoryvcpubootcpuon_poweroffon_rebooton_crashdiskinterfaceinputgraphics 补充说明1.磁盘总线类型 虚拟机xml文件解析 name name # 虚拟机名称&#xff0c;具有唯一性&#xff0c;不可与已建立的虚拟机重复uuid uuid #虚…

MoblieNetV1、V2、V3、ViT四种Moblie模型的分析对比

1、MoblieNetV1 2017年提出&#xff0c;论文地址为&#xff1a;https://arxiv.org/pdf/1704.04861.pdf 1.1 相关知识 提到了标准卷积、深度可分卷积、点卷积&#xff0c;并分析了不同卷积结构的计算量&#xff0c;&#xff08;假设 D k D_k Dk​为ksize&#xff0c;M为卷积的…

在VMware Workstation虚拟机上安装centos服务,并使用xshell连接centos服务。

一、安装VMware Workstation 可前往http://www.kkx.net/soft/22239.html&#xff0c;附带有下载链接&#xff0c;和对应的破解码。 二、下载centos .iso格式文件 前往https://mirrors.aliyun.com/centos/7/isos/x86_64/下载。 以下两个&#xff0c;选择哪一个都行。 记得要下…

【MySQL进阶篇】学习笔记

文章目录 MySQL进阶学习前言1、存储引擎1.1 MySQL体系结构概览1.2 存储引擎介绍1.3 常见存储引擎的特点1.3.1 InnoDB的特点1.3.2 MyISAM1.3.3 Memory1.3.4 总结 2、索引2.1 索引介绍2.2 索引的结构2.2.1 前置知识2.2.2 索引结构的种类 2.3 索引的分类2.4 索引的使用2.4.1 索引的…

Vue3 通过ref获取 el-dialog 内容(组件)中的dom元素的问题

问题描述&#xff1a; 项目中&#xff0c;使用el-dialog组件展示内容&#xff0c;内容是自己封装的一个组件&#xff0c;组件中通过ref获取dom元素然后进行绘制echarts图形的。 问题是&#xff1a;在弹出el-dialog组件后&#xff0c;echarts图形没有渲染出来。刚开始还以为是自…

ArcPy学习心得系列(5)遥感数据中值滤波与均值滤波实现方法(不计入NoDATA)

在数据处理与应用的过程中,我们难免会遇到一些低质量的遥感数据,低质量遥感数据一般是由于天气因素导致的,在云量较多时,卫星传感器所采集到的地面信息被云层所遮挡,导致遥感图像成像过程中产生了较多噪声,对遥感数据的精确度造成了一定影响,如果不解决这些数据中的噪声…

超详细IDEA连接本地数据库以及使用教程

文章目录 前言一、IDEA连接本地数据库二、IDEA使用数据库操作 前言 IDEA的项目要想连接本地数据库&#xff0c;前提就是本地已经配置有数据库&#xff0c;并且可以使用 附Windows10 安装配置数据库教程: 超详细MySQL(免安装版)安装与配置教程 一、IDEA连接本地数据库 点击IDE…

什么是视频|孪生视频孪生,打造实时实景数字孪生应用

元宇宙概念下&#xff0c;虚拟世界和虚拟空间的讨论日益增多&#xff0c;其相关技术的应用和发展也备受关注。在众多技术手段中&#xff0c;数字孪生技术以虚实结合为主&#xff0c;架起虚拟世界与现实世界之间沟通的桥梁。 视频孪生更侧重从真实角度出发&#xff0c;打造实时…

【大数据之Hive】十九、Hive之文件格式和压缩

1 Hadoop压缩概述 Hive中的压缩算法与Hadoop中的压缩算法保持一致&#xff0c;可以把Hive当作Hadoop的一个客户端。 【大数据之Hadoop】十八、MapReduce之压缩 2 Hive文件格式 Hive表中常用的数据存储格式&#xff1a;text file&#xff08;行式存储&#xff09;、orc&#x…

Vue3 ElementPlus写的导航栏

Vue3 ElementPlus Vuex Router写的导航栏&#xff0c;效果如图&#xff1a; 导航条路径那里是自动的。 链接: https://pan.baidu.com/s/1pjqgR9QGbB2ZYIECPwNIoQ?pwdk5ew 提取码: k5ew 复制这段内容后打开百度网盘手机App&#xff0c;操作更方便哦

Android进阶之路 - 背景阴影、阴影背景

不知道你是不是也经常听到这些话&#xff1a;你这个没有阴影效果&#xff1b;你这个阴影太浓了&#xff1b;你这个阴影太粗了&#xff1b;你这个阴影太实了&#xff1b;你这个阴影颜色也不对&#xff0c;你这个阴影… 在正式开发中&#xff0c;临近上线前有个环节叫UI验收&…

Vector - CAPL - 数据库和CAPL_02

DBLookup 动态读取数据库中的信息 //Transmitter 属性以及数据库属性只能通过 DBLookup 动态读取。 //返回数据库中存储的 DLC on message * {int myAttributeValue;myAttributeValue DBLookup(this).MyAttribute;write(this.Transmitter); // compiler errorwrite(DBLookup(…

AR试穿试戴相关SDK或平台

1.火山引擎 链接 咨询过平台收费比较高几十万一年而且还是起步价 2.Geenee 链接 geenee在衣服、裤子、头饰以及鞋子方面可以实现试穿。 3.Wanna 链接 Wanna 试衣、试包、试鞋及手表都可以&#xff0c;我试过鞋子的试穿效果还不错 4.DeepAR …

sqlite维护命令复习学习

前面已经看了一些sqlite命令&#xff0c;例如查看表名&#xff0c;查看表结构等&#xff1b;下面继续看一下&#xff1b; 查看全部表名&#xff1b; 查看单个或全部的表结构&#xff1b; 输出表结构和数据&#xff1b; 使用.output 把查询结果定向到1.txt&#xff1b; 重新定向…

Java设计模式系列--观察者模式写法2:JDK

原文网址&#xff1a;Java设计模式系列--观察者模式写法2&#xff1a;JDK_IT利刃出鞘的博客-CSDN博客 简介 说明 本文用示例介绍观察者模式的一种写法&#xff1a;JDK。 JDK的观察者模式简介 在 Java 中&#xff0c;java.util.Observable 类和 java.util.Observer 接口定义…

Elsevier: Expert Systems With Applications 经验分享

目录 序时间线投稿返稿录用模板下载链接 序 这是一篇Elsevier旗下Expert Systems With Applications(ESWA)期刊的投稿经验分享。虽然是ESWA&#xff0c;但对于Elsevier旗下的其它期刊也适用&#xff0c;他们都可以用一套模板。 需要注意的是不同期刊会有一些特别的要求&#…

13 直接存储器访问DMA(基于STM32HAL库)

目录 DMA-直接存储器访问控制器 DMA概览 DMA的作用 DMA框图 DMA外设要点概括 DMA功能对比 STMF10x DMA具体内容 DMA主要特性 DMA中断 DMA请求映像 DMA的使用步骤 HAL库中的DMA功能实例 句柄结构体介绍&#xff08;以DMA为例&#xff09; 外设初始化结构体介绍 具体…

多元回归预测 | Matlab基于粒子群算法优化深度置信网络(PSO-DBN)的数据回归预测,matlab代码回归预测,多变量输入模型

文章目录 效果一览文章概述部分源码参考资料效果一览 文章概述 多元回归预测 | Matlab基于基于粒子群算法优化深度置信网络(PSO-DBN)的数据回归预测,matlab代码回归预测,多变量输入模型,多变量输入模型 评价

聊聊不同集群的微服务如何通过feign调用

前言 之前业务部门的某项目微服务调用关系如下图 后因业务改造需要&#xff0c;该项目需要将服务A部署到另外一个集群&#xff0c;但服务A仍然需要能调用到服务B&#xff0c;调用关系如下图 之前调用方式是负责服务B的开发团队提供相应的feign客户端包给到服务A开发团队&…

三种Linux内核代码在线阅读工具

记录一下 1 . 可在线阅读uboot&#xff0c;kernel&#xff0c;busybox(rootfs)&#xff0c;可搜索字符串&#xff0c;函数跳 https://lxr.missinglinkelectronics.com/ 界面如下&#xff1a; 2. 显示界面跟代码编辑器很像&#xff0c;同样可以函数跳转 https://elixir.boot…