分布式消息服务-RocketMQ

消息轨迹

2024-07-02 02:28:35

消息轨迹记录了一条消息从生产端到消息队列RocketMQ服务端,再到消费端的整个过程,包括各阶段的时间、执行状态等。

使用说明:

客户端SDK默认不开启消息轨迹功能,需要在消息收发时主动开启消息轨迹,以Java为例,如下所示:

l  生产者启用消息轨迹:

DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName", new AclClientRPCHook(new SessionCredentials("控制台角色AK","控制台角色CK")), true, null);

l  消费者启用消息轨迹:

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroupName", new AclClientRPCHook(
                new SessionCredentials(
                        "控制台角色AK",
                        "控制台角色CK")
        ), new AllocateMessageQueueAveragely(), true, null);

消息轨迹的查询方式:

1.     天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。

2.     登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。

3.     进入实例列表,点击【管理】按钮进入管理菜单。

4.     进入消息查询菜单,支持三种查询消息轨迹的方式:按key,按ID,按偏移量;

5.     根据查询结果,查看消息轨迹。


wv3btXz1hOca