1.4主流消息中间件介绍——RabbitMQ
- ActiveMQ，性能不是很好，因此在高并发的场景下，直接被pass掉了。它的Api很完善，在中小型互联网公司可以去使用。
- kafka，主要强调高性能，如果对业务需要可靠性消息的投递的时候。那么就不能够选择kafka了。但是如果做一些日志收集呢，kafka还是很好的。因为kafka的性能是十分好的。
- RocketMQ，它的特点非常好。它高性能、满足可靠性、分布式事物、支持水平扩展、上亿级别的消息堆积、主从之间的切换等等。MQ的所有优点它基本都满足。但是它最大的缺点：商业版收费。因此它有许多功能是不对外提供的。
那么说完这三种MQ还有没有其他MQ能够选择呢？有的，也是这次学习的MQ——RabbitMQ。
RabbitMQ于2007年发布，是一个在AMQP(高级消息队列协议)基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件之一。
RabbitMQ特点
- RabbitMQ是使用Erlang语言开发的开源消息队列系统，基于AMQP协议来实现。
- AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。
- AMQP协议更多用在企业系统内，对数据一致性、稳定性和可靠性要求很高的场景，对性能和吞吐量的要求还在其次。
- RabbitMQ的可靠性是非常好的，数据能够保证百分之百的不丢失。可以使用镜像队列，它的稳定性非常好。所以说在我们互联网的金融行业。对数据的稳定性和可靠性要求都非常高的情况下，我们都会选择RabbitMQ。当然没有kafka性能好，但是要比AvtiveMQ性能要好很多。也可以自己做一些性能的优化。
- RabbitMQ可以构建异地双活架构，包括每一个节点存储方式可以采用磁盘或者内存的方式。
RabbitMQ的集群架构
- 图中说的就是，我们可以采用三个节点作为RabbitMQ的一组集群，当然可以有许多组。节点与节点之间采用mirror queue。基于这种方式，能够保证数据百分之百的不丢失。
- 前端可以去做负载均衡，比如负载均衡组件：HA-proxy ，进行TCP级别的负载。
- 如果想做一个高可用的话，就需要借助keepAlived做一个高可用的配置。
- 比如前端加一个虚拟的VIP，通过VIP路由到指定的负载均衡组件，再有它路由到RabbtMQ的某一个节点。
这就是整个RabbitMQ集群架构。
能够实现非常完善，高可用并且性能也十分好，稳定性超强。并且有各种集群恢复手段。
比如:某一个节点挂了，或者某个磁盘损坏了，它也能进行一个消息修复。
入门RabbitMQ核心概念
RabbitMQ 是一个开源的消息代理和队列服务器，用来通过普通协议在完全不同的应用之间共享数据（RabbitMQ能够实现跨语言跨平台的机制，），RabbitMQ是使用Erlang语言来编写的，并且RabbitMQ是基于AMQP协议的。
仅仅通过上面一句话，相信大家一定有很多疑惑和问题。
- RabbitM成熟度到底怎么样？
- 业界使用度怎么样？哪些大厂在使用？为什么？
- 包括RabbitMQ到底都有哪些特点?
- RabbitMQ为什么要用Erlang语言去编写？
- 什么是AMQP协议？AMQP协议里面的具体的规范又是什么？
我相信大家跟我一样都会有这样的疑惑。那么我们一起来学习一RabbitMQ吧。
互联网大厂为什么选择RabbitMQ？
业界使用度怎么样？哪些大厂在使用？为什么？都有哪些优点？
- 据我了解：滴滴、美团、去哪儿、头条…
这些互联网大厂都会采用RabbitMQ作为它底层的消息通信的一个基础组件。根本原因：
- 开源、性能优秀、稳定性保障
- 提供可靠性消息投递模式（confirm）、返回模式（return）
- 与SpringAMQP完美的整合、扩展性变得更强、API丰富
- 集群模式丰富、表达式配置、HA（高可用）模式、镜像队列模型
- 保证数据不丢失的前提下做到高可靠性、可用性
RabbiMQ的高性能是如何做到的？
原因就在于它使用了Erlang语言，Erlang语言最初在于交换机领域的架构模式，这样使得RabbitQ在Broker之间进行数据交互的性能是非常优秀的。
- 还有一点也是取决于作者，RabbitMQ开发的作者在开发RabbitMQ之间，先用Erlang语言做了一个简单的交换机，然后他惊奇的发现：Erlang的优点：Erlang有着和原生Socket一样好的延迟效果。
- 相信大家接触过Socket的朋友，对它的有怎样的性能有一定的了解。像我们耳熟能详的RPC通信框架。比如说：dubbo，它底层就是采用了Netty，Netty无非就是网络编程中的高性能之王，它无非就是一个Socket。
- 基于这个特点呢，我们就有了一个充分的选择RabbitMQ的理由。其实我们选择RabbitMQ的时候，有一个主要的考量目标就是：当消息入到RabbtMQ节点上的时候，RabbitMQ的延迟以及响应。
什么是AMQP高级消息队列协议？
AMQP全称：Advanced Message Queuing Protocol（高级消息队列协议）
AMQP定义：是具有现代特征的二进制协议。是一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。
它就类似于Java中的JMS。是比较上层的规范，基于这个规范可以开发出各种各项的消息中间件。
- Pubilsher application：生产者应用 生产的消息，扔到Server端。
- Server：指的就是RabbitMQ的节点
- Virtual host:虚拟主机，比较上层的一个路由，类似于路由器这么一个概念。后续介绍
- Exchange:交换机，生产者直接将消息投递到Exchange中。但是要经历3个过程 -》server->Virtual host->Exchange
先确定将消息发送到哪台服务器，那么就需要先去建立连接，设置一些地址等等。
- 第二层，投递到哪个Virtual host 需要定义。
- 第三层，投递到哪个Exchange也需要定义。
再看Consumer application 消费者的应用端，消费端只需要监听Message Queue，当队列中有消息的时候，就拿出来消费。因此在Exchange和Message Queue之间有绑定的关系存在，后续详细介绍。
AMQP核心概念是什么？
- server: 又称Broker,接收客户端的链接，实现AMQP实体服务
- Connection: 链接，应用程序与Broker的网络连接
- Channel:网络信道，几乎所有的操作（数据的读、写）都在Channel中进行，Channel是进行消息读写的通道。客户端可建立多个Channel，每个Channel代表一个会话任务。
- Message：消息，服务器和应用程序之间传送的数据，由Properties和Body组成。Properties可以对消息进行修饰，比如消息的优先级、延迟等高级特性；Body则就是消息体内容。
- Virtual host:虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个Virtual host 里面可以有若干个Exchange和Queue，同一个Virtual Host里面不能有相同名称的Exchange和Queue。一种逻辑概念，类似Redis的逻辑数据库。用来划分具体的服务。
- Exchange：交换机，接收消息，根据路由键转发消息到绑定的队列
- Binding:Exchange 和Queue之间的虚拟连接，Binding中可以包含routing key
- Routing key:一个路由股则，虚拟机可用它来确定如何路由一个特定消息。
- Queue:也称为message Queue,消息队列，保存消息并将它们转发给消费者。
以上核心概念先有一个大概的认知，以后会详细介绍。
RabbitMQ整体架构模型是什么样子的？
- 生产者把消息投递到Exchange,Exchange投递到Queue.
- 因此我们的生产者只需要关注把消息投递到指定的Exchange即可,我们的消费者只需要监听指定Queue即可。就是这么简单的机制。
- 通过图我们也能看到，生产者不需要关注投递到哪个队列，消费也不需要关注是从哪个Exchange上来的，这两块没有耦合的情况。主要是应为Exchange和Queue有一个绑定的关系。
RabbitMQ消息是如何流转的？
生产者publisher application 生产消息Message投递到Exchange上，Exchange绑定MessageQueue，可以绑定过多个MessageQueue，为什么三个队列只有其中一个队列收到了消息呢？主要是由于Exchange是有一个路由功能的。这个路由就是routing key,这个路由有两个非常关键的点，
- 第一个：你的消息是需要发送到哪个Exchange。
- 第二个：你发消息的时候需要带上routing key，然后通过Exchange 和 MessageQueue 建立一个绑定关系，通过路由key把消息路由到一个指定的队列上。然后我们的消费端直接监听队列就行了，就可以消费了。
