AMQP.0-10中文版——概述

时间 2020-02-06

标签 amqp.0 amqp 中文版概述繁體版

原文原文链接

AMQP.0-10中文版——概述

第1章概述php

1.1. 本文档的目标

这份文档定义了高级消息队列协议，这个协议使得听从该协议的客户端应用和消息中间件服务器之间可以互相通讯。为了彻底实现互操做性，咱们还定义了消息中间件服务的标准行为。编程

咱们面对这个领域有经验的技术读者，同时还提供了足够的规范和指南，一个合适的技术工程师能够根据这些文档在任何硬件平台上用各类编程语言来构建听从该协议的解决方案。安全

1.2. 专利

AMQP的设计目标之一是它的概念都来自于现有的、无产权阻碍的、普遍推行的标准——好比由互联网工程任务组和万维网颁布的标准。服务器

所以，咱们相信仅用众所周知的一些技术就可以实现AMQP服务，好比现有的开源网络程序和电子邮件路由软件或者那些技术专家们所熟悉的技术。网络

1.3. 摘要

1.3.1. 什么是AMQP

高级消息队列协议使得听从该规范的客户端应用和消息中间件服务器的全功能互操做成为可能。框架

1.3.2. 为何要用AMQP

咱们的目标是实现一种在全行业普遍使用的标准消息中间件技术，以便下降企业和系统集成的开销，而且向大众提供工业级的集成服务。异步

咱们的宗旨是经过AMQP，让消息中间件的能力最终被网络自己所具备，而且经过消息中间件的普遍使用发展出一系列有用的应用程序。编程语言

1.3.3. AMQP的范围

为了彻底实现消息中间件的互操做性，须要充分定义网络协议和消息代理服务的功能语义。分布式

所以，AMQP定义网络协议(AMQP是协议！)和代理服务以下：模块化

一套肯定的消息交换功能，也就是“高级消息交换协议模型”。AMQP模型包括一套用于路由和存储消息的功能模块，以及一套在这些模块之间交换消息的规则。
一个网络线级协议（数据传输格式），客户端应用能够经过这个协议与消息代理和它实现的AMQP模型进行交互通讯。

能够只实现AMQP协议规范中的的部分语义，可是咱们相信明确的描述这些语义有助于理解这个协议。

1.3.4. 高级消息交换协议

1.3.4.1. AMQP模型

咱们须要明确的定义服务器的语义，由于全部服务器实现都应该保持这些语义的一致性，不然就没法进行互操做。

所以AMQP模型描述了一套模块化的组件以及这些组件之间进行链接的标准规则。

在服务器中，三个主要功能模块链接成一个处理链完成预期的功能：

“exchange”接收发布应用程序发送的消息，并根据必定的规则将这些消息路由到“消息队列”。
“message queue”存储消息，直到这些消息被消费者安全处理完为止。
“binding”定义了exchange和message queue之间的关联，提供路由规则。

使用这个模型咱们能够很容易的模拟出存储转发队列和主题订阅这些典型的消息中间件概念。

一个AMQP服务器相似于邮件服务器，exchage相似于消息传输代理（email里的概念），message queue相似于邮箱。Binding定义了每个传输代理中的消息路由表，发布者将消息发给特定的传输代理，而后传输代理将这些消息路由到邮箱中，消费者从这些邮箱中取出消息。

在之前的中间件系统的应用场景中，发布者直接将消息发送给邮箱或者邮件列表。

区别就在于用户能够控制message queue与exchage的链接规则，这能够作不少有趣的事情，好比定义一条规则：“将全部包含这样这样的消息头的消息都复制一份再发送到消息队列中”。

AMQP模型有如下目标：

支持金融服务领域的语义要求。
支持金融服务领域所要求的性能要求。
可以很方便的扩展新的消息路由和队列。
经过AMQP协议（AMQP和AMQP Protocol的是总体和部分的关系），服务器应用能够经过编程的方式来实现具体的功能语义。
简单而灵活。

1.3.4.2. AMQP协议

AMQP协议是一个二进制协议，拥有一些现代特色：多信道、协商式、异步、安全、跨平台、中立、高效。

AMQP一般被划分为三层：

模型层定义了一套命令（按功能分类），客户端应用能够利用这些命令来实现它的业务功能。

会话层负责将命令从客户端应用传递给服务器，再将服务器的应答传递给客户端应用，会话层为这个传递过程提供可靠性、同步机制和错误处理。

传输层提供帧处理、信道复用、错误检测和数据表示。

实现者能够将传输层替换成任意传输协议，只要不改变AMQP协议中与客户端应用程序相关的功能。实现者还可使用其余高层协议中的会话层。

AMQP模型的设计由如下几个需求所驱动：

保证听从AMQP规范的服务器实现之间可以进行互操做。
为服务质量提供显示控制。
支持全部消息中间件的功能：消息交换、文件传输、流传输、远程进程调用等。
兼容已有的消息API规范（好比Sun公司的JMS规范）。
造成一致和明确的命名。
经过AMQP协议能够完整的配置服务器线路（TODO：server wiring是啥意思？）。
使用命令符号能够很容易的映射成应用级别的API。
明肯定义每个操做只作一件事情。

AMQP传输层的设计由如下几个主要的需求所驱动，这些需求不分前后次序：

使用可以快速打包解包的二进制编码来保证数据的紧凑性。
可以处理任意大小的消息。
容许零拷贝数据传输（好比远程DMA）。
一个链接支持多个会话。
保证会话可以从网络错误、服务器失效中恢复。
为了长期存在，没有隐含的内置限制（TODO：To be long-lived，with no significant in-built limitations）。
异步传输消息。
可以很容易的处理新的和变化的需求。
高版本的AMQP规范可以兼容低版本的规范。
使用强断言模型来保证应用程序的可修复性。
保持编程语言的中立性。
适宜使用代码生成工具生成协议处理模块。

1.3.5. 功能范围

咱们支持各类消息交换的体系结构：

存储转发（多个消息发送者，单个消息接收者）。
分布式事务（多个消息发送者，多个消息接收者）。
发布订阅（多个消息发送者，多个消息接收者）。
基于内容的路由（多个消息发送者，多个消息接收者）。
文件传输队列（多个消息发送者，多个消息接收者）。
点对点链接（单个消息发送者，单个消息接收者）。

1.4. 本文档的结构

本文档分红两个部分：

“概念”部分将对AMQP的概念作一个简单的介绍，描述AMQP怎么工做，以及AMQP的用途。
“标准”部分将对AMQP的模型层、会话层的每一个组成部分作精确的定义，还将定义AMQP在网络上传输的二进制消息结构。
咱们用IETF RFC2119中的术语定义：必须、没必要、应该、不该该和能够（详见http://www.ietf.org/rfc/rfc2119.txt）。
当咱们讨论听从AMQP规范的服务器的具体行为时，咱们使用术语“服务器”来表示这些服务器。
当咱们讨论听从AMQP规范的客户端应用的具体行为时，咱们使用术语“客户端”来表示这些客户端应用。
咱们使用“端点”来表示“服务器或者客户端”。
除非另有说明，全部数字都是十进制的。
协议中的常量都用大写字母的名字来表示。AMQP的实现若是须要在代码或者文档中定义和使用这些常量，必须用这些名字来表示。
属性名、命令或者控制参数，以及帧字段都用小写字母的名字来表示。AMQP的实现必须在代码或者文档中与之保持一致。

1.5. 约定

1.5.1. 定义

1.5.2. 版本号

AMQP版本用两个版本号表示——主版本号和次版本号。咱们约定版本由主版本号后面加小数点再加上次版本号组成（好比1-3表示主版本号为1，次版本号为3）。

主版本号和次版本号能够用0到255以内的全部值。
主版本号保持不变，次版本号递增。当AMQP工做组提高主版本号时，次版本号将被设置为0。所以，有可能出现这样的版本序列：1-2，1-3，1-4，2-0，2-1……
一旦本协议发布以后（主版本号大于1），应尽可能防止次版本号递增到9。不过在发布以前（版本0-x），因为会对本协议进行频繁的修订，能够不遵照这条约定。
一旦本协议发布以后（主版本号大于1），同一个主版本不一样次版本的实现必须向后兼容。而在发布以前，这些次版本的实现不须要兼容。
大于或者等于99的主版本号用于测试和开发目的。

1.5.3. 技术术语

AMQP模型（AMQP Model）：一个由关键实体和语义表示的逻辑框架，听从AMQP规范的服务器必须提供这些实体和语义。为了实现本规范中定义的语义，客户端能够发送命令来控制AMQP服务器。
链接（Connection）：一个网络链接，好比TCP/IP套接字链接。
会话（Session）：端点之间的命名对话。在一个会话上下文中，保证“刚好传递一次”。
信道（Channel）：多路复用链接中的一条独立的双向数据流通道。为会话提供物理传输介质。
客户端（Client）：AMQP链接或者会话的发起者。AMQP是非对称的，客户端生产和消费消息，服务器存储和路由这些消息。
服务器（Server）：接受客户端链接，实现AMQP消息队列和路由功能的进程。也称为“消息代理”。
端点（Peer）：AMQP对话的任意一方。一个AMQP链接包括两个端点（一个是客户端，一个是服务器）。
搭档（Partner）：当描述两个端点之间的交互过程时，使用术语“搭档”来表示“另外一个”端点的简记法。好比咱们定义端点A和端点B，当它们进行通讯时，端点B是端点A的搭档，端点A是端点B的搭档。
片断集（Assembly）：段的有序集合，造成一个逻辑工做单元。
段（Segment）：帧的有序集合，造成片断集中一个完整子单元。
帧（Frame）：AMQP传输的一个原子单元。一个帧是一个段中的任意分片。
控制（Control）：单向指令，AMQP规范假设这些指令的传输是不可靠的。
命令（Command）：须要确认的指令，AMQP规范规定这些指令的传输是可靠的。
异常（Exception）：在执行一个或者多个命令时可能发生的错误状态。
类（Class）：一批用来描述某种特定功能的AMQP命令或者控制。
消息头（Header）：描述消息数据属性的一种特殊段。
消息体（Body）：包含应用程序数据的一种特殊段。消息体段对于服务器来讲彻底不透明——服务器不能查看或者修改消息体。
消息内容（Content）：包含在消息体段中的的消息数据。
交换器（Exchange）：服务器中的实体，用来接收生产者发送的消息并将这些消息路由给服务器中的队列。
交换器类型（Exchange Type）：基于不一样路由语义的交换器类。
消息队列（Message Queue）：一个命名实体，用来保存消息直到发送给消费者。
绑定器（Binding）：消息队列和交换器之间的关联。
绑定器关键字（Binding Key）：绑定的名称。一些交换器类型可能使用这个名称做为定义绑定器路由行为的模式。
路由关键字（Routing Key）：一个消息头，交换器能够用这个消息头决定如何路由某条消息。
持久存储（Durable）：一种服务器资源，当服务器重启时，保存的消息数据不会丢失。
临时存储（Transient）：一种服务器资源，当服务器重启时，保存的消息数据会丢失。
持久化（Persistent）：服务器将消息保存在可靠磁盘存储中，当服务器重启时，消息不会丢失。
非持久化（Non-Persistent）：服务器将消息保存在内存中，当服务器重启时，消息可能丢失。
消费者（Consumer）：一个从消息队列中请求消息的客户端应用程序。
生产者（Producer）：一个向交换器发布消息的客户端应用程序。
虚拟主机（Virtual Host）：一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。客户端应用程序在登陆到服务器以后，能够选择一个虚拟主机。

下面这些术语在AMQP规范的上下文中没有特别的意义：

主题：一般指发布消息；AMQP规范用一种或多种交换器来实现主题。
服务：一般等同于服务器。AMQP规范使用“服务器”这个术语来兼容IETF的标准术语，而且明确了协议中每一个部分的角色（两方也多是AMQP服务）。
消息代理：等同于服务器。AMQP规范使用术语“客户端”和“服务器”来兼容IETF的标准术语