42 线上生产环境的RocketMQ集群进行消息轨迹的追踪

快来打我* 2022-09-01 09:22 89阅读 0赞

### 1. 消息轨迹 ###

RocketMQ支持在生产环境里查询一条消息的轨迹。

总得来说，我们可以知道一个消息是什么时候从哪个Producer发送出来的？它在Broker端是进入到了哪个Topic里去的？它在消费者层面是被哪个Consumer什么时候消费出来的？

### 2.消息轨迹的开启配置 ###

想要使用上面说到的RocketMQ支持的消息轨迹功能，主要配置过程如下：

首先需要在broker的配置文件里开启： traceTopicEnable=true 选项，此时就会开启消息轨迹追踪的功能。

开启以上配置项后，在启动该 broker 的时候会自动创建出来一个内部的 Topic ，也就是 **RMQ\_SYS\_TRACE\_TOPIC**，这个Topic就是用来存储所有的消息轨迹追踪的数据的。

接着，需要在发送消息的时候开启消息轨迹，，此时创建Producer的时候采用如下方式：

DefaultMQProducer producer = new DefaultMQProducer("TestProducerGroup",true);

以上代码中，构造函数中的第二个参数，就是 enableMsgTrace参数，它设值为 true，就是说可以对消息开启轨迹追踪。

在订阅消息的时候，对于Consumer也是同理的，在构造函数的第二个参数设置为true，就是开启了消费时候的轨迹追踪。

### 3.消息轨迹的原理 ###

在Broker、Producer、Consumer都配置好了轨迹追踪之后，Producer在发送消息的时候，就会上报这个消息的一些数据到内置的 RMQ\_SYS\_TRACE\_TOPIC里去，它会上报如下的一些数据：Producer的消息、发送消息的时间、消息是否发送成功、发送消息的耗时。

接着消息到Broker端之后，Broker端也会记录消息的轨迹数据，包括如下：消息存储的Topic、消息存储的位置、消息的 key、消息的tags。

最后当消息被消费到Consumer端之后，它也会上报一些轨迹数据到内置的 RMQ\_SYS\_TRACE\_TOPIC 里去，包括如下一些东西：Consumer的信息、投递消息的时间、这是第几轮投递消息、消息消费是否成功、消费这条消息的耗时。

### 4.查询消息轨迹 ###

在RocketMQ控制台里，在导航栏就有一个消息轨迹，在里面可以创建查询任务，可以根据messageId、message key或者Topic来查询，查询任务执行完毕之后，就可以看到消息轨迹的界面了。

发表评论取消回复

表情：

评论列表（有 0 条评论，89人围观）

还没有评论，来说两句吧...

相关阅读

相关 Nginx生产环境配置、elasticsearch生产环境配置、rocketmq生产环境配置（史上最全）

Nginx实现10万+并发在优化内核时，可以做的事情很多，不过，我们通常会根据业务特点来进行调整，当Nginx作为静态web内容服务器、反向代理或者提供压缩服务器的服务

男娘i/ 2024年03月23日 12:22/ 0 赞/ 129 阅读

相关 RocketMQ集群环境部署

文章目录 1. 准备环境 2. 修改主机名 3. 免密登录配置 4. 配置RocketMQ集群 5.

柔情只为你懂/ 2024年03月22日 18:11/ 0 赞/ 102 阅读

相关 RocketMQ消息轨迹产生的背景以及使用方式

背景最近在维护RocketMQ经常会出现这种问题消息发送方和接收方出现扯皮，消息发送方说我的消息已经发送成功了，消费方说我没接收到消息。两边各持己见，谁也不会说服谁。

Love The Way You Lie/ 2023年10月14日 21:36/ 0 赞/ 37 阅读

相关 Elasticsearch—生产环境集群核心配置

一. Elasticsearch相关配置 path.data 和 path.log 这两个配置的目录分别用来存放`索引数据`和`日志`，它们的默认路径

小鱼儿/ 2023年10月05日 14:28/ 0 赞/ 76 阅读

相关【RocketMQ】多方位测试开启消息追踪对集群性能的损耗

文章目录测试信息集群开启消息追踪客户端使用消息追踪生产者消费者客户端未使用消息

痛定思痛。/ 2023年10月03日 08:28/ 0 赞/ 8 阅读

相关 RocketMQ消息轨迹

开启消息轨迹 broker端 `traceTopicEnable`属性设置为true，默认值为false。设置为true，broker启动的时候会初始化存储轨迹数据

Myth丶恋晨/ 2023年01月10日 03:55/ 0 赞/ 162 阅读

相关 Elasticsearch—生产环境集群核心配置

一. Elasticsearch相关配置 path.data 和 path.log 这两个配置的目录分别用来存放`索引数据`和`日志`，它们的默认路径位于`$_ES

电玩女神/ 2022年12月08日 05:11/ 0 赞/ 272 阅读

相关 42 线上生产环境的RocketMQ集群进行消息轨迹的追踪

1. 消息轨迹 RocketMQ支持在生产环境里查询一条消息的轨迹。总得来说，我们可以知道一个消息是什么时候从哪个Producer发送出来的？它在Broker端是进入

快来打我*/ 2022年09月01日 09:22/ 0 赞/ 90 阅读

相关【RocketMQ工作原理】消息的生产过程

1 消息的生产过程 Producer可以将消息写入到某Broker中的某Queue中，其经历了如下过程： Producer发送消息之前，会先向NameServer

「爱情、让人受尽委屈。」/ 2022年08月28日 15:53/ 0 赞/ 209 阅读

相关 Ceph集群生产环境安装部署

前言 ceph的组件以及工作流程非常的复杂,是一个庞大的系统,在尝试ceph之前尽量多查阅官方的文档,理解ceph的mon/osd/mds/pg/pool等各组件/Uni

我会带着你远行/ 2022年05月13日 07:28/ 0 赞/ 540 阅读