会话优先级

会话优先级的用途

会话优先级可用于执行以下操作：

• 标识会话是否优先于其他会话。

• 支持不同的服务层，其中，支付较高价格的客户的消息先发送，支付较低价格的客户的消息后发送。

• 优先处理客户请求而非后台任务。例如，新客户注册应比向数据仓库发送业务事务摘要具有更高的优先级。

会话优先级与会话端点

会话优先级是使用 CREATE BROKER PRIORITY 语句在每个数据库中创建的。每个会话优先级均定义了以下内容：

• 会话优先级的名称。

• 分配给 Service Broker 会话的优先级别。该级别被指定为从 1（最低）到 10（最高）的整数。默认值为 5。

• 用于确定优先级别应用于哪些会话的条件如下：

  • 约定名称或 ANY。

  • 本地服务名称或 ANY。

  • 远程服务名称或 ANY。

Service Broker 在创建会话端点时为其分配优先级别。每个会话均有两个会话端点：

• 发起方会话端点将会话的一端与发起方服务和发起方队列相关联。发起方会话端点是在运行 BEGIN DIALOG 语句时创建的。与发起方会话端点关联的操作包括：

  • 从发起方服务发送。

  • 从发起方队列接收。

  • 从发起方队列获取下一个会话组。

• 目标会话端点将会话的另一端与目标服务和队列相关联。目标会话端点是在将来自发起方的第一个消息放入目标队列时创建的。与目标会话端点关联的操作包括：

  • 从目标队列接收。

  • 从目标服务发送。

  • 从目标队列获取下一个会话组。

哪个服务被认定为本地或远程服务取决于会话端点的类型：

• 对于发起方会话端点，发起方服务为本地服务，目标服务为远程服务。

• 对于目标会话端点，目标服务为本地服务，发起方服务为远程服务。

Service Broker 如何分配优先级别

Service Broker 在创建会话端点时分配会话优先级别。会话端点将优先级别一直保留到会话结束。新的优先级或对现有优先级的更改都不会应用于现有会话。

Service Broker 将约定和服务条件与端点属性最匹配的会话优先级中的优先级别分配给会话端点。下表显示了匹配优先顺序：

Service Broker 首先寻找其指定的约定、本地服务和远程服务与会话端点所用的约定、本地服务和远程服务匹配的优先级。如果找不到，Service Broker 将接着寻找约定和本地服务与端点所用的约定和本地服务匹配且远程服务被指定为 ANY 的优先级。此过程会一直继续下去，直到优先顺序表中列出的所有变体均已比对过为止。如果未找到匹配项，将为端点分配默认优先级 5。

Service Broker 通信协议不在会话端点间传输优先级别。Service Broker 独立地为每个端点分配一个优先级别。若要让 Service Broker 将优先级别同时分配给发起方会话端点和目标会话端点，必须确保会话优先级同时涵盖这两个端点。如果发起方会话端点和目标会话端点分别在不同的数据库中，则必须在每个数据库中创建会话优先级。如果发起方端点和目标端点在同一个数据库中：

• 可以使用一个会话优先级同时涵盖两个会话端点，该会话优先级要指定会话所用的约定名称并为本地和远程服务名称均指定 ANY。

• 可以使用两个会话优先级分别涵盖每个会话端点：

  • 一个针对发起方端点的会话，为 LOCAL_SERVICE_NAME 指定发起方服务名称，并为 REMOTE_SERVICE_NAME 指定目标服务名称。

  • 一个针对目标端点的会话，为 LOCAL_SERVICE_NAME 指定目标服务名称，并为 REMOTE_SERVICE_NAME 指定发起方服务名称。

通常为会话的两个会话端点指定相同的优先级别。尽管可以为每个端点指定不同的优先级别，但这样做并不意味着某个方向的消息发送速度会比另一个方向快。消息从一个会话端点发出，在另一个端点上接收。因此，每次消息传输都会受到分配给这两个端点的优先级别的影响。例如，您可以配置一个会话，使发起方会话端点的优先级别为 10，而目标端点的优先级别为 1。在这种情况下：

• 消息从发起方服务传输时使用优先级别 10，从目标队列接收时使用优先级别 1。

• 消息从目标服务传输时使用优先级别 1，从发起方队列接收时使用优先级别 10。

在以下情况下，分配给会话组的优先级别与分配给任意会话的最高优先级别相同：

• 会话是组的成员。

• 会话当前在服务队列中拥有消息。

如果未在数据库中创建任何会话优先级，将为数据库中的所有会话端点分配默认优先级 5。

会话优先级不会影响消息转发，消息转发总是采用默认优先级 5。

会话优先级示例

假定系统配置如下：

• 一个 InitiatorDB，其中包含 InitiatorService 和 InitiatorQueue。

• 一个 TargetDB，其中包含 TargetService 和 TargetQueue。

• 一个名为 SimpleContract 的约定，指定将 RequestMessages 从 InitiatorService 发送到 TargetService。它还指定将 ReplyMessages 从 TargetService 发送到 InitiatorService。

此脚本指定发起方会话端点的优先级别及其关联操作：

• 将 RequestMessage 从 InitiatorService 发送到 TargetQueue 的 SEND。

• 从 InitiatorQueue 接收 ReplyMessage 的 RECEIVE。

USE InitiatorDB;
GO
CREATE BROKER PRIORITY InitiatorToTargetPriority
    FOR CONVERSATION
    SET (CONTRACT_NAME = SimpleContract,
         LOCAL_SERVICE_NAME = InitiatorSerivce,
         REMOTE_SERVICE_NAME = N'TargetService',
         PRIORITY_LEVEL = 3);
GO

此脚本指定目标会话端点的优先级别及其关联操作：

• 从 TargetQueue 接收 RequestMessage 的 RECEIVE。

• 将 ReplyMessage 从 TargetService 发送到 InitiatorQueue 的 SEND。

USE TargetDB;
GO
CREATE BROKER PRIORITY TargetToInitiatorPriority
    FOR CONVERSATION
    SET (CONTRACT_NAME = SimpleContract,
         LOCAL_SERVICE_NAME = TargetService,
         REMOTE_SERVICE_NAME = N'InitiatorService',
         PRIORITY_LEVEL = 3);
GO

优先级的工作方式

通常，Service Broker 先发送和接收高优先级会话的消息，再发送和接收低优先级会话的消息。高优先级会话的消息在队列中等待的时间短于低优先级会话的消息。

接收优先级别

传输优先级别

请参阅

参考

概念