目录

一、springboot项目整合rabbitMQ

1、创建springboot项目

 2.rabbitMQ的底层配置实现

3.单播测试 

测试发送消息

 测试接收消息

 序列号json数据发送

4.测试广播

5.消息队列的监听

 测试：

 总结

6.注解AmqpAdmin的使用

创建exchange

 创建队列

 创建绑定规则

一、springboot项目整合rabbitMQ

1、创建springboot项目

 2.rabbitMQ的底层配置实现

我们可以看到rabbitMQ的底层配置属性的核心在于RabbitProperties配置类

 我们可以看到，这些属性都是在配置文件中可以配置的

 可以看到默认的虚拟机主机和我们创建的是一样的，我们可以不用指定

 springboot的配置文件

3.单播测试 

测试发送消息

 进入到rabbitMQ中查看消息

由于采用的是java默认的序列化方式 

 测试接收消息

运行 

 然后我们就可以看到rabbitMQ对应的消息队列里面就没有了

 序列号json数据发送

默认使用的消息转换器

 因此我们可以换一个MessageConverter

我们可以看到在MessageConverter的子类中有json类

创建自定义的MessageConverter

注入到IOC容器之后，会自动生效 

 再次发送

 也能收到

4.测试广播

5.消息队列的监听

监听指定的消息队列中的消息，一旦有消息进来就会被调用执行

 在启动主类上添加开启rabbitMQ的注解方式

 测试：

 启动测试之后，后台马上打印出消息

测试消息类获取到的内容

 打印出两个

 总结

一定接收方法的对象是队列，发送消息的对象是交换器和队列

6.注解AmqpAdmin的使用

AmqpAdmin：创建和删除 queue，exchange，binding

创建exchange

创建exchange

 在DirectExchange的构造参数中可以加入多个参数，和在rabbitMQ的管理界面创建的参数内容是相同的

运行测试

 创建队列

 创建绑定规则

 运行测试