企业官网建设流程全解析

视觉做的比较好的国外网站,网站地图设计,wordpress 图片宽度,深圳系统开发高端网站建设目录标题RocketMQ mqadmin 排查与模拟一、环境背景说明二、核心概念速记三、查看 Topic 是否有生产四、查看 Topic 的生产 / 消费速率#xff08;最推荐#xff09;五、如何查看 ConsumerGroup#xff08;重点#xff09;1️⃣ 查看当前所有 ConsumerGroup2️⃣ 查看某个 C…目录标题RocketMQ mqadmin 排查与模拟一、环境背景说明二、核心概念速记三、查看 Topic 是否有生产四、查看 Topic 的生产 / 消费速率最推荐五、如何查看 ConsumerGroup重点1️⃣ 查看当前所有 ConsumerGroup2️⃣ 查看某个 ConsumerGroup 的消费情况3️⃣ 判断 Consumer 是否在线六、mqadmin 模拟生产安全七、mqadmin 模拟消费⚠️慎用只读不推 offset安全推进 offset有风险八、mqadmin 能做 / 不能做的事✅ 能做❌ 不能做九、标准排障流程推荐记住十、运维重要提醒十一、常用参数说明十二、官方文档链接 核心文档常用命令快速参考十三、一句话总结RocketMQ mqadmin 排查与模拟适用场景不清楚某个 Topic 是否有生产 / 消费不知道 ConsumerGroup 是什么mqadmin 命令部分不可用版本差异需要用 mqadmin 做最小化排障、验证链路一、环境背景说明当前环境使用的 mqadmin 路径/root/rocketmq/broker/bin/mqadmin该 mqadmin 特点✅ 功能较完整✅ 支持consumeMessage可模拟消费❌ 不支持consumerList/topicConsumeStatus属于定制 / 增强版 mqadmin命令名与 Apache 官方新版略有差异二、核心概念速记概念说明Topic生产侧逻辑概念消息写入ConsumerGroup消费侧逻辑概念offset 归属#InTPSTopic 生产速率每秒写入消息数#OutTPSTopic 消费速率每秒消费消息数#Accumulation消息堆积量BrokerOffset - ConsumerOffset⚠️ Topic 与 ConsumerGroup不是一对一关系三、查看 Topic 是否有生产mqadmin topicStatus-nNameSrv-tTopic示例输出#Broker Name #QID #Min Offset #Max Offset #Last Updated rocketmq-ddffdb1a-0 0 0 22 2025-12-31 07:04:47,308关注字段#MaxOffset判断逻辑MaxOffset 持续增长 → 有生产MaxOffset 不变 → 无生产 / 生产异常四、查看 Topic 的生产 / 消费速率最推荐mqadmin statsAll-nNameSrv|grepTopic示例输出#Topic #Consumer Group #Accumulation #InTPS #OutTPS #InMsg24Hour #OutMsg24Hour bpx-topic 0 0.00 0.00 20 NO_CONSUMER字段含义#InTPS生产速率msg/s#OutTPS消费速率msg/s#Accumulation消息堆积量判断#InTPS #OutTPS → 正在堆积#InTPS ≈ #OutTPS → 消费跟得上NO_CONSUMER→ 无消费者订阅该 Topic五、如何查看 ConsumerGroup重点1️⃣ 查看当前所有 ConsumerGroupmqadmin consumerProgress-nNameSrv示例输出#Group #Count #Version #Type #Model #TPS #Diff Total bpx-consumer-group 0 OFFLINE 0 0 TOOLS_CONSUMER 3 V4_9_4 PULL 0 0说明GroupName 即 ConsumerGroup可同时看到堆积量#Diff Total、消费速率#TPSOFFLINE 表示该 Consumer 当前未在线2️⃣ 查看某个 ConsumerGroup 的消费情况mqadmin consumerProgress-nNameSrv-gConsumerGroup用途判断该 Group 是否堆积判断消费是否正常推进3️⃣ 判断 Consumer 是否在线mqadmin consumerConnection-nNameSrv-gConsumerGroup示例输出在线#ClientId #ClientAddr #Language #Version 245.0.1.220consumer-xxxSTREAM 245.0.1.220:40726 JAVA V4_9_4判断有客户端信息 → Consumer 正常在线无输出 / 报错 → Consumer 未启动或异常六、mqadmin 模拟生产安全mqadmin sendMessage\-nNameSrv\-tTopic\-pmqadmin test message示例输出#Broker Name #QID #Send Result #MsgId rocketmq-ddffdb1a-0 0 SEND_OK F500033F033A3AF49F1C9C0758D10000用途验证 Topic 是否可写验证 Broker 是否正常验证消费链路是否能收到消息七、mqadmin 模拟消费⚠️慎用⚠️风险说明不指定-g参数只读取消息不推进 offset相对安全指定-g ConsumerGroup参数会推进该 Group 的 offset生产环境慎用只读不推 offset安全mqadmin consumeMessage\-nNameSrv\-tTopic\-c10推进 offset有风险mqadmin consumeMessage\-nNameSrv\-tTopic\-gConsumerGroup\-c10说明属于运维级假消费适合排障 / 验证不等同真实业务消费建议先查看帮助mqadmin help consumeMessage八、mqadmin 能做 / 不能做的事✅ 能做模拟生产消息拉取消息假消费查看 Topic 状态查看 TPS / 堆积查询消息❌ 不能做模拟真实业务消费逻辑执行完整 rebalance精准压测消费者性能真实消费必须使用官方示例 Consumer自定义 SDK Consumer九、标准排障流程推荐记住1️⃣ topicStatus → 是否有生产 2️⃣ statsAll → 生产 / 消费 TPS 3️⃣ consumerProgress → 谁在消费 是否堆积 4️⃣ consumerConnection → Consumer 是否在线十、运维重要提醒⚠️生产环境慎用以下命令命令风险consumeMessage -g Group推进 offset可能丢失消息resetOffsetByTime重置 offset可能重复消费或跳过消息skipAccumulatedMessage跳过堆积消息造成业务消息丢失十一、常用参数说明参数含义-nNameServer 地址格式ip:port多个用分号分隔-tTopic 名称-gConsumerGroup 名称-bBroker 地址或名称-h查看帮助-c数量如消息条数十二、官方文档链接 核心文档文档链接Admin Tool 官方文档中文rocketmq.apache.org/zh/docs/deploymentOperations/02admintoolAdmin Tool 官方文档Englishrocketmq.apache.org/docs/deploymentOperations/02admintoolApache RocketMQ 官网rocketmq.apache.orgApache RocketMQ GitHubgithub.com/apache/rocketmq常用命令快速参考类别命令说明TopictopicList查看所有 TopicTopictopicStatus查看 Topic 消息队列 offsetTopictopicRoute查看 Topic 路由信息TopicstatsAll打印订阅关系、TPS、积累量等消费consumerProgress查看消费状态和进度消费consumerConnection查询 Consumer 网络连接消费consumerStatus查看消费者详细状态消息sendMessage发送一条测试消息消息consumeMessage消费消息可指定 offset消息queryMsgById根据 msgId 查询消息消息queryMsgByKey根据 Key 查询消息集群clusterList查看集群信息集群brokerStatus查看 Broker 运行状态十三、一句话总结在 RocketMQ 中Topic 看生产ConsumerGroup 看消费statsAll 看吞吐consumerProgress 看堆积这四点能解决 90% 的 RocketMQ 排障问题。Sources:Admin Tool - Apache RocketMQ