1.rocketmq的消息发送时,producer客户端生成msgId(通过ip+进程+自增值+当前与系统启动时间差值),有另外的一个叫法uniqId
方法入口:MessageClientIDSetter.createUniqID()
通过mqadmin查询时需要通过msgid+对应topic
2.OffsetMsgId:由broker服务端生成(服务端ip地址+服务端消息的物理分区偏移量来达到唯一值id),通过该id可以直接定位消息内容,如果为mqadmin查询,不需要指定topic
3.消费者如果消费失败,调用sendMessageBack方法将消息发给broker,重新消费时的消息msgId不变,offsetMsgId会变(因为新消息储存的地址已变),uniq_key属性保存原消息msgId
4.rocketmq-console 控制台查询,首先将msgId 用 queryMsgById 该命令去查,如果报错,则当成 uniqID(全局ID)+topic查询
版权声明:本文为songzhifengnihao原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。