Springboot集成RabbitMQ

基本思路

SpringBoot整合RabbitMQ可分为生产者工程与消费者工程，分为以下几步

生产者工程：

（1）添加RabbitMQ的依赖

（2）在application.yml中配置RabbitMQ的信息

（3）创建一个rabbitMQ配置类

（4）创建生产者

消费者工程：

1）添加RabbitMQ的依赖

2）在application.yml中配置RabbitMQ的信息

3）创建一个rabbitMQ配置类

4）消费者工程

生产者工程

1、添加RabbitMQ的依赖

spring-boot-starter-amqp

2、在application.yml中配置RabbitMQ的信息

rabbitmq:

addresses: ieonline.microsoft.com

username: sjw

password: 123456

virtual-host: /

heartbeat: 60

listener:

simple:

acknowledge-mode: manual

concurrency: 1

max-concurrency: 10

prefetch: 100

3、创建一个rabbitMQ配置类

配置Exchange、Queue、及绑定交换机，本例配置topic交换机

4、创建生产者

使用RabbitTemplate发送消息

生产者工程结束

消费者工程

1、添加依赖

2、配置application.yml

3、创建一个rabbitMQ配置类

4、监听队列，接收消息

5、启动生产者

启动成功，我们打开控制台，发现成功创建了Exchange。

成功创建了两个队列

6、启动消费者，查看消息

我们发现已经成功监听到了消息。