RabbitMQ学习总结
最近一段时间项目用到了RabbitMQ消息队列, 在此之前, 只用过ActiveMQ; 在用过RabbitMQ之后再对比ActiveMQ, 发现RabbitMQ各方面更加的强大, 对Spring的支持更加的友好! 在此总结好RabbitMQ的相关知识点, 也为了更好地巩固记忆;
RabbitMQ介绍:
从概念出发, RabbitMQ的全称为Message Queue, 即消息队列, RabbitMQ是由erlang语言开发, 基于高级消息队列协议(AMQP), 实现的消息队列, 作用是应用程序之间的解耦, 系统与系统之间的通讯; 而其中, erlang语言是一种通用的面向并发的编程语言，它由瑞典电信设备制造商爱立信所辖的CS-Lab开发，目的是创造一种可以应对大规模并发活动的编程语言和运行环境。Erlang问世于1987年，经过十年的发展，于1998年发布开源版本。Erlang是运行于虚拟机的解释性语言，但是现在也包含有乌普萨拉大学高性能Erlang计划（HiPE）开发的本地代码编译器，自R11B-4版本开始，Erlang也开始支持脚本式解释器。在编程范型上，Erlang属于多重范型编程语言，涵盖函数式、并发式及分布式。顺序执行的Erlang是一个及早求值,单次赋值和动态类型的函数式编程语言。而AMQP高级消息队列则是提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。
介绍完了基本的概念后, 大致了解了RabbitMQ是由erlang语言基于高级消息队列协议AMQP开发的一个消息中间件, 那么它的应用场景主要是以下这几个方面:
1、任务异步处理。
将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。提高了应用程序的响应时间。
2、应用程序解耦合
MQ相当于一个中介，生产方通过MQ与消费方交互，它将应用程序进行解耦合。
目前市面上用的比较多的消息队列主要有: ActiveMQ, RabbitMQ, ZeroMQ, Kafka, MetaMQ, RocketMQ, Redis
那么项目中为什么会选用RabbitMQ呢? 从它的特性出发, 主要是考虑到了以下几点:
1、使得简单，功能强大。
2、基于AMQP协议。
3、社区活跃，文档完善。
4、高并发性能好，这主要得益于Erlang语言。
5、SpringBoot默认集成RabbitMQ。
RabbitMQ的原理与主要构成
组成部分说明如下：
Broker：消息队列服务进程，此进程包括两个部分：Exchange和Queue。
Exchange：消息队列交换机，按一定的规则将消息路由转发到某个队列，对消息进行过虑。
Queue：消息队列，存储消息的队列，消息到达队列并转发给指定的消费方。
Producer：消息生产者，即生产方客户端，生产方客户端将消息发送到MQ。
Consumer：消息消费者，即消费方客户端，接收MQ转发的消息。
消息发布与接收流程
-----发送消息-----
1、生产者和Broker建立TCP连接。
2、生产者和Broker建立通道。
3、生产者通过通道消息发送给Broker，由Exchange将消息进行转发。
4、Exchange将消息转发到指定的Queue（队列）
----接收消息-----
1、消费者和Broker建立TCP连接
2、消费者和Broker建立通道
3、消费者监听指定的Queue（队列）
4、当有消息到达Queue时Broker默认将消息推送给消费者。
5、消费者接收到消息。
1、发送端操作流程
1）创建连接
2）创建通道
3）声明队列
4）发送消息
2、接收端
1）创建连接
2）创建通道
3）声明队列
4）监听队列
5）接收消息
6）ack回复
RabbitMQ的工作模式
RabbitMQ有以下几种工作模式 ：
1、Work queues
2、Publish/Subscribe
3、Routing
4、Topics()
5、Header
6、RPC
Work queues模式
该种模式中, 可以多个消费者共同监听消费同一个消息队列中的消息, 对于一个队列中任务过于繁重的情况可以使用多个消费者监听同一个队列, RabbitMQ会采用轮询的方式让每个监听的队列都消费消息, 消费者消费完一条消息后, 才能接着消费下一条消息
Publish/Subscribe模式
每个消费者监听自己的队列, 生产者将消息发给broker，由交换机将消息转发到绑定此交换机的每个队列，每个绑定交换机的队列都将接收 到消息
publish/subscribe与work queues有什么区别
区别：
1）work queues不用定义交换机，而publish/subscribe需要定义交换机。
2）publish/subscribe的生产方是面向交换机发送消息，work queues的生产方是面向队列发送消息(底层使用默认
交换机)。
3）publish/subscribe需要设置队列和交换机的绑定，work queues不需要设置，实质上work queues会将队列绑
定到默认的交换机 。
相同点：
所以两者实现的发布/订阅的效果是一样的，多个消费端监听同一个队列不会重复消费消息。
2、实质工作用什么 publish/subscribe还是work queues。
建议使用 publish/subscribe，发布订阅模式比工作队列模式更强大，并且发布订阅模式可以指定自己专用的交换
机。
Routing模式
每个消费者监听自己的队列，并且设置routingkey, 生产者将消息发给交换机，由交换机根据routingkey来转发消息到指定的队列。
Routing模式和Publish/subscibe有什么区别？
Routing模式要求队列在绑定交换机时要指定routingkey，消息会转发到符合routingkey的队列。
Topics模式
每个消费者监听自己的队列，并且设置带统配符的routingkey, 生产者将消息发给broker，由交换机根据routingkey来转发消息到指定的队列。
Topic模式更多加强大，它可以实现Routing、publish/subscirbe模式的功能。
Header模式
header模式与routing不同的地方在于，header模式取消routingkey，使用header中的 key/value（键值对）匹配队列。
RPC模式
RPC即客户端远程调用服务端的方法 ，使用MQ可以实现RPC的异步调用，基于Direct交换机实现，流程如下：
1、客户端即是生产者就是消费者，向RPC请求队列发送RPC调用消息，同时监听RPC响应队列。
2、服务端监听RPC请求队列的消息，收到消息后执行服务端的方法，得到方法返回的结果
3、服务端将RPC方法 的结果发送到RPC响应队列
4、客户端（RPC调用方）监听RPC响应队列，接收到RPC调用结果。