美文网首页RocketMQ系列
RocketMQ系列(六):消息轨迹

RocketMQ系列(六):消息轨迹

作者: 范柏柏 | 来源:发表于2020-06-07 15:59 被阅读0次

    消息轨迹是什么

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

    所以就两个核心

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

    消息轨迹日志的格式(记录什么)

    • 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的负载压力

    相关文章

      网友评论

        本文标题:RocketMQ系列(六):消息轨迹

        本文链接:https://www.haomeiwen.com/subject/htpctktx.html