1.发送测试消息
bin/mqadmin checkMsgSendRT -n 192.168.x.x:9876 -t topic_online_test -s 1024
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0Broker Name                      QID  #Send Result            RTbroker-a                          0     true                    314broker-a                          1     true                    0broker-a                          2     true                    0
broker-a                          3     true                    0
broker-b                          0     true                    2
broker-b                          1     true                    1
broker-b                          2     true                    1
broker-b                          3     true                    0
broker-a                          0     true                    1
broker-a                          1     true                    0
broker-a                          2     true                    0
broker-a                          3     true                    1
broker-b                          0     true                    4
-t topic topic name
-a amount message amout | default 100
-s size message size | default 128 Byte
2.print message by queue
bin/mqadmin printMsgByQueue -n 192.168.1.x:9876 -b 192.168.1.x -i 0
3.打印topic中的信息
bin/mqadmin printMsg -n 192.168.1.x:9876 -t SCANRECORD
"t", "topic", true, "topic name"
"c", "charsetName ", true, "CharsetName(eg: UTF-8,GBK)"
"s", "subExpression ", true, "Subscribe Expression(eg: TagA || TagB)"
"b", "beginTimestamp ", true,  Begin timestamp[currentTimeMillis|yyyy-MM-dd#HH:mm:ss:SSS]
"e", "endTimestamp ", true, End timestamp[currentTimeMillis|yyyy-MM-dd#HH:mm:ss:SSS]
"d", "printBody ", true,"print body"
MSGID: C0A81F8166832F2C9B1953831616FB45 MessageExt [queueId=20, storeSize=686, queueOffset=35052080, sysFlag=0, bornTimestamp=1539724299798, bornHost=/192.168.x.x:29781, storeTimestamp=1539724299179, storeHost=/192.168.x.x:10911, msgId=C0A801B400002A9F000005F308F9B3A5, commitLogOffset=6541385773989, bodyCRC=1167936923, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=SCANRECORD, flag=0, properties={MIN_OFFSET=35046369, MAX_OFFSET=40298522, KEYS=1dd04932-b7d9-43ee-8b31-39d16dd043d4, UNIQ_KEY=C0A81F8166832F2C9B1953831616FB45, WAIT=true, TAGS=2}, body=484]] BODY: {"billCode":"640010206680","blReturnBillId":0,"blUntreadPieceId":0,"clazz":"2","dataFrom":"2","dispatchId":0,"ownerBagNo":"3783585805","pdaCode":"S50117101164","piece":1,"preOrNexStaId":14761,"preOrNextStation":"\u6F6E\u6C55\u4E2D\u5FC3","prepProvinceId":440000,"registerDate":1539724298000,"scanDate":1539724241000,"scanMan":"\u9648\u4E9A\u5973","scanManCode":"020019.0865","scanProvinceId":440000,"scanSite":"\u5E7F\u5DDE\u5E7F\u56ED","scanSiteId":1051037,"scanType":"\u53D1\u4EF6"}
4.通过messageId查询消息
bin/mqadmin queryMsgById -n 192.168.x.x:9876  -i C0A801B400002A9F000005F308F9B3A5
"i", "msgId", true, "Message Id"
"consumerGroup", true, "consumer group name"
"clientId", true, "The consumer's client id"
"sendMessage", true, "resend message"
"unitName", true, "unit name"
bin/mqadmin queryMsgById -n 192.168.x.x:9876  -i C0A801B400002A9F000005F308F9B3A5
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
OffsetID:            C0A801B400002A9F000005F308F9B3A5
OffsetID:            C0A801B400002A9F000005F308F9B3A5
Topic:               SCANRECORD
Tags:                [2]
Keys:                [1dd04932-b7d9-43ee-8b31-39d16dd043d4]
Queue ID:            20
Queue Offset:        35052080
CommitLog Offset:    6541385773989
Reconsume Times:     0
Born Timestamp:      2018-10-17 05:11:39,798
Store Timestamp:     2018-10-17 05:11:39,179
Born Host:           192.168.31.129:29781
Store Host:          192.168.1.180:10911
System Flag:         0
Properties:          {KEYS=1dd04932-b7d9-43ee-8b31-39d16dd043d4, UNIQ_KEY=C0A81F8166832F2C9B1953831616FB45, WAIT=true, TAGS=2}
Message Body Path:   /tmp/rocketmq/msgbodys/C0A81F8166832F2C9B1953831616FB45
MessageTrack [consumerGroup=ZtoSignGroup, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=newOpenPartnerDeadlineJob, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=smartidivision-scanrecord-dis, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=PanguRecordGroup, trackType=CONSUMED, exceptionDesc=null]MessageTrack [consumerGroup=code-send-consumer, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=shenZhouOneSiteKpiConsumer, trackType=CONSUMED, exceptionDesc=null]MessageTrack [consumerGroup=SortComplementConsumer, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=tf_wonder_waybill_center_scanrecord, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=dpmComScanRecordConsumer, trackType=UNKNOWN, exceptionDesc=org.apache.rocketmq.client.exception.MQClientException: CODE: 17  DESC: No topic route info in name server for the topic: %RETRY%dpmComScanRecordConsumer
See [http://rocketmq.apache.org/docs/faq/](http://rocketmq.apache.org/docs/faq/) for further details., org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1212)]MessageTrack
5.根据key查询存储消息
bin/mqadmin queryMsgByKey -n 192.168.x.x:9876 -t SCANRECORD -k 1dd04932-b7d9-43ee-8b31-39d16dd043d4
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
Message ID                                        QID                                  Offset
C0A81F8166832F2C9B1953831616FB45                     20                                 35052080
6.根据offset查询储存消息
bin/mqadmin  queryMsgByOffset -n 192.168.x.x:9876 -t SCANRECORD -b broker-a -i 20 -o 35052080
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
OffsetID:            C0A801B400002A9F000005F308F9B3A5
OffsetID:            C0A801B400002A9F000005F308F9B3A5
Topic:               SCANRECORD
Tags:                [2]
Keys:                [1dd04932-b7d9-43ee-8b31-39d16dd043d4]
Queue ID:            20
Queue Offset:        35052080
CommitLog Offset:    6541385773989
Reconsume Times:     0
Born Timestamp:      2018-10-17 05:11:39,798
Store Timestamp:     2018-10-17 05:11:39,179
Born Host:           192.168.31.129:29781
Store Host:          192.168.1.180:10911
System Flag:         0
Properties:          {MIN_OFFSET=35046369, MAX_OFFSET=40342481, KEYS=1dd04932-b7d9-43ee-8b31-39d16dd043d4, UNIQ_KEY=C0A81F8166832F2C9B1953831616FB45, WAIT=true, TAGS=2}
Message Body Path:   /tmp/rocketmq/msgbodys/C0A81F8166832F2C9B1953831616FB45
MessageTrack [consumerGroup=ZtoSignGroup, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=newOpenPartnerDeadlineJob, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=smartidivision-scanrecord-dis, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=PanguRecordGroup, trackType=CONSUMED, exceptionDesc=null]MessageTrack [consumerGroup=code-send-consumer, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=shenZhouOneSiteKpiConsumer, trackType=CONSUMED, exceptionDesc=null]MessageTrack [consumerGroup=SortComplementConsumer, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=tf_wonder_waybill_center_scanrecord, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=dpmComScanRecordConsumer, trackType=UNKNOWN, exceptionDesc=org.apache.rocketmq.client.exception.MQClientException: CODE: 17  DESC: No topic route info in name server for the topic: %RETRY%dpmComScanRecordConsumer
See [http://rocketmq.apache.org/docs/faq/](http://rocketmq.apache.org/docs/faq/) for further details., org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1212)]MessageTrack [
"t", "topic", true, "topic name"
"b", "brokerName", true, "Broker Name"
"i", "queueId", true, "Queue Id"
"o", "offset", true, "Queue Offset"
7.通过UniqueKey查询消息内容
bin/mqadmin queryMsgByUniqueKey -n 192.168.x.x:9876  -t SCANRECORD -i C0A801B400002A9F000005F308F9B3A5
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
Topic:               SCANRECORD
Tags:                [2]
Keys:                [1dd04932-b7d9-43ee-8b31-39d16dd043d4]
Queue ID:            20
Queue Offset:        35052080
CommitLog Offset:    6541385773989
Reconsume Times:     0
Born Timestamp:      2018-10-17 05:11:39,798
Store Timestamp:     2018-10-17 05:11:39,179
Born Host:           192.168.31.129:29781
Store Host:          192.168.1.180:10911
System Flag:         0
Properties:          {KEYS=1dd04932-b7d9-43ee-8b31-39d16dd043d4, UNIQ_KEY=C0A81F8166832F2C9B1953831616FB45, WAIT=true, TAGS=2}
Message Body Path:   /tmp/rocketmq/msgbodys/C0A81F8166832F2C9B1953831616FB45
MessageTrack [consumerGroup=ZtoSignGroup, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=newOpenPartnerDeadlineJob, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=smartidivision-scanrecord-dis, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=PanguRecordGroup, trackType=CONSUMED, exceptionDesc=null]MessageTrack [consumerGroup=code-send-consumer, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=shenZhouOneSiteKpiConsumer, trackType=CONSUMED, exceptionDesc=null]MessageTrack [consumerGroup=SortComplementConsumer, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=tf_wonder_waybill_center_scanrecord, trackType=CONSUMED_BUT_FILTERED, exceptionDesc=null]MessageTrack [consumerGroup=dpmComScanRecordConsumer, trackType=UNKNOWN, exceptionDesc=org.apache.rocketmq.client.exception.MQClientException: CODE: 17  DESC: No topic route info in name server for the topic: %RETRY%dpmComScanRecordConsumer
See [http://rocketmq.apache.org/docs/faq/](http://rocketmq.apache.org/docs/faq/) for further details., org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1212)]MessageTrack
"i", "msgId", true, "Message Id"
"g", "consumerGroup", true, "consumer group name"
"d", "clientId", true, "The consumer's client id"
"t", "topic", true, "The topic of msg"

RocketMQ Message相关命令【实战笔记】相关推荐

  1. OpenSSL 之 RSA 相关命令学习笔记

    2019独角兽企业重金招聘Python工程师标准>>> 作者: Angus.Fenying <i.am.x.fenying@gmail.com> 日期: 2016-11- ...

  2. Redis 笔记（02）— keys 键相关命令（查询数据库key数量、判断key是否存在、指定key过期时间、查看key类型、查看key剩余秒数、选择数据库、删除key、删除数据库）

    1. keys 键相关命令 命令 说明 dbsize 返回当前数据路的key数量 exists key 测试指定key是否存在 expire key seconds 为key指定过期时间 type k ...

  3. Udacity机器人软件工程师课程笔记（八）-ROS Turtlesim 包的相关命令

    Turtlesim 包的相关命令 这个部分包含五个子主题,分别是 列出所有活动节点 列出所有主题 获取有关主题的信息 显示消息信息 实时回应消息 1.列出所有的活动节点 为了获取所用的活动且向ROS ...

  4. [运维笔记] - (命令).Windows server常用网络相关命令

    [运维] - Windows server网络相关命令 注:内容通过Microsoft文档整体和翻译,仅用于便于维护工作时查询. 资料翻译者:jcLee95 邮箱:291148484@163.com ...

  5. 【笔记】SSH服务：基本概述、相关命令“ssh、scp、sftp”、验证方式、场景实践、安全优化

    SSH服务 SSH基本概述 SSH是一个安全协议,在进行数据传输时,会对数据包进行加密处理,加密后在进行数据传输.确保了数据传输安全.那SSH服务主要功能有哪些呢? 1.提供远程连接服务器的服务 2. ...

  6. LInux-文本处理相关命令笔记

    目录 文本处理相关命令 正则表达式 介绍 BRE和ERE seq xargs 常用选项 常用使用方法 uniq 介绍 常见选项 常见使用方法 实例 tr 常用选项 常见使用方法 能转换的原因 grep ...

  7. Unix C学习笔记10 进程的概念，相关命令，父子孤尸，进程标识，创建子进程

    进程的概念 相关命令 pstree显示bash进程 ps显示进程,以快照方式,显示某一瞬间进程状态 ps aux top显示实时进程信息,会动态变化 父子孤尸 进程标识 会重用,但不会立马重用PID ...

  8. RabbitMQ实战笔记

    RabbitMQ实战笔记 1 MQ引言 1.1 中间件技术及架构的概述 1.2 什么是MQ 1.3 为什么要用MQ 1.4 MQ的分类 1.5 MQ的选择 2 RabbitMQ 的引言 2.1 Rab ...

  9. 4. Python脚本学习实战笔记四 新闻聚合

    4. Python脚本学习实战笔记四 新闻聚合 本篇名言:"人言纷杂,保持自我:工作勤奋,娱乐适度:对待朋友,不玩心术:处理事务,不躁不怒:生活讲究,量入为出:知足常乐,一生幸福!" ...

  10. python爬虫从入门到实战笔记——第四章Scrapy框架

    推荐阅读: python爬虫从入门到实战笔记--第一章爬虫原理和数据爬取 python爬虫从入门到实战笔记--第二章非结构化数据和结构化数据的提取 python爬虫从入门到实战笔记--第三章动态HTM ...

最新文章

  1. 如何通过一行代码下载B站视频？
  2. Java中实现多线程关键词整理
  3. crontab 知识查阅
  4. 十 Appium环境搭建(Windows版)
  5. python属性访问顺序_Python 对象属性的访问
  6. 手机网页里的模态对话框
  7. 在windows server 2008 R2上运行disk cleanup
  8. Vue组件化开发 - 非常详细，不要错过哦~
  9. python中file和open_Python中的file和open简述
  10. 使用加密签名时遇到的一个问题
  11. LeetCode刷题——209. 长度最小的子数组
  12. assert()和panic()
  13. oracle sql 实现三张表左连接查询
  14. 基于Wiki的知识共享平台模型架构
  15. GDKOI2018终焉记WC2018并列记
  16. 前方高能！阿里云双11拼团百团大战已开启！
  17. postgresql查看数据库及数据表占用空间
  18. 初学者应从文件目录结构理解import的过程，并创建自已的代码库
  19. x86 单线并发多拨_最近好多人问单线多拨，傻瓜式openwrt单线多拨叠加速率教程...
  20. Chrome浏览器默认全屏启动（非--kiosk模式）

热门文章

  1. macbook卡在进度条开不了机_mac开机卡在进度条的问题
  2. Python地学分析 — GDAL通过矢量裁剪遥感图像
  3. python转换word到html,Python实现批量将word转html并将html内容发布至网站的方法
  4. 一个普通前端的2022年终总结：多病的一年
  5. [读书笔记] 蔡康永的说话之道
  6. Swagger3/thinkphp6教程
  7. STM32L4超低功耗特性概述
  8. C语言：设备管理系统
  9. 政府采购和招标投标常见问题：评标的依据是什么？
  10. iOS开发-Tom猫