Rocketmq生产者 把当前线程的所有请求头 放进去让消费者拿到

RocketMQ生产者可以通过设置消息属性的方式来把当前线程的所有请求头放进去让消费者拿到。具体实现可以参考如下代码：

// 设置消息属性
Message message = new Message(topic, body.getBytes(), "TagA");
message.putUserProperty("header1", value1);
message.putUserProperty("header2", value2);
// 发送消息
SendResult sendResult = producer.send(message);

在上述代码中，通过 `putUserProperty` 方法设置了两个消息属性 `header1` 和 `header2`，并将当前线程的请求头值 `value1` 和 `value2` 分别赋给这两个消息属性。在消费者端，可以通过 `MessageExt` 对象的 `getUserProperties` 方法获取消息属性值，如下所示：

List<MessageExt> msgs = pullResult.getMsgFoundList();
for (MessageExt message : msgs) {
    String header1 = message.getUserProperty("header1");
    String header2 = message.getUserProperty("header2");
    // 处理消息
}

在消费者端获取到消息后，通过 `getUserProperty` 方法获取消息属性值，即可获取到当前线程的请求头值。