操作场景
查询消息轨迹前,需要先在客户端开启消息轨迹。
本章节介绍使用Java和Go开启消息轨迹的方法。
操作步骤(Java)
在客户端开启消息轨迹的方法如下:
- 生产者开启消息轨迹(除事务消息以外的消息 类型 )
构造函数的“enableMsgTrace”参数传入“true”,例如:
DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName", true);
- 生产者开启消息轨迹( 事务消息 )
构造函数的“enableMsgTrace”参数传入“true”,例如:
TransactionMQProducer producer = new TransactionMQProducer(null,"ProducerGroupName", null, true, null);
须知:
生产者客户端版本在4.9.0以上才支持事务消息的轨迹,如果版本不满足要求,请先升级。
- 消费者开启消息轨迹
构造函数的“enableMsgTrace”参数传入“true”,例如:
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroupName",true);
操作步骤(Go )
在客户端开启消息轨迹的方法如下:
- 执行以下命令,检查是否已安装Go。
go version
返回如下回显时,说明Go已经安装。
[root@ecs-test sarama]# go version
goversion go1.16.5 linux/amd64
如果未安装Go,请下载并安装。
-
在“go.mod”中增加以下代码,添加依赖。
-
生产者开启消息轨迹(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。
-
消费者开启消息轨迹(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。