当一条消息从生产者发送到 TDMQ Pulsar 版服务端,再由消费者进行消费,TDMQ Pulsar 版会完整记录这条消息中间的流转过程,并以消息轨迹的形式呈现在控制台。
消息轨迹记录了消息从生产端到 TDMQ Pulsar 版 服务端,最后到消费端的整个过程,包括各阶段的时间(精确到微秒)、执行结果、生产者 IP、消费者 IP 等。
操作场景
当您需要排查以下问题时,就可以使用 TDMQ Pulsar 版控制台的消息查询功能,按照时间维度或者根据日志中查到的消息 ID,来查看具体某条消息的消息内容、消息参数和消息轨迹。
查看某条消息的具体内容,具体参数。
查看消息由哪个生产 IP 发送,是否发送成功,消息到服务端的具体时间。
查看消息是否已持久化。
查看消费由哪些消费者消费了,是否消费成功,消息确认消费的具体时间。
需要做分布式系统的性能分析,查看 MQ 对相关消息处理的时延。
查询限制
消息查询最多可以查询近3天的消息。
一次性最多可以查询65536条消息。
前提条件
已经参考 SDK 文档 部署好生产端和消费端服务,并在7天内有消息生产和消费。 操作步骤
2. 在消息查询页面,首先选择地域和环境,再选择需要查询的时间范围,如果您知道对应的消息 ID,也可以输入消息 ID 进行精准查询。
3. 单击查询,下方列表会展示所有查询到的结果并分页展示。
4. 找到您希望查看内容或参数的消息,单击操作列的查看详情,即可查看消息的基本信息、内容(消息体)以及参数。
5. 单击操作列的查看消息轨迹,或者在详情页单击 Tab 栏的消息轨迹,即可查看该消息的消息轨迹(详细说明请参考 消息轨迹查询结果说明)。 消息轨迹查询结果说明
消息轨迹查询出来的结果分为三段:消息生产、消息存储和消息消费。
消息生产
|
生产地址 | |
| TDMQ Pulsar 版服务端确认接收到消息的时间,精确到毫秒。 |
| 消息从生产端发送到 TDMQ Pulsar 版服务端的时间消耗,精确到微秒。 |
| 表示消息生产成功或失败,如果状态为失败一般是消息在发送过程中遇到了头部数据部分丢失,以上几个字段可能会为空值。 |
消息存储
|
存储时间 | 消息被持久化的时间(由于当前 TDMQ Pulsar 版统一为强一致模式,消息持久化后才会被确认,所以该时间与生产时间一致,高性能模式下此时间会与生产时间不一致)。 |
| 表示消息持久化成功或失败,如果状态为失败则表明消息未落盘成功,可能由于底层磁盘损坏或无多余容量导致,遇见此类情况需尽快提工单咨询。 |
消息消费
消息消费是以列表形式呈现的。TDMQ Pulsar 版支持多订阅模式,一条消息可能会被多个订阅中的多个消费者消费。
列表中展示的信息说明:
|
消费组名称 | |
| |
| 消费者回复确认信息(ACK)到 TDMQ Pulsar 版服务端,服务端接收到确认信息的时间。 |
| 消息从服务端投递到消费者,直到服务端收到消费者的确认信息(ACK)经过的时长,精确到微秒。 |
| 消费者消费成功或者失败,消费者如果返回了取消确认的信息(NACK),这个字段会显示失败。 |
本页内容是否解决了您的问题?