场景描述
消息轨迹记录了一条消息从生产端到消息队列RocketMQ服务端,再到消费端的整个过程,包括各阶段的时间、执行状态等。
使用说明
客户端SDK默认不开启消息轨迹功能,需要在消息收发时主动开启消息轨迹,以Java为例,如下所示:
- 生产者启用消息轨迹:
DefaultMQProducer producer =new
DefaultMQProducer("ProducerGroupName",new
AclClientRPCHook(newSessionCredentials("控制台角色AK","控制台角色CK")),true,null);
- 消费者启用消息轨迹:
DefaultMQPushConsumer consumer =new
DefaultMQPushConsumer("ConsumerGroupName",new
AclClientRPCHook(
new SessionCredentials(
"控制台角色AK",
"控制台角色CK")
),newAllocateMessageQueueAveragely(),true,null);
消息轨迹的查询方式
- 天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。
- 登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。
- 进入实例列表,点击【管理】按钮进入管理菜单。
- 进入消息查询菜单,支持三种查询消息轨迹的方式:按key,按ID,按偏移量;
- 根据查询结果,查看消息轨迹。