消息轨迹与说明

消息轨迹记录了消息从生产端到 TDMQ RocketMQ 版服务端，最后到消费端的整个过程，包括各阶段的时间（精确到微秒）、执行结果、生产者 IP、消费者 IP 等。

前提条件

• 您已经部署好生产端和消费端服务，并在3天内有消息生产和消费。

• 如果您使用的是 5.0 及以上版本的 gRPC 客户端进行消息的生产和消费，则无需在客户端另行开启轨迹开关。

• 如果您使用的是 4.x 版本的客户端，或者 5.0 以上版本的 Remoting 客户端，则需要在客户端来设置开启消息轨迹功能，具体设置示例如下：

• 更多关于客户端的说明请参见 社区客户端说明。
  生产者设置

    
  DefaultMQProducer producer = new DefaultMQProducer(namespace, groupName,
      // ACL权限
      new AclClientRPCHook(new SessionCredentials(AK, SK)), true, null);
  

  Push 消费者设置

    
  // 实例化消费者
  DefaultMQPushConsumer pushConsumer = new DefaultMQPushConsumer(NAMESPACE,groupName,
      new AclClientRPCHook(new SessionCredentials(AK, SK)),
      new AllocateMessageQueueAveragely(), true, null);
  

  Pull 消费者设置

    
  DefaultLitePullConsumer pullConsumer = new DefaultLitePullConsumer(NAMESPACE,groupName,
      new AclClientRPCHook(new SessionCredentials(AK, SK)));
  // 设置NameServer的地址
  pullConsumer.setNamesrvAddr(NAMESERVER);
  pullConsumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
  pullConsumer.setAutoCommit(false);
  pullConsumer.setEnableMsgTrace(true);
  pullConsumer.setCustomizedTraceTopic(null);
  

  Spring Boot Starter 接入（2.2.2版本及以上运行）

    
  DefaultLitePullConsumer pullConsumer = new DefaultLitePullConsumer(NAMESPACE,groupName,
      new AclClientRPCHook(new SessionCredentials(AK, SK)));
  // 设置NameServer的地址
  pullConsumer.setNamesrvAddr(NAMESERVER);
  pullConsumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
  pullConsumer.setAutoCommit(false);
  pullConsumer.setEnableMsgTrace(true);
  pullConsumer.setCustomizedTraceTopic(null);
  

消息轨迹查询结果说明

消息轨迹查询出来的结果分为三段：消息生产、消息存储和消息消费。

消息生产

消息存储

消息消费

消息消费是以列表形式呈现的，TDMQ RocketMQ 版支持集群消费和广播消费两种消费模式。
列表中展示的信息说明：

单击订阅名称左方的右三角，查看服务端每次推送消息的详情。