對應的application.properties如下：

spring.rabbitmq.host=122.xx.xxx.xxx spring.rabbitmq.port=5672 spring.rabbitmq.username=xxxxxx spring.rabbitmq.password=xxxxxx spring.rabbitmq.virtual-host=/xxxxxx spring.rabbitmq.cache.channel.checkout-timeout=10

關鍵代碼如下：

package cn.it1995.demo.component;import org.springframework.amqp.core.*; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.boot.CommandLineRunner; import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Component;@Component public class Runner implements CommandLineRunner {static final String topicExchangeName = "spring-head-test";static final String queueName = "spring-boot-head";@BeanQueue queue(){return new Queue(queueName, false);}@BeanTopicExchange exchange(){return new TopicExchange(topicExchangeName);}@BeanBinding binding(Queue queue, TopicExchange exchange){return BindingBuilder.bind(queue).to(exchange).with("Hello.*");}private final RabbitTemplate rabbitTemplate;public Runner(RabbitTemplate rabbitTemplate){this.rabbitTemplate = rabbitTemplate;}@Overridepublic void run(String... args) throws Exception {MessageProperties messageProperties = new MessageProperties();messageProperties.setHeader("key", "value1");Message message = new Message("conduct oneself well".getBytes(), messageProperties);Message ret = rabbitTemplate.sendAndReceive(topicExchangeName, "Hello.1111", message);System.out.println(ret);} }

其中設置頭在run函數中：

@Overridepublic void run(String... args) throws Exception {MessageProperties messageProperties = new MessageProperties();messageProperties.setHeader("key", "value1");Message message = new Message("conduct oneself well".getBytes(), messageProperties);Message ret = rabbitTemplate.sendAndReceive(topicExchangeName, "Hello.1111", message);System.out.println(ret);}

用管理工具查看下：

?

總結

以上是生活随笔為你收集整理的Java笔记-spring-rabbit框架中消息中header的添加的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。