Java笔记-spring-rabbit框架中消息中header的添加

对应的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的添加相关推荐

Java笔记-Spring中RabbitMQ的调用
目录基本概念代码与演示基本概念 Spring中已经整合了RabbitMQ,通过配置bean文件,然后在源码中加载,可以简化代码操作. 身为C++程序员不得不说这种方式真的是太爽了. 在本人做过的 ...
使用Gradle禁止Java和Spring Boot Web应用程序中的FindBugs警告
如何在+ Spring Boot和+ Java应用程序中使用注释抑制FindBugs警告如果您的构建由于FindBugs问题而中断,并且是假阳性,或者由于其他考虑而无法解决问题,则可以添加注释来忽略 ...
Java进阶学习 - Dubbo框架(持续更新中~~)
Java进阶学习 - Dubbo框架 1.简介 Dobbo是一个高性能的RPC框架,解决了分布式钟的调用问题优点:解决了分布式系统中互相调用问题缺点:缺少统一管理的调度中心 2.为什么Dubbo说 ...
从零开始学java 框架_从零开始学 Java - 搭建 Spring MVC 框架
如果创建一个 Spring 项目 Spring MVC 框架在 Java 的 Web 项目中应该是无人不知的吧,你不会搭建一个 Spring 框架?作为身为一个刚刚学习Java的我都会,如果你不会的话 ...
Java笔记-Spring Boot中Spring WS WS-Addressing中@Action实例
此笔记为利用Spring WS的WS-Addressing发送SOAP请求及接收其响应. WS-Addressing(Web服务寻址):传送Web服务端点的引用的数据结构,以及一套能够在特定的消息上关 ...
Java笔记-Spring Boot Webservice中对指定namespace及localpart进行拦截
在外网中有这样的一个例子: @Overridepublic void addInterceptors(List<EndpointInterceptor> interceptors) {// ...
java获取chanel的ip_Netty:在消息中获取远程IP地址 - java
在我的类中(扩展SimpleChannelHandler),我尝试获取最初发送消息的IP. @Override public void messageReceived(ChannelHandlerCo ...
中去掉外键_【Java笔记】035天，MySQL中的增删改查
学习Java的第35天. 今天天除了学习MySQL中的各种约束,MySQL中DML的操作,还有MySQL查询语句ds-- MySQLdz中d的约束有: • 非空约束(not null) • 唯一性约束 ...
Java笔记-通过反射获取枚举类型中所有数据
程序运行截图如下: 代码如下: Em.java package cn.it1995;public enum Em {ONE(1, "第一个枚举"),TWO(2, "第二个 ...

Java笔记-spring-rabbit框架中消息中header的添加

Java笔记-spring-rabbit框架中消息中header的添加相关推荐

最新文章

热门文章