消息中间件RabbitMQ学习笔记---AMQP协议简介_amqp 的中间件

消息中间件RabbitMQ学习笔记—AMQP协议简介

1.协议架构简介

1. AMQP全称高级消息队列协议（Advanced Message Queuing Protocol），是一种标准，类似于JMS，兼容JMS协议。目前RabbitMQ主流支持AMQP 0-9-1，3.8.4版本支持AMQP 1.0。
   

2.AMQP中的概念简介

1. Publisher：消息发送者，将消息发送到Exchange并指定RoutingKey，以便queue可以接收到指定的消息。
2. Consumer：消息消费者，从queue获取消息，一个Consumer可以订阅多个queue以从多个queue中接收消息。
3. Server：一个具体的MQ服务实例，也称为Broker。
4. Virtual host：虚拟主机，一个Server下可以有多个虚拟主机，用于隔离不同项目，一个Virtual host通常包含多个Exchange、Message Queue。
5. Exchange：交换器，接收Producer发送来的消息，把消息转发到对应的Message Queue中。
6. Routing key：路由键，用于指定消息路由规则（Exchange将消息路由到具体的queue中），通常需要和具体的Exchange类型、Binding的Routing key结合起来使用。
7. Bindings：指定了Exchange和Queue之间的绑定关系。Exchange根据消息的Routing key和Binding配置（绑定关系、Binding、Routing key等）来决定把消息分派到哪些具体的queue中。这依赖于Exchange类型。
8. Message Queue：实际存储消息的容器，并把消息传递给最终的Consumer。
   

3.AMQP传输层架构简介

1. AMQP是一个二进制的协议，信息被组织成数据帧，有很多类型。数据帧携带协议方法和其他信息。所有数据帧都拥有基本相同的格式：帧头，负载，帧尾。数据帧负载的格式依赖于数据帧的类型。
2. 我们假定有一个可靠的面向流的网络传输层（TCP/IP或等价的协议）。
3. 在一个单一的socket连接中，可能有多个相互独立的控制线程，称为“channel”。每个数据帧使用通道号码编号。通过数据帧的交织，不同的通道共享一个连接。对于任意给定通道，数据帧严格按照序列传输。
4. 我们使用小的数据类型来构造数据帧，如bit，integer，string以及字段表。数据帧的字段做了轻微的封装，不会让传输变慢或解析困难。根据协议规范机械地生成成数据帧层相对简单。
5. 线级别的格式被设计为可伸缩和足够通用，以支持任意的高层协议（不仅是AMQP）。我们假定AMQP会扩展，改进以及随时间的其他变化，并要求wire-level格式支持这些变化。

4. AMQP协议协商

1. AMQP客户端和服务端进行协议协商。意味着当客户端连接上之后，服务端会向客户端提出一些选项，客户端必须能接收或修改。如果双方都认同协商的结果，继续进行连接的建立过程。协议协商是一个很有用的技术手段，因为它可以让我们断言假设和前置条件。
2. 在AMQP中，我们需要协商协议的一些特殊方面：
   1. 真实的协议和版本。服务器可能在同一个端口支持多个协议。
   2. 双方的加密参数和认证方式。这是功能层的一部分。
   3. 数据帧最大大小，通道数量以及其他操作限制。
3. 对限制条件的认同可能会导致双方重新分配key的缓存，避免死锁。每个发来的数据帧要么遵守认同的限制，也就是安全的，要么超过了限制，此时另一方出错，必须断开连接。出色地践行了“要么一切工作正常，要么完全不工作”的RabbitMQ哲学。
4. 协商双方认同限制到一个小的值，如下：
   1. 服务端必须告诉客户端它加上了什么限制。
   2. 客户端响应服务器，或许会要求对客户端的连接降低限制。

5. AMQP数据帧界定

1. TCP/IP是流协议，没有内置的机制用于界定数据帧。现有的协议从以下几个方面来解决：
   1. 每个连接发送单一数据帧。简单但是慢。
   2. 在流中添加帧的边界。简单，但是解析很慢。
   3. 计算数据帧的大小，在每个数据帧头部加上该数据帧大小。这简单，快速，AMQP的选择。

6.AMQP客户端实现JMS客户端

1. RabbitMQ的JMS客户端用RabbitMQ Java客户端实现，既与JMS API兼容，也与AMQP 0-9-1协议兼容。
2. 局限性—》RabbitMQ JMS客户端不支持某些JMS 1.1功能：
   1. JMS客户端不支持服务器会话。
   2. XA事务支持接口未实现。
   3. RabbitMQ JMS主题选择器插件支持主题选择器。队列选择器尚未实现。
   4. 支持RabbitMQ连接的SSL和套接字选项，但仅使用RabbitMQ客户端提供的（默认）SSL连接协议。
   5. RabbitMQ不支持JMS NoLocal订阅功能，该功能禁止消费者接收通的消息。可以调用包含NoLocal参数的方法，但该方法将被忽略。
3. RabbitMQ使用amqp协议，JMS规范仅对于Java的使用作出的规定，跟其他语言无关，协议是语言无关的，只要语言实现了该协议，就可以做客户端。如此，则不同语言之间互操作性得以保证。