RabbitMQ 即一个消息队列，主要是用来实现应用程序的异步和解耦，同时也能起到消息缓冲，消息分发的作用。
RabbitMQ是实现AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。RabbitMQ主要是为了实现系统之间的双向解耦而实现的。当生产者大量产生数据时，消费者无法快速消费，那么需要一个中间层。保存这个数据。
AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。
RabbitMQ是一个开源的AMQP实现，服务器端用Erlang语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。
通常我们谈到队列服务, 会有三个概念： 发消息者、队列、收消息者，RabbitMQ 在这个基本概念之上, 多做了一层抽象, 在发消息者和 队列之间, 加入了交换器 (Exchange). 这样发消息者和队列就没有直接联系, 转而变成发消息者把消息给交换器, 交换器根据调度策略再把消息再给队列。
那么，其中比较重要的概念有 4 个，分别为：虚拟主机，交换机，队列，和绑定。
虚拟主机：一个虚拟主机持有一组交换机、队列和绑定。为什么需要多个虚拟主机呢？很简单，RabbitMQ当中，用户只能在虚拟主机的粒度进行权限控制。 因此，如果需要禁止A组访问B组的交换机/队列/绑定，必须为A和B分别创建一个虚拟主机。每一个RabbitMQ服务器都有一个默认的虚拟主机“/”。
交换机：Exchange 用于转发消息，但是它不会做存储 ，如果没有 Queue bind 到 Exchange 的话，它会直接丢弃掉 Producer 发送过来的消息。
这里有一个比较重要的概念：路由键 。消息到交换机的时候，交互机会转发到对应的队列中，那么究竟转发到哪个队列，就要根据该路由键。
绑定：也就是交换机需要和队列相绑定，这其中如上图所示，是多对多的关系。
接下来用springboot整合rabbitmq，首先安装好一个RabbitMQ（安装过程略）：
然后创建springboot的rabbitmq项目，如下：
可以看到下载后，关键的一个依赖是amqp：
然后在配置文件里面加入rabbitmq的关键配置：
一对一发送
接下来看代码，首先配置一个队列message：
然后写一个发送消息方法：
然后是接收者：
注意：必须是一个queue，此处都是message。
首先启动项目，项目启动成功，可以看到，rabbitmq里面多了一个message：
最后写一个测试方法，测试发送和接收：
运行结果：
注意：运行测试方法的时候，如果Receiver没有打印，可能是因为测试方法运行时间太短，可以把测试方法中的调用send方法的代码注释掉，然后重新运行测试方法，或者直接启动application，就能看到打印了。
一对多发送
来看看一对多发送，首先在发送端发送十个消息，为每个消息加上序号：
然后建立两个接收者，如下：
测试方法如下：
然后运行测试方法，发送消息，可以看到接收结果：
根据返回结果得到以下结论：
一个发送者，N个接受者,经过测试会均匀的将消息发送到N个接收者中
多对多发送
同理，可以弄多个发送者多个接收者测试多对多发送，首先写两个发送方法：
然后写两个接收的方法：
测试代码如下：
运行测试，结果如下：
可以看到结论和一对多一样，每个都会均匀将消息发送到接收者。
对象支持
来看看对对象的支持，新建一个user类：
增加发送和接收方法：
测试方法：
运行测试方法：
运行结果为：
上面是spirng boot rabbitmq对对象的支持。
Topic Exchange 。
topic 是RabbitMQ中最灵活的一种方式，可以根据routing_key自由的绑定不同的队列
首先对topic规则配置，这里使用两个队列来测试：
可以看到上面定义了两个队列，一个exchange，messageA匹配的是topic.a队列，messageB匹配的是所有topic.开头的队列。下面分别定义两个发送方法：
发送send1会匹配到topic.#和topic.a，两个Receiver都可以收到消息，发送send2只有topic.#可以匹配，所以只有Receiver2监听到消息。
两个接收方法如下：
分别写两个测试方法：
测试结果如下：
可以看到topic配置很灵活。
Fanout Exchange
Fanout 就是我们熟悉的广播模式或者订阅模式，给Fanout交换机发送消息，绑定了这个交换机的所有队列都收到这个消息。
Fanout 相关配置：
发送方法如下：
这里使用了A、B、C三个队列绑定到Fanout交换机上面，发送端的routing_key参数写任何字符都会被忽略。
针对三个队列的三个接收方法如下：
测试方法如下：
运行结果如下：
结果说明，绑定到fanout交换机上面的队列都收到了消息！
代码地址： https://gitee.com/blueses/spring-boot-demo
网友评论