Azure 服务总线和事件中心内的 AMQP 1.0 协议指南
高级消息队列协议 1.0 是一种标准化组帧和传输协议，能够以异步、安全且可靠的方式在两方之间传输消息。 它是 Azure 服务总线消息传递和 Azure 事件中心的主要协议。
AMQP 1.0 是中间件供应商（例如 Microsoft 和 Red Hat）与许多消息传送中间件用户（例如代表金融服务行业的 JP Morgan Chase）广泛合作的成果。 OASIS 是 AMQP 协议和扩展规范的技术标准化论坛，它已获 ISO/IEC 19494:2014 国际标准的官方批准。
目标
本文总结了 AMQP 1.0 消息传递规范的核心概念以及由 OASIS AMQP 技术委员会制定的扩展规范，并说明了 Azure 服务总线如何根据这些规范进行实现和构建。
目的是要让在任何平台上使用任何现有 AMQP 1.0 客户端堆栈的开发人员通过 AMQP 1.0 与 Azure 服务总线交互。
常见的通用型 AMQP 1.0 堆栈（例如 Apache Qpid Proton 或 AMQP.NET Lite）会实现所有核心 AMQP 1.0 协议元素（如会话或链接）。 这些基本元素有时以更高级别的 API 进行包装；Apache Proton 甚至提供两个 API：命令式 Messenger API 和反应式 Reactor API。
在以下介绍中，我们假设 AMQP 连接、会话和链接的管理以及帧传输和流量控制的处理都由相应的堆栈（例如 Apache Proton-C）处理，而不需要应用程序开发人员特别注意。 抽象假设存在一些 API 基元（例如连接能力）以及创建某种形式的 sender 和 receiver 抽象对象的能力，并分别具有 send() 和 receive() 的某种形式的操作 。
介绍 Azure 服务总线的高级功能（例如消息浏览或会话管理）时，以 AMQP 术语说明这些功能，但也可作为一种分层虚拟实现，基于此假设的 API 抽象。
AMQP 是什么？
AMQP 是一种组帧和传输协议。 组帧表示它为以网络连接的任一方向流入的二进制数据流提供结构。 该结构针对要在已连接方之间交换的不同数据块（称为“帧” ）提供略图。 传输功能确保通信双方都可以对于何时应发送帧以及传输何时应视为完成建立共识。
与先前已过期，但仍有一些消息中转站使用的 AMQP 工作组的草稿版本不同，工作组的最终标准化 AMQP 1.0 协议并未规定消息中转站的存在或消息中转站内实体的任何特定拓扑。
该协议可用于对称的对等通信，以便与支持队列和发布/订阅实体的消息代理交互，如 Azure 服务总线所为。 它还可以用于与消息传送基础结构交互，其交互模式不同于一般队列（和 Azure 事件中心的情况一样）。 当事件发送到事件中心时，事件中心的作用如同队列，但从中读取事件时，其作用更类似于串行存储服务；它有点类似于磁带驱动器。 客户端选择可用数据流的偏移，并获取从该偏移位置转到最新可用的所有事件。
AMQP 1.0 协议被设计为可扩展，允许进一步规范以增强其功能。 本文档中介绍的三个扩展规范对其进行了说明。 在对于通过现有 HTTPS/WebSockets 基础结构进行的通信，可能难以配置本机 AMQP TCP 端口。 绑定规范定义如何通过 WebSockets 将 AMQP 分层。 以请求/响应方式与消息传送基础结构交互，以便进行管理或提供高级功能时，AMQP 管理规范定义所需的基本交互基元。 在联合授权模型集成中，AMQP 基于声明的安全规范定义如何关联和续订与链接关联的授权令牌。
基本 AMQP 方案
本部分说明 AMQP 1.0 与 Azure 服务总线的基本使用方式，其中包括创建连接、会话和链接，以及与服务总线实体（例如队列、主题和订阅）相互传输消息。
若要了解 AMQP 工作原理，可参阅最权威的 AMQP 1.0 规范，但此规范是为了精确引导实现而编写的，不是为了传授协议知识。 本部分着重于尽可能介绍描述服务总线如何使用 AMQP 1.0 的术语。
连接和会话
AMQP 将通信程序称为容器 ；其中包含节点 ，即这些容器内的通信实体。 队列可以是此类节点。 AMQP 允许多路复用，因此单个连接可用于节点之间的许多通信路径；例如，应用程序客户端可以同时从一个队列接收，并通过相同的网络连接发送到另一个队列。
网络连接因此固定在容器上。 它由采用客户端角色的容器启动，对采用接收者角色的容器进行出站 TCP 套接字连接，以侦听和接受入站 TCP 连接。 连接握手包括协商协议版本，声明或协商传输级别安全性 (TLS)/安全套接字层 (SSL) 的使用，以及基于 SASL 的连接范围的身份验证/授权握手。
Azure 服务总线或 Azure 事件中心随时都需要使用 TLS。 它支持通过 TCP 端口 5671 的连接，因此 TCP 连接在进入 AMQP 协议握手前先与 TLS 重叠；它还支持通过 TCP 端口 5672 的连接，因此服务器使用 AMQP 规定的模型，立即提供强制的 TLS 连接升级。 AMQP WebSockets 绑定创建基于 TCP 端口 443 的隧道，其相当于 AMQP 5671 连接。
在设置连接和 TLS 之后，服务总线提供两个 SASL 机制选项：
- SASL PLAIN 常用于将用户名和密码凭据发送到服务器。 服务总线没有帐户，但是有命名的共享访问安全规则，这些规则可授予权限并与某个密钥关联。 规则名称可作为用户名，而密钥（如 base64 编码文本）可作为密码。 与所选规则关联的权限控管允许在连接上进行的操作。
- 当客户端想要使用稍后所述的基于声明的安全 (CBS) 模型时，SASL ANONYMOUS 可用于绕过 SASL 授权。 使用此选项，即可以匿名方式创建短期的客户端连接，在此连接期间，客户端只能与 CBS 终结点交互，并且 CBS 握手必须完成。
创建传输连接之后，容器各自声明它们愿意处理的帧大小上限；在空闲超时后，如果连接上没有任何活动，它们将单方面断开连接。
它们也声明支持的并发通道数量。 通道是基于连接的单向出站虚拟传输路径。 会话从每个互连的容器获取通道，以形成双向通信路径。
会话具有基于时段的流量控制模型；创建会话时，每一方声明它愿意在接收时段内接受的帧数。 当各方交换帧时，已传输的帧将填满该时段，传输在时段已满时停止，直到该时段使用流程行为原语进行重置或扩展为止（行为原语是 AMQP 术语，表示在双方之间交换的协议级别手势）。
这种基于时段的模型大致类似于 TCP 基于时段的流量控制概念，但属于套接字内的会话级别。 协议提出了一个概念：允许多个并发会话，因此高优先级流量的速度可能快于受限制的正常流量，就像高速公路上有一个快速车道一样。
Azure 服务总线目前只对每个连接使用一个会话。 服务总线标准版的服务总线帧大小上限为 262,144 字节 (256 KB)。 服务总线高级版和事件中心的该上限为 1048576 (100 MB)。 服务总线不强加任何特定会话级别限制时段，但是在链接级别流量控制中定期重置时段（请参阅下一部分）。
连接、通道和会话是暂时性的。 如果基础连接失效，则必须重新创建连接、TLS 隧道、SASL 授权上下文和会话。
AMQP 出站端口要求
通过 TCP 使用 AMQP 连接的客户端需要在本地防火墙中打开端口 5671 和 5672。 如果启用了 EnableLinkRedirect 功能，除了这些端口，可能还需要打开其他端口。 EnableLinkRedirect 是一项新的消息传递功能，它可以在接收消息时跳过一个跃点，从而有助于提高吞吐量。 客户端将开始通过端口范围 104XX 直接与后端服务通信，如下图所示。
如果防火墙阻止了这些端口，则 .NET 客户端将失败，并返回 SocketException（“试图以访问权限所禁止的方式访问套接字”）。 可以通过在连接字符串中设置 EnableAmqpLinkRedirect=false 来禁用该功能，这将强制客户端通过端口 5671 与远程服务通信。
AMQP WebSocket 绑定提供了一种通过 WebSocket 传输建立 AMQP 连接隧道的机制。 此绑定通过 TCP 端口 443 创建隧道，相当于 AMQP 5671 连接。 如果你在防火墙后面，并且该防火墙阻止通过端口 5671、5672 建立 TCP 连接，但允许通过端口 443 (https) 建立 TCP 连接，请使用 AMQP WebSocket。
链接
AMQP 通过链接传输消息。 链接是在能以单个方向传输消息的会话中创建的通信路径；传输状态协商通过链接在已连接方之间双向进行。
任一容器可以在现有的会话中随时创建链接，这使 AMQP 不同于其他许多协议（包括 HTTP 和 MQTT），其中启动传输和传输路径是创建套接字连接之一方的独占权限。
启动链接的容器请求相对的容器接受链接，并且选择发送者或接收者的角色。 因此，任一容器均可启动创建单向或双向通信路径，而后者建模为成对链接。
链接具有名称并与节点关联。 如一开始所述，节点是容器内的通信实体。
在服务总线中，节点直接等同于队列、主题、订阅，或队列或订阅的死信子队列。 AMQP 中使用的节点名称因此是服务总线命名空间内实体的相对名称。 如果队列名为 myqueue，则该名称也是它的 AMQP 节点名称。 主题订阅遵循 HTTP API 约定归类为“订阅”资源集合，因此主题 mytopic 上的订阅 sub 具有 AMQP 节点名称 mytopic/subscriptions/sub。
正在连接的客户端也必须使用本地节点名称来创建链接；服务总线不规范这些节点名称，并且不进行解释。 AMQP 1.0 客户端堆栈通常使用方案，以确保这些暂时节点名称是客户端范围内的唯一名称。
传输
建立链接后，即可通过该链接传输消息。 在 AMQP 中，使用明确的协议手势运行传输（传输行为原语），以通过链接将消息从发送者转到接收者。 传输在“安置好”时完成，这意味着双方已建立该传输结果的共识。
在最简单的情况下，发送者可以选择发送“预先安置”的消息，这意味着客户端对结果不感兴趣，并且接收者不提供任何有关操作结果的反馈。 此模式由服务总线在 AMQP 协议级别支持，但不显示在任何客户端 API 中。
一般情况是发送未安置好的消息，并且接收者使用处置行为原语表示接受或拒绝。 拒绝发生于接收者因为任何原因而无法接受消息时，而拒绝消息包含原因相关信息，这是 AMQP 所定义的错误结构。 如果消息因为服务总线内部的错误而被拒绝，则服务返回该结构内的额外信息，而如果发出支持请求，该信息即可用于提供诊断提示给支持人员。 稍后介绍有关错误的更多详细信息。
“已解除”状态是一种特殊形式的拒绝，表示接收者对传输没有任何技术异议，但对于安置传输也不感兴趣。 该情况的确存在，例如，当消息传递到服务总线客户端，而客户端因为无法执行处理消息所生成的任务（尽管消息传递本身并未出错）而选择“放弃”消息时。 该状态的一个变体是“已修改”状态（这种状态允许在消息解除后进行更改）。 服务总线目前不使用该状态。
AMQP 1.0 规范定义进一步的处置状态（称为“已接收”），其对于处理链接恢复特别有用。 当以前的连接和会话丢失时，链接恢复允许重组链接的状态，以及新连接和会话的任何搁置传递。
服务总线不支持链接恢复；如果客户端失去对服务总线的连接，并且存在挂起的未处理消息传输，该消息传输将会丢失，并且客户端必须重新连接、重建链接，以及重试传输。
同样地，服务总线和事件中心都支持“至少一次”传输，其中的发送者可确保消息已存储并接受，但是不支持在 AMQP 级别的“刚好一次”传输，其中的系统尝试恢复链接并继续协商传递状态，以免重复传输消息。
为了弥补可能的重复发送，服务总线支持重复检测队列和主题（可选功能）。 重复检测在用户定义的时段内记录所有传入消息的消息 ID，并以无消息方式放弃在该相同时段内使用相同消息 ID 发送的所有消息。
流量控制
除了以前介绍过的会话级别流量控制模型以外，每个链接都有自己的流量控制模型。 会话级别流量控制可防止容器必须一次处理太多帧，链接级别流量控制让应用程序负责控制它想要从链接处理的消息数目以及时机。
在链接上，传输只发生于发送者有足够的“链接信用额度”时。 链接信用额度是接收者使用流程行为原语所设置的计数器，其范围是链接。 将链接信用额度分配给发送者时，将通过传递消息来尝试用完该信用额度。 每个消息传递使剩余的链接信用额度减 1。 链接信用额度用完时，传递便停止。
当服务总线采用接收者角色时，则立即提供给发送者充足的链接信用额度，以便立即发送消息。 使用链接信用额度时，服务总线偶尔发送“流程”行为原语给发送者，以更新链接信用额度余额。
采用发送者角色时，服务总线发送消息，用完任何未偿付的链接信用额度。
在 API 级别的“接收”调用转译成由客户端发送到服务总线的“流”行为原语，而服务总线获取队列中第一个可用的未锁定消息，进行锁定并传输，以使用该信用额度。 如果没有可立即传递的消息，由任何链接使用该特定实体创建的任何未偿付额度仍以抵达顺序记录，而消息遭到锁定并且在能够使用任何未偿付额度时传输。
当传输进入“已接受”、“已拒绝”或“已解除”终端状态的其中一种时，消息锁定就会解除。 终端的状态为“已接受”时，将从服务总线中删除消息。 它保留在服务总线中，并会在传输达到任何其他状态时传递给下一个接收者。 服务总线在因为重复拒绝或解除而达到实体所允许的最大传递计数时，自动将消息转到实体死信队列中。
即使是服务总线 API 现今也不直接公开这种选项，较低级别的 AMQP 协议客户端可以使用链接额度模型，通过颁发大量的链接额度，将针对每个接收请求颁发一单位额度的“拉取式”模型变成“推送式”模型，并接收可用的消息，而不需要任何进一步的交互。 通过 ServiceBusProcessor.PrefetchCount 或 ServiceBusReceiver.PrefetchCount 属性设置来支持推送。 如果两者均不为零，则 AMQP 客户端使用它作为链接额度。
在此内容中，务必了解实体内消息锁定的过期时钟在从实体获取消息时启动，而不是在消息放在网络上时启动。 每当客户端通过颁发链接额度来表示接收消息的就绪情况时，因此预期它会积极地拉取网络上的消息并准备好处理它们。 否则消息锁定可能在消息传递之前过期。 使用链接信用流量控制应直接反映出可立即准备处理分派给接收者的可用消息。
以下部分汇总了在不同 API 交互期间行为原语流程的图解概述。 每部分说明不同的逻辑操作。 其中一些交互可能很“缓慢”，这意味着它们可能只在有需要时运行。 直到发送或请求第一个消息，创建消息发送者才造成网络交互。
下表中的箭头显示行为原语流程方向。
创建消息接收者
| 客户端 | 服务总线 |
|---|---|
--> attach(<br/>name={link name},<br/>handle={numeric handle},<br/>role=**receiver**,<br/>source={entity name},<br/>target={client link ID}<br/>) |
客户端作为接收者附加到实体 |
| 附加到链接末尾的服务总线回复 | <-- attach(<br/>name={link name},<br/>handle={numeric handle},<br/>role=**sender**,<br/>source={entity name},<br/>target={client link ID}<br/>) |
创建消息发送者
| 客户端 | 服务总线 |
|---|---|
--> attach(<br/>name={link name},<br/>handle={numeric handle},<br/>role=**sender**,<br/>source={client link ID},<br/>target={entity name}<br/>) |
无操作 |
| 无操作 | <-- attach(<br/>name={link name},<br/>handle={numeric handle},<br/>role=**receiver**,<br/>source={client link ID},<br/>target={entity name}<br/>) |
创建消息发送者（错误）
| 客户端 | 服务总线 |
|---|---|
--> attach(<br/>name={link name},<br/>handle={numeric handle},<br/>role=**sender**,<br/>source={client link ID},<br/>target={entity name}<br/>) |
无操作 |
| 无操作 | <-- attach(<br/>name={link name},<br/>handle={numeric handle},<br/>role=**receiver**,<br/>source=null,<br/>target=null<br/>)<br/><br/><-- detach(<br/>handle={numeric handle},<br/>closed=**true**,<br/>error={error info}<br/>) |
关闭消息接收者/发送者
| 客户端 | 服务总线 |
|---|---|
--> detach(<br/>handle={numeric handle},<br/>closed=**true**<br/>) |
无操作 |
| 无操作 | <-- detach(<br/>handle={numeric handle},<br/>closed=**true**<br/>) |
发送（成功）
| 客户端 | 服务总线 |
|---|---|
--> transfer(<br/>delivery-id={numeric handle},<br/>delivery-tag={binary handle},<br/>settled=**false**,,more=**false**,<br/>state=**null**,<br/>resume=**false**<br/>) |
无操作 |
| 无操作 | <-- disposition(<br/>role=receiver,<br/>first={delivery ID},<br/>last={delivery ID},<br/>settled=**true**,<br/>state=**accepted**<br/>) |
发送（错误）
| 客户端 | 服务总线 |
|---|---|
--> transfer(<br/>delivery-id={numeric handle},<br/>delivery-tag={binary handle},<br/>settled=**false**,,more=**false**,<br/>state=**null**,<br/>resume=**false**<br/>) |
无操作 |
| 无操作 | <-- disposition(<br/>role=receiver,<br/>first={delivery ID},<br/>last={delivery ID},<br/>settled=**true**,<br/>state=**rejected**(<br/>error={error info}<br/>)<br/>) |
接收
| 客户端 | 服务总线 |
|---|---|
--> flow(<br/>link-credit=1<br/>) |
无操作 |
| 无操作 | < transfer(<br/>delivery-id={numeric handle},<br/>delivery-tag={binary handle},<br/>settled=**false**,<br/>more=**false**,<br/>state=**null**,<br/>resume=**false**<br/>) |
--> disposition(<br/>role=**receiver**,<br/>first={delivery ID},<br/>last={delivery ID},<br/>settled=**true**,<br/>state=**accepted**<br/>) |
无操作 |
多消息接收
| 客户端 | 服务总线 |
|---|---|
--> flow(<br/>link-credit=3<br/>) |
无操作 |
| 无操作 | < transfer(<br/>delivery-id={numeric handle},<br/>delivery-tag={binary handle},<br/>settled=**false**,<br/>more=**false**,<br/>state=**null**,<br/>resume=**false**<br/>) |
| 无操作 | < transfer(<br/>delivery-id={numeric handle+1},<br/>delivery-tag={binary handle},<br/>settled=**false**,<br/>more=**false**,<br/>state=**null**,<br/>resume=**false**<br/>) |
| 无操作 | < transfer(<br/>delivery-id={numeric handle+2},<br/>delivery-tag={binary handle},<br/>settled=**false**,<br/>more=**false**,<br/>state=**null**,<br/>resume=**false**<br/>) |
--> disposition(<br/>role=receiver,<br/>first={delivery ID},<br/>last={delivery ID+2},<br/>settled=**true**,<br/>state=**accepted**<br/>) |
无操作 |
消息
以下部分说明服务总线使用标准 AMQP 消息部分中的哪些属性，以及它们如何映射到服务总线 API 集。
任何应用程序需要定义的属性都应映射至 AMQP 的 application-properties 映射。
头文件
| 字段名称 | 使用情况 | API 名称 |
|---|---|---|
| durable | - | - |
| priority | - | - |
| ttl | 消息生存时间 | TimeToLive |
| first-acquirer | - | - |
| delivery-count | - | DeliveryCount |
属性
| 字段名称 | 使用情况 | API 名称 |
|---|---|---|
message-id |
应用程序为此消息定义的自由格式标识符。 用于重复检测。 | MessageId |
user-id |
应用程序定义的用户标识符，服务总线无法进行解释。 | 无法通过服务总线 API 访问。 |
to |
应用程序定义的目标标识符，服务总线无法进行解释。 | 操作 |
subject |
应用程序定义的消息用途标识符，服务总线无法进行解释。 | 主题 |
reply-to |
应用程序定义的回复路径指示符，服务总线无法进行解释。 | ReplyTo |
correlation-id |
应用程序定义的相关性标识符，服务总线无法进行解释。 | CorrelationId |
content-type |
应用程序定义的内容类型指示符，服务总线无法进行解释。 | ContentType |
content-encoding |
应用程序定义的内容编码指示符，服务总线无法进行解释。 | 无法通过服务总线 API 访问。 |
absolute-expiry-time |
声明消息过期的绝对时刻。 在输入时忽略（观察到标头 TTL），在输出时授权具权威性。 | 无法通过服务总线 API 访问。 |
creation-time |
声明消息的创建时间。 不由服务总线使用 | 无法通过服务总线 API 访问。 |
group-id |
应用程序为相关的消息集定义的标识符。 用于服务总线会话。 | SessionId |
group-sequence |
用于标识消息在会话内的相对序列号的计数器。 服务总线会将其忽略。 | 无法通过服务总线 API 访问。 |
reply-to-group-id |
- | ReplyToSessionId |
消息注释
存在几个不属于 AMQP 消息属性的其他服务总线消息属性，且它们在消息上作为 MessageAnnotations 传递。
| 注释映射键 | 使用情况 | API 名称 |
|---|---|---|
x-opt-scheduled-enqueue-time |
声明消息应于何时出现在实体上 | ScheduledEnqueueTime |
x-opt-partition-key |
应用程序定义的键，指示消息应进入哪个分区。 | PartitionKey |
x-opt-via-partition-key |
应用程序定义的分区键值，指示某个事务在何时用于通过传输队列发送消息。 | TransactionPartitionKey |
x-opt-enqueued-time |
服务定义的 UTC 时间，代表将消息加入队列的实际时间。 输入时忽略。 | EnqueuedTime |
x-opt-sequence-number |
服务定义的唯一编号，用于分配给消息。 | SequenceNumber |
x-opt-offset |
服务定义的消息的排队序列号。 | EnqueuedSequenceNumber |
x-opt-locked-until |
服务定义。 日期和时间，在此之前消息将在队列/订阅中被锁定。 | LockedUntil |
x-opt-deadletter-source |
服务定义。 如果从死信队列中接收消息，则该队列表示原始消息的来源。 | DeadLetterSource |
事务功能
一个事务将两个或更多操作组合成执行作用域。 就本质而言，此类事务必须确保所有操作属于给定的操作组，无论联合成功还是失败。
操作按标识符 txn-id 分组。
对于事务性交互，客户端充当 transaction controller，控制着应该一起被分组的操作。 服务总线服务充当 transactional resource 并根据 transaction controller 的请求执行工作。
客户端和服务通过该客户端建立的 control link 进行通信。 declare 和 discharge 消息由控制器通过控制链接发送，从而各自分配并完成事务（它们不代表事务性工作的划分）。 实际的发送/接收工作不是在此链接上执行的。 所请求的每个事务性操作通过所需 txn-id 显式标识，因此可能出现于连接上的任何链接。 如果关闭了控制链接，但是还存在它所创建的未释放事务，则所有此类事务都将立即回滚，且针对它们执行进一步的事务性工作的尝试都将导致失败。 不能预先确定控制链接上的消息。
每个连接都需要启动自己的控制链接，才能开始并结束事务。 该服务定义一个充当 coordinator 的特殊目标。 客户端/控制器建立了指向该目标的控制链接。 控制链接不受单个实体限制，即同样的控制链接可用于启动并释放多个实体的事务。
启动事务
若要开始事务性工作，控制器必须从协调器获取一个 txn-id。 通过发送 declare 类型消息完成此操作。 如果声明成功，协调器会响应一个处置结果，其中包含分配的 txn-id。
| 客户端（控制器） | 方向 | 服务总线（协调器） |
|---|---|---|
| attach( name={link name}, ... ， role=sender, target=Coordinator ） |
------> | |
| <------ | attach( name={link name}, ... ， target=Coordinator() ） |
|
| transfer( delivery-id=0, ...) { AmqpValue (Declare() )} |
------> | |
| <------ | disposition( first=0, last=0, state=Declared( txn-id={transaction ID} ）） |
释放事务
控制器通过向协调器发送 discharge 消息来推断事务性工作。 控制器通过在释放正文上设置 fail 标志，指示它希望提交或回滚该事务性工作。 如果协调器无法完成释放操作，消息将被拒绝且结果中带有 transaction-error。
请注意：fail=true 表示事务回滚，fail=false 表示提交。
| 客户端（控制器） | 方向 | 服务总线（协调器） |
|---|---|---|
| transfer( delivery-id=0, ...) { AmqpValue (Declare())} |
------> | |
| <------ | disposition( first=0, last=0, state=Declared( txn-id={transaction ID} ）） |
|
| 。 。 。 其他链接上的 事务性工作 。 。 。 |
||
| transfer( delivery-id=57, ...) { AmqpValue ( Discharge(txn-id=0, fail=false))} |
------> | |
| <------ | disposition( first=57, last=57, state=Accepted() ) |
在事务中发送消息
所有事务性工作是通过承载 txn-id 的事务性传递状态 transactional-state 完成的。在发送消息时，transactional-state 由消息的传输框架承载。
| 客户端（控制器） | 方向 | 服务总线（协调器） |
|---|---|---|
| transfer( delivery-id=0, ...) { AmqpValue (Declare())} |
------> | |
| <------ | disposition( first=0, last=0, state=Declared( txn-id={transaction ID} ）） |
|
| transfer( handle=1, delivery-id=1, state= TransactionalState( txn-id=0)) { payload } |
------> | |
| <------ | disposition( first=1, last=1, state=TransactionalState( txn-id=0, outcome=Accepted())) |
在事务中处置消息
消息处置包括类似 Complete / Abandon / DeadLetter / Defer 的操作。 若要在事务中执行这些操作，请通过 disposition 传递 transactional-state。
| 客户端（控制器） | 方向 | 服务总线（协调器） |
|---|---|---|
| transfer( delivery-id=0, ...) { AmqpValue (Declare())} |
------> | |
| <------ | disposition( first=0, last=0, state=Declared( txn-id={transaction ID} ）） |
|
| <------ | transfer( handle=2, delivery-id=11, state=null) { payload } |
|
| disposition( first=11, last=11, state=TransactionalState( txn-id=0, outcome=Accepted())) |
------> |
高级服务总线功能
本部分介绍 Azure 服务总线的高级功能，这些功能基于 AMQP 的 OASIS 技术委员会目前正在开发的 AMQP 草稿扩展。 服务总线实现这些草稿的最新版本，并且采用这些草稿达到标准状态时所引进的更改。
注意
服务总线消息高级操作通过请求/响应模式受到支持。 服务总线中的 AMQP 1.0：基于请求/响应的操作文章中详细介绍了这些操作。
AMQP 管理
AMQP 管理规范是本文中介绍的第一个草稿扩展。 此规范定义一组基于 AMQP 协议的协议，以便通过 AMQP 进行消息基础结构的管理交互。 此规范定义泛型操作（例如“创建”、“读取”、“更新”和“删除”），以便管理消息传送基础结构内的实体和一组查询操作。
上述所有手势都需要客户端与消息传送基础结构之间的请求/响应交互，因此此规范定义如何制作 AMQP 上交互模式的模型：客户端连接到消息传送基础结构、启动会话，并创建一组链接。 在某一个链接上，客户端扮演发送者，而在其他链接上扮演接收者，因此创建一组可作为双向通道的链接。
| 逻辑运算 | 客户端 | 服务总线 |
|---|---|---|
| 创建请求响应路径 | --> attach(<br/>name={*link name*},<br/>handle={*numeric handle*},<br/>role=**sender**,<br/>source=**null**,<br/>target="myentity/$management"<br/>) |
无操作 |
| 创建请求响应路径 | 无操作 | \<-- attach(<br/>name={*link name*},<br/>handle={*numeric handle*},<br/>role=**receiver**,<br/>source=null,<br/>target="myentity"<br/>) |
| 创建请求响应路径 | --> attach(<br/>name={*link name*},<br/>handle={*numeric handle*},<br/>role=**receiver**,<br/>source="myentity/$management",<br/>target="myclient$id"<br/>) |
|
| 创建请求响应路径 | 无操作 | \<-- attach(<br/>name={*link name*},<br/>handle={*numeric handle*},<br/>role=**sender**,<br/>source="myentity",<br/>target="myclient$id"<br/>) |
准备好该组链接，请求/响应实现就相当简单：请求是发送到消息传送基础结构内了解此模式之实体的消息。 在该请求消息中，properties 部分中的 reply-to 字段设置为链接（此响应要传递到的链接）的 target 标识符。 处理实体会处理此请求，并通过“target”标识符匹配所示“reply-to”标识符的链接传递回复 。
显然，该模式要求回复目标的客户端容器和客户端生成的标识符在所有客户端中是唯一的，并且出于安全原因，还要难以预测。
用于管理协议和所有使用相同模式的其他协议的消息交换发生在应用程序级别；它们不回定义新的 AMQP 协议级别手势。 这是刻意设计的，以便应用程序立即使用与 AMQP 1.0 堆栈兼容的这些扩展。
服务总线目前不会实现管理规范的任何核心功能，但是对基于声明的安全性功能以及将在以下部分中讨论的几乎所有高级功能而言，管理规范所定义的请求/响应模式属于基础性内容：
基于声明的授权
AMQP 基于声明的授权 (CBS) 规范草案基于管理规范的请求/响应模式，主要说明如何配合使用联合安全令牌与 AMQP 的广义模型。
简介中所述的 AMQP 默认安全模型基于 SASL，并与 AMQP 连接握手集成。 使用 SASL 的好处是它提供已定义一组机制的可扩展模型，任何正式依赖 SASL 的协议均可受益。 在这些机制之中，“PLAIN”用于传输用户名和密码，“EXTERNAL”用于绑定到 TLS 级别安全，“ANONYMOUS”用于表示缺少显式身份验证/授权，还有其他各种机制能够用于传递身份验证和/或授权凭据或令牌。
AMQP 的 SASL 集成有两个缺点：
- 所有凭据与令牌的范围都只限于连接。 消息传送基础结构可能需要根据每个实体提供不同的访问控制；例如，允许令牌的持有者发送到队列 A，而不是到队列 B。使用固定在连接上的授权上下文，就不可能使用单个连接并且对队列 A 和 B 使用不同的访问令牌。
- 访问令牌的有效时间通常有限。 此有效性要求用户定期重新获取令牌，而如果用户的访问权限已更改，令牌的颁发者便有机会拒绝颁发刷新令牌。 AMQP 连接可能持续很长时间。 SASL 模型只提供一个机会在连接时设置令牌，这意味着消息传送基础结构必须在令牌过期时断开客户端的连接，或者必须接受允许与访问权限可能已在其间吊销的客户端持续通信的风险。
服务总线实现的 AMQP CBS 规范可让这两个问题获得圆满的解决：它可让客户端创建访问令牌与每个节点的关联，以及在这些令牌过期前进行更新，而无需中断消息流。
CBS 定义由消息传送基础结构所提供的虚拟管理节点（名为 $cbs）。 管理节点可代表消息传送基础结构中的任何其他节点接受令牌。
协议手势是管理规范定义的请求/回复交换。 这意味着客户端使用 $cbs 节点创建一组链接，在输出链接上传递请求，并在输入链接上等待响应。
请求消息具有以下应用程序属性：
| 键 | 可选 | 值类型 | 值内容 |
|---|---|---|---|
operation |
否 | string | put-token |
type |
否 | string | 正在放置的令牌类型。 |
name |
否 | string | 令牌应用到的“受众”。 |
expiration |
是 | timestamp | 令牌过期时间。 |
name 属性标识应与此令牌关联的实体。 在服务总线中，这是队列或主题/订阅的路径。 type 属性标识令牌类型：
| 令牌类型 | 令牌说明 | 正文类型 | 注释 |
|---|---|---|---|
jwt |
JSON Web 令牌 (JWT) | AMQP 值（字符串） | |
servicebus.chinacloudapi.cn:sastoken |
服务总线 SAS 令牌 | AMQP 值（字符串） | - |
令牌赋予权限。 服务总线识别三个基本权限：“发送”允许发送、“侦听”允许接收，“管理”允许操作实体。 服务总线 SAS 令牌引用在命名空间或实体上配置的规则，这些规则是使用权限配置的。 使用与该规则关联的密钥来签名令牌，以此方式让令牌表达各自的权限。 与使用 put-token 的实体关联的令牌将允许已连接的客户端根据每个令牌权限来与实体交互。 客户端承担 sender 角色的链接需要“发送”权限，而承担 receiver 角色的链接则需要“侦听”权限。
回复消息具有以下 application-properties 值
| 键 | 可选 | 值类型 | 值内容 |
|---|---|---|---|
status-code |
否 | int | HTTP 响应代码 [RFC2616] 。 |
status-description |
是 | string | 状态的说明。 |
客户端可以针对消息传送基础结构中的任何实体重复调用 put-token 。 令牌的范围是当前客户端且定位点为当前连接，这意味着服务器在删除连接时会删除所有保留的令牌。
当前服务总线实现只允许 CBS 与 SASL 方法 “ANONYMOUS”结合。在 SASL 握手之前，必须始终存在 SSL/TLS 连接。
因此所选的 AMQP 1.0 客户端必须支持 ANONYMOUS 机制。 匿名访问表示发生初始连接握手（包括创建初始会话），而服务总线不知道谁正在创建此连接。
创建连接和会话后，将链接附加到 $cbs 节点和发送 put-token 请求是唯一允许的操作。 必须在创建连接后的 20 秒内使用对某个实体节点的 put-token 请求成功创建有效的令牌，否则服务总线将单方面断开连接。
客户端后续负责跟踪令牌过期时间。 令牌过期时，服务总线立即删除相应实体连接上的所有链接。 为防止出现问题，客户端随时可以通过具有相同 put-token 手势的虚拟 $cbs 管理节点，使用新的令牌来替换节点的令牌，且不干扰在不同链接上流动的有效负载流量。
发送方式功能
发送方式/传输发送者功能让服务总线能通过另一个实体将给定消息转发到目标实体。 此功能用于在单个事务中执行跨实体的操作。
借助此项功能，可以创建发送程序并建立指向 via-entity 的链接。 在建立链接时，会传递其他信息以建立此链接上的消息/传输的正确目标。 附加成功后，此链接上发送的所有消息都会自动通过 via-entity 转发到 destination-entity 。
注意：在建立此链接前，via-entity 和 destination-entity 都需要通过身份验证。
| 客户端 | 方向 | 服务总线 |
|---|---|---|
attach(<br/>name={link name},<br/>role=sender,<br/>source={client link ID},<br/>target=**{via-entity}**,<br/>**properties=map [(<br/>com.microsoft:transfer-destination-address=<br/>{destination-entity} )]** ) |
------> | |
| <------ | attach(<br/>name={link name},<br/>role=receiver,<br/>source={client link ID},<br/>target={via-entity},<br/>properties=map [(<br/>com.microsoft:transfer-destination-address=<br/>{destination-entity} )] ) |
后续步骤
若要详细了解 AMQP，请参阅服务总线 AMQP 概述。