知道了什么是MQ，也知道了它能做什么，接下来就是整合到我们的应用中，首先梳理如何引入依赖，以及演示代码的结构说明。

项目结构

image.png
common用于存储公用的代码，后续交换机等名称常量，都会在common里，这样各个module都可以直接使用。

mqprod顾名思义主要用于消息的生成；consumer1是消费者，用于消费消息和主要的演示作用。

依赖导包

在pom文件内，需要引入mq的依赖，springboot已经做了相应整合所以直接引入下面依赖即可：

  1. <!-- amqp依赖，包含Rabbitmq-->
  2. <dependency>
  3.   <groupId>org.springframework.boot</groupId>
  4.   <artifactId>spring-boot-starter-amqp</artifactId>
  5. </dependency>

配置文件

在yml文件内添加对rabbitmq地址配置：

  1. spring:
  2.   rabbitmq:
  3.     host: 127.0.0.1
  4.     port: 5672
  5.     username: guest
  6.     password: guest
  7.     virtual-host: /

各属性值根据实际情况修改，在prod和consumer1里都配置好，至此我们就可以在应用内使用rabbitmq

而rabbitmq提供了多种数据生产和消费的模式，满足各类应用情况，接下来依次说明。