后端-SpringBoot集成RabbitMQ

1. RabbitMQ的介绍

介绍RabbitMQ之前先说一下AMQP协议：

AMQP，即Advanced Message Queuing Protocol（高级消息队列协议），一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。Erlang中的实现有RabbitMQ等。
AMQP 其实和Http一样 都是一种协议， 只不过 Http是针对网络传输的， 而AMQP是基于消息队列的。

AMQP 协议中的基本概念：

1. Broker： 接收和分发消息的应用，我们在介绍消息中间件的时候所说的消息系统就是Message Broker。
2. Virtual host： 出于多租户和安全因素设计的，把AMQP的基本组件划分到一个虚拟的分组中，类似于网络中的namespace概念。当多个不同的用户使用同一个RabbitMQ server提供的服务时，可以划分出多个vhost，每个用户在自己的vhost创建exchange／queue等。
3. Connection： publisher／consumer和broker之间的TCP连接。断开连接的操作只会在client端进行，Broker不会断开连接，除非出现网络故障或broker服务出现问题。
4. Channel： 如果每一次访问RabbitMQ都建立一个Connection，在消息量大的时候建立TCP Connection的开销将是巨大的，效率也较低。Channel是在connection内部建立的逻辑连接，如果应用程序支持多线程，通常每个thread创建单独的channel进行通讯，AMQP method包含了channel id帮助客户端和message broker识别channel，所以channel之间是完全隔离的。Channel作为轻量级的Connection极大减少了操作系统建立TCP connection的开销。
5. Exchange： message到达broker的第一站，根据分发规则，匹配查询表中的routing key，分发消息到queue中去。常用的类型有：direct (point-to-point), topic (publish-subscribe) and fanout (multicast)。
6. Queue： 消息最终被送到这里等待consumer取走。一个message可以被同时拷贝到多个queue中。
7. Binding： exchange和queue之间的虚拟连接，binding中可以包含routing key。Binding信息被保存到exchange中的查询表中，用于message的分发依据。

Exchange的类型：

1. direct： 这种类型的交换机的路由规则是根据一个routingKey的标识，交换机通过一个routingKey与队列绑定 ，在生产者生产消息的时候 指定一个routingKey当绑定的队列的routingKey与生产者发送的一样 那么交换机会吧这个消息发送给对应的队列。
2. fanout： 这种类型的交换机路由规则很简单，只要与他绑定了的队列，他就会把消息发送给对应队列（与routingKey没关系）。
3. topic： 这种类型的交换机路由规则也是和routingKey有关，只不过topic他可以根据*,#（*代表过滤一个单词，#代表过滤后面所有单词，用.隔开）来识别routingKey我打个比方假设我绑定的routingKey有队列A和B，A的routingKey是：*.user，而B的routingKey是#.user，那么我生产一条消息routingKey 为：error.user那么此时2个队列都能接受到， 如果改为topic.error.user那么这时候只有B能接受到了。

RabbitMQ：是一个开源的 基于AMQP协议实现的一个完整的企业级消息中间件，服务端语言由Erlang（面向并发编程）语言编写 对于高并发的处理有着天然的优势，客户端支持非常多的语言。

RabbitMQ 如同redis一样 他也是采用c/s架构由服务端与客户端组成。

注意：在安装RabbitMQ的时候，首先要下载Erlang安装包，而且版本要对应。

2. RabbitMQ与SpringBoot的整合

1. 首先引入SpringBoot和RabbitMQ的依赖