Compartir a través de

异步消息传送模式和高可用性

可以通过多种不同的方式实现异步消息传送。 对于队列、主题和订阅,Azure 服务总线通过存储和转发机制支持异步。 在正常(同步)操作中,会将消息发送到队列和主题,并从队列和主题接收消息。 编写的应用程序依赖于这些始终可用的实体。 当实体运行状况因各种环境而发生变化时,需要一种能够提供满足大多数需求的缩减功能实体的方式。

应用程序通常使用异步消息传送模式来实现大量通信方案。 可以构建一些应用程序,以便客户端在其中可以向服务发送消息(即使该服务未运行)。 对于将经历大量通信的应用程序,队列可以通过提供缓冲通信的场所,帮助对负载进行分级。 最后,可以获得一个简单而高效的负载均衡器,从而在多台计算机间分发消息。

为了维护任何这些实体的可用性,请考虑表达这些实体可能不可用的多种方式,从而构建持久的消息传送系统。 一般来说,我们通过以下不同的方式发现实体对我们编写的应用程序不可用:

  • 无法发送消息。
  • 无法接收消息。
  • 无法管理实体(创建、检索、更新或删除实体)。
  • 无法与服务取得联系。

对于以上每种故障,存在不同的故障模式,从而使应用程序能够在某种程度功能缩减的情况下继续执行工作。 例如,可以发送消息但无法接收消息的系统仍可以从客户接收指令,但无法处理这些指令。 本主题讨论了可能发生的潜在问题,以及如何缓解这些问题。 服务总线引入了必须选择加入的大量缓解措施,本主题还介绍了管理这些选择性加入缓解措施的规则。

服务总线可靠性

可通过多种方式来处理消息和实体问题,有一套对这些缓解措施的恰当使用进行管理的准则。 要了解这些准则,必须先了解服务总线中可能出现的故障。 由于 Azure 系统的设计,所有这些故障往往都是短期的。 在高级别中,引起不可用的各种原因如下所示:

  • 来自服务总线所依赖的外部系统的限制。 与存储和计算资源的交互存在限制。
  • 服务总线所依赖的系统出现问题。 例如,存储的给定部分可能遇到问题。
  • 单个子系统上出现服务总线故障。 在此情况下,计算节点可能会陷入不一致状态而必须重新启动其自身,从而导致它负责处理的所有实体负载均衡到其他节点。 这又可能导致短时间内消息处理变慢。
  • Azure 数据中心的服务总线发生故障。 这是“灾难性故障”,无论故障时间是数分钟还是几小时,在此期间都无法访问系统。

注意

“存储”这一术语既能表示 Azure 存储又能表示 SQL Azure。

服务总线包含了针对这些问题的许多缓解措施。 以下各节介绍了每个问题及其相应的缓解措施。

限制

通过服务总线,设置限制可以实现协作消息速率管理。 每个单独的服务总线节点包含许多实体。 其中每个实体都需要在 CPU、内存、存储和其他方面占用系统。 当上述任一方面检测到超出定义阈值的使用情况时,服务总线可以拒绝给定的请求。 调用方会接收到服务器繁忙异常,并在 10 秒后重试。

作为一种缓解措施,该代码必须读取错误并停止该消息的任何重试至少 10 秒。 由于错误可能发生在多个客户应用程序之间,所以最好允许每个应用程序独立执行重试逻辑。 该代码可以通过对命名空间、队列或主题启用分区来减少受限概率。

有关应用程序代码应如何处理限制问题的详细信息,请参阅有关限制模式的文档

Azure 依赖项的问题

Azure 中的其他组件可能偶尔会发生服务问题。 例如,当服务总线使用的系统正在升级时,该系统可能会暂时出现功能缩减。 为了解决这些类型的问题,服务总线会定期进行调查并实施缓解措施。 这些缓解措施的副作用的确存在。 例如,为了处理存储的暂时性问题,服务总线通过实现系统来允许消息发送操作持续工作。 由于缓解措施的性质,发送的消息可能最多需要 15 分钟才能在受影响的队列或订阅中显示以及才可以接收得到。 一般而言,大多数实体不会遇到此问题。 但是,考虑到 Azure 服务总线中的实体数,有时需要为服务总线客户的一小部分实施此缓解措施。

单个子系统上的服务总线故障

使用任何应用程序时,环境都可能导致服务总线的内部组件出现不一致。 当服务总线检测到这种不一致时,它从该应用程序收集数据以辅助诊断问题。 收集到数据后,会重新启动该应用程序以尝试使其返回一致状态。 此过程发生得相当迅速,并且会导致实体长达数分钟不可用,而典型的停机时间则要短得多。

在这些情况下,客户端应用程序将生成超时异常或消息传送异常。 服务总线通过自动客户端重试逻辑来缓解该问题。 如果重试周期用尽而未能传递消息,可以尝试使用关于处理中断和灾难问题的文章中所述的其他功能进行研究。

后续步骤

了解服务总线中的异步消息传送的基础知识后,可阅读有关处理中断和灾难问题的详细信息。