源码分析RocketMQ消息轨迹

本文沿着RocketMQ消息轨迹-设计篇的思路，从如下3个方面对其源码进行解读：发送消息轨迹消息轨迹格式存储消息轨迹数据发送消息轨迹流程首先我们来看一下在消息发送端如何启用消息轨迹，示例代码如下： 1public class TraceProducer { 2    public static void main(String[] args) throws MQClientException, InterruptedException { 3        DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName",true);      // @1 4        producer.setNamesrvAddr("127.0.0.1:9876"); 5        producer.start(); 6        for (int i = 0; i 10; i++) 7            try { 8                { 9                    Message msg = new Message("TopicTest",10                        "TagA",11                        "OrderID188",12                        "Hel ………………………………