springboot 集成RabbitMQ

这里简单记录springboot集成RabbitMQ，RabbitMQ的搭建使用docker容器搭建。

工具/原料

1
启动部署一个mq服务，这里用docker部署的，可以参考，也可以自己在服务器上部署，部署时记得设置用户名和密码，最后启动的时候可以看到mq的节点名字
2
然后创建一个springboot，记得勾选RabbitMQ
2
此文章非法爬取自百度经验
3
如果是已有的项目，在pom.xml添加如下依赖即可
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId></dependency>
4
现在开始配置mq，在application.yml添加如下配置,图中是yml格式，下面是普通的格式
spring.rabbitmq.host=mq所在服务的ip
spring.rabbitmq.port=14002
spring.rabbitmq.username= root
spring.rabbitmq.password= ********
5
配置添加好了之后，现在开始给mq添加个配置类，注意Queue的导包
@Configurationpublic class MqConfig { @Bean public Queue helloQueue(){ return new Queue("hello"); }}
6
编写个测试发送类，主要代码
rabbitTemplate.convertAndSend("hello",context);
7
在编写mq接收类，主要三个注解
@Component@RabbitListener(queues = "hello")
@RabbitHandler
8
最后运行测试，先运行主程序，再运行测试类的发送mq方法，反过来是接收不到消息的
END