rocketmq中的自定義消息頭

在springboot中使用rocketmq的客戶端，有2種方式。

一是使用 org.apache.rocketmq的rocketmq-client

二是，在pom.xml中引用

<dependency>
   <groupId>org.apache.rocketmq</groupId>
   <artifactId>rocketmq-spring-boot-starter</artifactId>
   <version>2.0.3</version>
</dependency>

具體網址 https://github.com/apache/rocketmq-spring/blob/master/README_zh_CN.md

在原文的FAQ的6和7中的描述，即可以添加自定義的頭屬性。

在實驗中發現，與原有定義的屬性名稱重復的自定義名稱將按照描述中的說明添加“USER_”，如果不是沖突的名稱，則不會被改變。

public void send() throws InterruptedException {
        Message<?> msg = MessageBuilder.withPayload("Hi rocketmq!")
                .setHeader(MessageConst.PROPERTY_KEYS, "20191018")
                .setHeader("TAGS", "191018")
                .setHeader(MessageConst.PROPERTY_BUYER_ID,"20191018a")
                .setHeader("MQ", "user_mq")
                .build();
        template.convertAndSend(topic + ":1018", "topic with tags");
        java.lang.Thread.sleep(2000);
        template.send(topic, msg);
        log.info("send mq message, ext message" + msg.toString());
    }

setHeader("TAGS", "191018")，將被過濾掉，setHeader("USER_TAGS", "191018")，在接收端能收到結果的。
想添加tags屬性應該只能放在發送函數中的第一個參數中。如代碼中的 ‘(topic + ":1018",’
setHeader(MessageConst.PROPERTY_KEYS, "20191018")，是有效的。
比如 MessageConst.PROPERTY_BUYER_ID 這樣的 MessageConst下的其他屬性（試過幾個）似乎都被過濾了。並不像是描述中說的那樣添加 “USER_”前綴。