消息中间件——RabbitMQ（三）理解RabbitMQ核心概念和AMQP协议！

前言

本章学习，咱们能够了解到如下知识点：

• 互联网大厂为何选择RabbitMQ？
• RabbiMQ的高性能之道是如何作到的？
• 什么是AMQP高级协议？
• AMQP核心概念是什么？
• RabbitMQ总体架构模型是什么样子的？
• RabbitMQ消息是如何流转的？

1. 初识RabbitMQ

RabbitMQ 是一个开源的消息代理和队列服务器，用来经过普通协议在彻底不一样的应用之间共享数据（RabbitMQ可以实现跨语言跨平台的机制，），RabbitMQ是使用Erlang语言来编写的，而且RabbitMQ是基于AMQP协议的。

仅仅经过上面一句话，相信你们必定有不少疑惑和问题。

• RabbitM成熟度到底怎么样？
• 业界使用度怎么样？哪些大厂在使用？为何？
• 包括RabbitMQ到底都有哪些特色?
• RabbitMQ为何要用Erlang语言去编写？
• 什么是AMQP协议？AMQP协议里面的具体的规范又是什么？

我相信你们跟我同样都会有这样的疑惑。那么咱们一块儿来学习一RabbitMQ吧。

咱们来了解第一个问题。

2. 互联网大厂为何选择RabbitMQ？

业界使用度怎么样？哪些大厂在使用？为何？都有哪些优势？ 据我了解：滴滴、美团、去哪儿、头条...

这些互联网大厂都会采用RabbitMQ做为它底层的消息通讯的一个基础组件。根本缘由：

1. 开源、性能优秀、稳定性保障
2. 提供可靠性消息投递模式（confirm）、返回模式（return）
3. 与SpringAMQP完美的整合、扩展性变得更强、API丰富
4. 集群模式丰富、表达式配置、HA（高可用）模式、镜像队列模型
5. 保证数据不丢失的前提下作到高可靠性、可用性

3. RabbiMQ的高性能之道是如何作到的？

缘由就在于它使用了Erlang语言，Erlang语言最初在于交换机领域的架构模式，这样使得RabbitQ在Broker之间进行数据交互的性能是很是优秀的。

还有一点也是取决于做者，RabbitMQ开发的做者在开发RabbitMQ之间，先用Erlang语言作了一个简单的交换机，而后他惊奇的发现：Erlang的优势：Erlang有着和原生Socket同样好的延迟效果。 相信你们接触过Socket的朋友，对它的有怎样的性能有必定的了解。像咱们耳熟能详的RPC通讯框架。好比说：dubbo，它底层就是采用了Netty，Netty无非就是网络编程中的高性能之王，它无非就是一个Socket。 基于这个特色呢，咱们就有了一个充分的选择RabbitMQ的理由。其实咱们选择RabbitMQ的时候，有一个主要的考量目标就是：当消息入到RabbtMQ节点上的时候，RabbitMQ的延迟以及响应。

4. 什么是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之间有绑定的关系存在，后续详细介绍。

5. AMQP核心概念是什么？

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,消息队列，保存消息并将它们转发给消费者。

以上核心概念先有一个大概的认知，之后会详细介绍。

6. RabbitMQ总体架构模型是什么样子的？

生产者把消息投递到Exchange,Exchange投递到Queue. 所以咱们的生产者只须要关注把消息投递到指定的Exchange便可,咱们的消费者只须要监听指定Queue便可。就是这么简单的机制。 经过图咱们也能看到，生产者不须要关注投递到哪一个队列，消费也不须要关注是从哪一个Exchange上来的，这两块没有耦合的状况。主要是应为Exchange和Queue有一个绑定的关系。

7. RabbitMQ消息是如何流转的？

生产者publisher application 生产消息Message投递到Exchange上，Exchange绑定MessageQueue，能够绑定过多个MessageQueue，为何三个队列只有其中一个队列收到了消息呢？主要是因为Exchange是有一个路由功能的。这个路由就是routing key,这个路由有两个很是关键的点， 第一个：你的消息是须要发送到哪一个Exchange。 第二个：你发消息的时候须要带上routing key，而后经过Exchange 和 MessageQueue 创建一个绑定关系，经过路由key把消息路由到一个指定的队列上。而后咱们的消费端直接监听队列就好了，就能够消费了。

文末

欢迎关注我的微信公众号：Coder编程 获取最新原创技术文章和免费学习资料，更有大量精品思惟导图、面试资料、PMP备考资料等你来领，方便你随时随地学习技术知识！ 新建了一个qq群：315211365，欢迎你们进群交流一块儿学习。谢谢了！也能够介绍给身边有须要的朋友。

文章收录至 Github: https://github.com/CoderMerlin/coder-programming Gitee: https://gitee.com/573059382/coder-programming 欢迎关注并star~

参考资料：

《RabbitMQ消息中间件技术精讲》

推荐文章：

消息中间件——RabbitMQ（一）Windws/Linux环境搭建（完整版）

消息中间件——RabbitMQ（二）各大主流消息中间件综合对比介绍！

原文出处：https://www.cnblogs.com/coder-programming/p/11364524.html