RocketMQ系列(六)：消息轨迹

消息轨迹是什么

消息轨迹就是记录消息从发送到存储到消费都是谁发的存哪了谁消费的以及时间点，这一套轨迹的日志。

所以就两个核心

• 消息轨迹日志的格式（记录什么）
• 消息轨迹日志的存储（存在哪）

消息轨迹日志的格式（记录什么）

• 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

消息轨迹日志的存储（存在哪）

如何记录（触发条件）

记录消息的轨迹主要是在

1. 消息发送前后
2. 消息消费前后

可以通过recketMq的hook机制，在触发点调用就好了

hook.png

存在哪

肯定是存在broker中。不可能引入其他存储中间件的。
所以最佳方案是：把消息轨迹也当一条消息存在broker队列中。

既然是消息，那topic如何确定呢？？

• 系统默认的topic。默认是：RMQ_SYS_TRACE_TOPIC，队列个数是1.

• 自定义topic。不推荐使用。

为了避免消息轨迹的消息 和 正常消息 混在一起。官方建议，在broker集群中，新增加一台机器，只在这台机器上开启消息轨迹追踪，所有消息轨迹的消息就会只存在这台机器上。

两点好处：

1. 数据隔离
2. 不会增加原先业务broker的负载压力