SpringBoot集成RabbitMQ
一心同学 人气:0前言
本篇博客将会通过我们的实际场景来演示如何在Spring Boot中集成RabbitMQ以及如何对各种队列模式进行操作。
一、场景描述
我们通过模仿用户下订单时，订单系统分别通过短信，邮件或微信进行推送消息，如下图：
二、准备工作
（1）创建两个Spring Boot项目分别对应生产者和消费者。
（2）导入依赖。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>（3）定义生产者的配置文件。
application.yml:
server:
port: 8021
spring:
#给项目来个名字
application:
name: rabbitmq-provider
#配置rabbitMq 服务器
rabbitmq:
host: 服务器地址
port: 5672
username: yixin
password: 123456
#虚拟host 可以不设置,使用server默认host
virtual-host: /（4）定义消费者的配置文件。
application.yml:
server:
port: 8022
spring:
#给项目来个名字
application:
name: rabbitmq-consumer
#配置rabbitMq 服务器
rabbitmq:
host: 服务器地址
port: 5672
username: yixin
password: 123456
#虚拟host 可以不设置,使用server默认host
virtual-host: /三、发布/订阅模式（Fanout）
加载全部内容