通过

你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

服务总线中的高级消息队列协议 (AMQP) 1.0 支持

  • 项目

Azure 服务总线云服务使用 AMQP 1.0 作为其主要通信方式。 在过去的十年中，Microsoft 与行业内的合作伙伴（相互竞争的消息传递代理的客户和供应商）开展合作，开发和发展 AMQP，并在 OASIS AMQP 技术委员会中开发了新的扩展。 AMQP 1.0 是 ISO 和 IEC 标准 (ISO 19464:20149)。

通过 AMQP 可使用独立于供应商和实现的开放标准协议构建跨平台的混合应用程序。 可以借助使用不同语言和框架构建的且运行在不同操作系统上的组件来构建应用程序。 所有这些组件均可连接到服务总线，并且能够高效且完全无损地无缝交换结构化业务消息。

简介：什么是 AMQP 1.0，为何它很重要？

通常，面向消息的中间件产品始终使用专用协议来支持客户端应用程序和代理之间的通信。 这意味着，在选择特定供应商的消息传递代理后，必须使用该供应商的库将客户端应用程序连接到该代理。 这会导致在一定程度上依赖于该供应商，因为将应用程序移植到其他产品需要对所有已连接应用程序进行代码改写。 在 Java 社区中，特定于语言的 API 标准（如 Java 消息服务 (JMS)）和 Spring Framework 的抽象在某种程度上缓和了这一痛点，但其功能范围非常窄，并且会将使用其他语言的开发人员排除在外。

此外，连接来自不同供应商的消息传递代理比较棘手。 这通常需要通过应用程序级桥接来将消息从一个系统移到另一个系统，并在其专用消息格式之间进行转换。 这是一个常见的要求；例如，在必须向较旧的独立系统提供新的统一接口时，或者在合并后集成 IT 系统时，会有这样的要求。 AMQP 允许与连接代理直接互连，例如使用 Apache Qpid Dispatch Router 之类的路由器或 RabbitMQ 之类的代理本机“铲子”。

软件产业是一个飞速发展的产业；新编程语言和应用程序框架的引入速度有时会非常惊人。 同样，IT 系统的要求随着时间不断变化，并且开发人员希望利用最新的平台功能。 但有时候，所选消息传送供应商不支持这些平台。 如果使用的是专用消息协议，其他供应商无法为这些新平台提供库。 因此，必须使用构建网关等手段，或者可让你继续使用消息传递产品的网桥。

这些问题推动了高级消息队列协议 (AMQP) 1.0 的开发。 这种协议源于 JP Morgan Chase，像多数金融服务公司一样，该公司大量使用面向消息的中间件。 目标非常简单：就是创建一个开放标准消息传送协议，从而能够借助使用不同语言、框架和操作系统构建的组件来构建基于消息的应用程序，而所有这些应用程序都使用各个供应商提供的同类最佳组件。

AMQP 1.0 技术特性

AMQP 1.0 是一个高效、可靠的线级消息传递协议，可用于构建强大、跨平台的消息传递应用程序。 协议有一个简单的目标：定义用于在两方之间安全、可靠且高效传输消息的机制。 这些消息本身使用可移植数据表示进行编码，这种表示支持不同发送者和接收者完全无损地交换结构化业务消息。 下面简要介绍几个最重要的特性：

  • 高效：AMQP 1.0 是一个面向连接的协议，它将二进制编码用于协议指令以及通过该协议传输的业务消息。 它融合了复杂的流控制方案，可最大限度地利用网络和已连接组件。 即便如此，但该协议的设计目的是实现有效性、灵活性和互操作性之间的平衡。
  • 可靠：使用 AMQP 1.0 协议交换消息时，可获得一系列可靠性保证，如即发即弃 (fire-and-forget) 和可靠的恰一次确认传送 (exactly-once acknowledged delivery)。
  • 灵活：AMQP 1.0 是一个灵活的协议，可用于支持不同的拓扑。 可以将同一协议用于客户端到客户端、客户端到代理以及代理到代理通信。
  • 独立于代理模型：AMQP 1.0 规范对代理所使用的消息传送模型不作任何要求。 这意味着可以向现有消息传送代理中轻松添加 AMQP 1.0 支持。

AMQP 1.0 是一种标准（带有大写字母“S”）

AMQP 1.0 是一种国际标准，已通过 ISO 和 IEC 的认证，认证编号为 ISO/IEC 19464:2014。

自 2008 年以来，AMQP 1.0 一直由一个由 20 多家公司（包括技术提供商和最终用户企业）组成的核心小组进行开发。 在此期间，用户企业提供其实际业务需求，技术供应商则开发该协议来满足这些需求。 在整个过程中，供应商参加了研讨会，并在会上协作验证了其实现之间的互操作性。

2011 年 10 月，开发工作提交给结构化信息标准促进组织（Organization for the Advancement of Structured Information Standards，OASIS）内的技术委员会，随后 OASIS AMQP 1.0 标准于 2012 年 10 月发布。 在开发该标准期间，以下公司参与了技术委员会的工作：

  • 技术供应商：Axway Software、Huawei Technologies、IIT Software、INETCO Systems、Kaazing、Microsoft、Mitre Corporation、Primeton Technologies、Progress Software、Red Hat、SITA、Software AG、Solace Systems、VMware、WSO2、Zenika。
  • 企业用户：Bank of America、Credit Suisse、Deutsche Boerse、Goldman Sachs、JPMorgan Chase。

OASIS AMQP 技术委员会的现任主席代表 Red Hat 和 Microsoft。

开放标准的公认好处包括：

  • 供应商锁定的几率较低
  • 互操作性
  • 有大量库和工具可供使用
  • 不会过时
  • 随时可找到知识渊博的工作人员
  • 风险较低且可控

AMQP 1.0 和 Service Bus

Azure 服务总线中对 AMQP 1.0 的支持意味着，你可以通过一系列使用有效二进制协议的平台来使用服务总线队列，以及发布/订阅中转消息传送功能。 此外，还可以生成由结合使用多个语言、框架和操作系统构建的组件组成的应用程序。

下图显示了一个部署示例，其中 Java 客户端运行在 Linux 上，并使用标准 Java 消息服务 (JMS) API 写入数据；而 .NET 客户端运行在 Windows 上，并通过服务总线使用 AMQP 1.0 交换消息。

此图显示一个服务总线交换消息，其中包含两个 Linux 环境和两个 Windows 环境。

图 1：演示使用服务总线和 AMQP 1.0 进行跨平台消息传送的部署方案示例

通过 Azure SDK 提供的所有受支持的服务总线客户端库均使用 AMQP 1.0。

与 HTTP/REST API 一样，AMQP-over-WebSockets 协议选项通过端口 TCP 443 运行，但在功能上与普通 AMQP 相同。 由于额外的握手往返，此选项的初始连接延迟较高，并且作为共享 HTTPS 端口的折衷方案，此选项的开销略高。 如果选择此模式，TCP 端口 443 足以进行通信。 以下选项允许选择 AMQP WebSockets 模式。

语言 选项
.NET (Azure.Messaging.ServiceBus) 使用将 ServiceBusClientOptions 用作参数的构造函数创建 ServiceBusClient。 将 ServiceBusClientOptions.TransportType 设置为 ServiceBusTransportType.AmqpWebSockets
.NET (Microsoft.Azure.ServiceBus) 创建客户端对象时，请使用将 TransportType、ServiceBusConnection 或 ServiceBusConnectionStringBuilder 用作参数的构造函数。

对于采用 transportType 作为参数的构造，请将参数设置为 TransportType.AmqpWebSockets。

对于采用 ServiceBusConnection 作为参数的构造函数，请将 ServiceBusConnection.TransportType 设置为TransportType.AmqpWebSockets。

如果使用 ServiceBusConnectionStringBuilder，则使用可让你选择指定 transportType 的构造函数。
Java (com.azure.messaging.servicebus) 创建客户端时，请将 ServiceBusClientBuilder.transportType 设置为 AmqpTransportType.AMQP.AMQP_WEB_SOCKETS
Java (com.microsoft.azure.servicebus) 创建客户端时，请将 com.microsoft.azure.servicebus.ClientSettings 中的 transportType 设置为 com.microsoft.azure.servicebus.primitives.TransportType.AMQP_WEB_SOCKETS
JavaScript 在创建服务总线客户端对象时，请使用 ServiceBusClientOptions 中的 webSocketOptions 属性。
Python 在创建服务总线客户端时，请将 ServiceBusClient.transport_type 设置为 TransportType.AmqpOverWebSocket

2026 年 9 月 30 日，我们将停用 Azure 服务总线 SDK 库 WindowsAzure.ServiceBus、Microsoft.Azure.ServiceBus 和 com.microsoft.azure.servicebus，这些库不符合 Azure SDK 准则。 我们还将结束对 SBMP 协议的支持，因此在 2026 年 9 月 30 日之后，你将无法再使用此协议。 请在该日期之前迁移到最新的 Azure SDK 库，新库提供了关键安全更新和改进功能。

尽管 2026 年 9 月 30 日之后仍然可以使用较旧的库，但它们将不再获得 Microsoft 的官方支持和更新。 有关详细信息，请参阅支持停用公告。

此外，还可以使用任何 AMQP 1.0 兼容协议堆栈中的服务总线：

语言 库
Java Apache Qpid Proton-J
C/C++ Azure uAMQP C、Apache Qpid Proton-C
Python Azure uAMQP for Python、Apache Qpid Proton Python）
PHP Azure uAMQP for PHP
Ruby Apache Qpid Proton Ruby
Go Azure Go AMQP、Apache Qpid Proton Go
C#/F#/VB AMQP .NET Lite、Apache NMS AMQP
JavaScript/Node Rhea

总结

  • AMQP 1.0 是一个开放、可靠的消息传递协议，可用于构建跨平台的混合应用程序。 AMQP 1.0 是一种 OASIS 标准。

后续步骤

准备好了解详细信息？ 请访问以下链接：