查看消息轨迹
1.修改配置文件
broker的启动文件加上消息轨迹相关配置
##if msg tracing is open,the flag will be true
traceTopicEnable=true
2.启动broker
使用broker-a.properties配置文件后台启动Broker。
nohup mqbroker -c /usr/local/rocketmq/rocketmq-all-4.9.1-bin-release/conf/2m-2s-async/broker-a.properties &
3.rocketmq-client代码改动如下
- 发送消息时开启消息轨迹
enableMsgTrace增加一个开关参数(enableMsgTrace)来实现消息轨迹是否开启；
customizedTraceTopic新增一个自定义参数(customizedTraceTopic)来实现用户存储消息轨迹数据至自己创建的用户级Topic
DefaultMQProducer producer = new DefaultMQProducer("Producer",true,"gj"); //（1）
- 订阅消息时开启消息轨迹
enableMsgTrace增加一个开关参数(enableMsgTrace)来实现消息轨迹是否开启；
customizedTraceTopic新增一个自定义参数(customizedTraceTopic)来实现用户存储消息轨迹数据至自己创建的用户级Topic
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("Consumer",true,"gj");
4.控制台查看消息轨迹
