RocketMQ 消息轨迹 - 设计篇

• 消息轨迹数据存储在哪？

1、消息轨迹数据格式

RocketMQ4.5 版本消息轨迹主要记录如下信息：

【一线大厂Java面试题解析+后端开发学习笔记+最新架构讲解视频+实战项目源码讲义】
浏览器打开：qq.cn.hn/FTf 免费领取

traceType

跟踪类型，可选值：Pub(消息发送)、SubBefore(消息拉取到客户端，执行业务定义的消费逻辑之前)、SubAfter(消费后)。

• timeStamp

当前时间戳。

• regionId

broker 所在的区域 ID，取自 BrokerConfig#regionId。

• groupName

组名称，traceType 为 Pub 时为生产者组的名称；如果 traceType 为 subBefore 或 subAfter 时为消费组名称。

• requestId

traceType 为 subBefore、subAfter 时使用，消费端的请求 Id。

• topic

消息主题。

• msgId

消息唯一 ID。

• tags

消息 tag。

• keys

消息索引 key，根据该 key 可快速检索消息。

• storeHost

跟踪类型为 PUB 时为存储该消息的 Broker 服务器 IP；跟踪类型为 subBefore、subAfter 时为消费者 IP。

• bodyLength

消息体的长度。

• costTime

耗时。

• msgType

消息的类型，可选值：Normal_Msg(普通消息),Trans_Msg_Half(预提交消息),Trans_msg_Commit(提交消息),Delay_Msg(延迟消息)。

• offsetMsgId

消息偏移量 ID,该 ID 中包含了 broker 的 ip 以及偏移量。

• success

是发送成功。

• contextCode

消费状态码，可选值：SUCCESS,TIME_OUT,EXCEPTION,RETURNNULL,FAILED。

2、记录消息轨迹

消息中间件的两大核心主题：消息发送、消息消费，其核心载体就是消息，消息轨迹（消息的流转）主要是记录消息是何时发送到哪台 Broker，发送耗时多少时间，在什么是被哪个消费者消费。记录消息的轨迹主要是集中在消息发送前后、消息消费前后，可以通过 RokcetMQ 的 Hook 机制。通过如下两个接口来定义钩子函数。

通过实行上述两个接口，可以实现在消息发送、消息消费前后记录消息轨迹，为了不明显增加消息发送与消息消费的时延，记录消息轨迹最好使用异步发送模式。

3、如何存储消息轨迹数据

消息轨迹需要存储什么消息以及在什么时候记录消息轨迹的问题都以及解决，那接下来就得思考将消息轨迹存储在哪里？存储在数据库中或其他媒介中，都会加重消息中间件，使其依赖外部组件，最佳的选择还是存储在 Broker 服务器中，将消息轨迹数据也当成一条消息存储到 Broker 服务器。

既然把消息轨迹当成消息存储在 Broker 服务器，那存储消息轨迹的 Topic 如何确定呢？RocketMQ 提供了两种方法来定义消息轨迹的 Topic。