消息轨迹是什么
消息轨迹就是记录消息从发送到存储到消费都是谁发的存哪了谁消费的以及时间点,这一套轨迹的日志。
所以就两个核心
- 消息轨迹日志的格式(记录什么)
- 消息轨迹日志的存储(存在哪)
消息轨迹日志的格式(记录什么)
-
traceType
跟踪类型,可选值:- Pub(消息发送)
- SubBefore(消息拉取到客户端,执行消费之前)
- SubAfter(消息消费后)
-
timeStamp
当前时间戳 -
regionId
broker所在的区域ID,取自BrokerConfig#regionId -
groupName
组名称,traceType为Pub时为生产组的名称;如果traceType为subBefore或subAfter时为消费者组名称 -
requestId
消费端的请求id,traceType为subBefore或subAfter时使用 -
topic
消息主题 -
msgId
消息唯一id -
tags
消息tag -
keys
消息索引key,根据key可快速检索消息 -
storeHost
存储主机。traceType为Pub时为存储该消息的broker服务器ip;traceType为subBefore或subAfter时为消费者ip -
bodyLength
消息体长度 -
costTime
耗时 -
msgType
消息的类型,可选值:- Nomar_Msg 普通消息
- Trans_Msg_Half 预提交消息
- Trans_Msg_Commit 提交消息
- Delay_Msg 延迟消息
-
offsetMsgId
消息偏移量Id,该id包含了broker的ip以及偏移量 -
success
是否发送成功 -
contextCode
消费状态码,可选值- SUCCESS
- TIME_OUT
- EXCEPTION
- RETRRNNULL
- FAILED
消息轨迹日志的存储(存在哪)
如何记录(触发条件)
记录消息的轨迹主要是在
- 消息发送前后
- 消息消费前后
可以通过recketMq的hook机制,在触发点调用就好了
hook.png
存在哪
肯定是存在broker中。不可能引入其他存储中间件的。
所以最佳方案是:把消息轨迹也当一条消息存在broker队列中。
既然是消息,那topic如何确定呢??
-
系统默认的topic。默认是:RMQ_SYS_TRACE_TOPIC,队列个数是1.
-
自定义topic。不推荐使用。
为了避免消息轨迹的消息 和 正常消息 混在一起。官方建议,在broker集群中,新增加一台机器,只在这台机器上开启消息轨迹追踪,所有消息轨迹的消息就会只存在这台机器上。
两点好处:
- 数据隔离
- 不会增加原先业务broker的负载压力
网友评论