优先发送到服务,以便具有较高优先级的请求被接收和高于一个较低优先级高速地处理请求。这样的模式是应用程序是实用的,它提供不同的服务级别保证或者针对独立客户

背景和问题

应用程序能够托付给其它服务的详细任务;比如,为了运行后台处理与其它应用程序或服务的整合在云中,消息队列通经常使用于将任务委派给后台处理。很多情况下,请求由服务接收的顺序是不重要的。然而在某些情况下,可能须要优先考虑的详细要求

这些要求必须早于较低优先级其它可能先前已发送由应用程序进行处理。

解决方式

队列一般是先入先出FIFO结构。而消费者一般会收到他们公布到队列中的顺序同样的消息然而。一些消息队列支持优先级的消息传递;应用程序公布一条消息能够分配优先级的消息。并在队列中的消息会自己主动又一次排序,使得具有较高优先级的消息将这些优先级较低被接收。图1示出了一个队列,它提供优先权的消息

云计算设计模式(十六)——优先级队列模式

 

图1  - 使用支持消息优先级排队机制

注意:

大多数消息队列的实现支持多个消费者下面竞争消费者模式)和消费过程的数量能够按比例添加或减小的需求支配。

不支持基于优先级的消息队列系统中,一种替代的解决方式是为每个优先级的独立队列。应用程序负责将邮件投递适当的队列每个队列能够有一个单独的消费者

优先级队列能够有更快的硬件低优先级队列中执行的消费者一个更大的泳池图2示出了这样的方法。

云计算设计模式(十六)——优先级队列模式

图2 - 使用不同的消息队列为每一个优先级

这样的策略的变化是消费者觉得检查高优先级队列中的消息,然后再才開始低优先级队列中读取消息。假设没有更高优先级的消息都在等待一个池还有,使用消费过程的一个池的溶液之间的一些语义差异(或者使用支持不同的优先级多个队列。每一个处理一个单一的优先级消息的消息的单个队列以及使用多个队列溶液为每一个队列一个单独的游泳池。

在单的做法优先级的消息总是会收到曾经低优先级的消息处理。

理论中,具有很低的优先级的消息能够被不断地代替,而且可能永远不会被处理。在多的方法较低优先级的报文将总是被处理仅仅是一样迅速的那些更高的优先级(取决于池和它们具有可用资源的相对大小

使用优先级排队机制可提供下面长处:
它同意应用程序满足必要可用性或性能优先的业务需求提供不同级别的服务,以客户的特定群体
它能够帮助最大限度地降低运营成本。在单队列的方式你能够缩减用户的数量,假设有必要的。高优先级消息仍将被首先处理(尽管可能更慢低优先级的消息可能会延迟更长。假设您已实现与消费者每个单独的队列多个消息队列的方式,能够降低消费者的低优先级队列或者甚至停止全部监听的讯息的消费者暂停处理一些很低优先级队列这些队列
•在多个消息队列的方法能够帮助划分的基础上处理要求的消息,以最大限度地提高应用程序的性能和可扩展性

比如,重要的任务,能够优先马上执行。而不太重要的后台任务能够安排在不太繁忙的时段执行的接收器来处理接收处理。

问题和注意事项


在决定怎样实现这个模式时。请考虑下面几点
•定义优先级解决方式的情况下比如,“高优先级”可能意味着。信息应该在十秒内进行处理。标识要求处理高优先级的项目以及其它什么资源必须分配给符合这些标准
确定是否全部高优先级的项目必须在不论什么优先级较低的项目之前进行处理

假设该消息是由消费者的一个池被处理可能有必要提供一种可抢先暂停正在处理的低优先级消息,假设更高优先级的消息。有一个任务的机制。
•在多个队列中的方法,使用监听全部的队列,而不是一个专门的客户的每一个队列的消费过程的一个池,消费者必须应用一种算法,以确保总是那些之前较高优先级的队列提供服务的消息优先级队列
•监视处理优先级队列中速度,以确保这些队列中的消息预期的速率进行处理。

•假设须要。以保证优先级的消息将被处理时,可能有必要实现与消费者的多个池多个消息队列的方法。或者,在一个支持消息优先队列它可能会动态地添加一个排队的消息的优先级,由于它的年龄

然而。该方法依赖于消息队列提供此功能。
使用单独的队列中每一个消息优先级最适合少数明白定义的优先级系统。
消息优先级能够通过系统逻辑决定的。比如而不是明白的高和低优先级的消息他们能够被指定为自费客户”或“非自费的客户依据您的商业模式,你的系统可能会分配很多其它的资源,收费处理消息付费用户比非自费的。
可能是检查队列消息相关联的金融和处理成本一些商业邮件系统的消息被公布或检索每次收取一小笔费用,每次一个队列中查询消息)检查多个队列时。该成本将有所添加。

•它可以是可以动态调整的基础上,该所服务的队列的长度消费者一个池的大小

欲了解很多其它信息,请參阅自己主动缩放指导

何时使用这个模式


这样的模式很适合场景
系统必须处理可能有不同的側重点多个任务

•不同的用户或租户应配以不同的优先级

样例


微软Azure不提供经过整理本地支持邮件自己主动优先级排队机制然而,它确实提供了Azure的服务总线主题和订阅,支持排队机制,提供邮件过滤,具有多种灵活的功能。使其很适合用在差点儿全部的优先级队列的实现在一起。

一个Azure的解决方式,能够实现服务总线话题。当中一个应用程序能够公布消息以相同的方式作为一个队列。消息能够包括应用程序定义的自己定义属性的形式的元数据。

服务总线订阅能够主题相关联,而且这些订阅能够筛选依据它们的属性信息。

当一个应用程序将消息发送到一个主题,该消息被定向到从那里能够被消费者阅读对应的订阅。

消费者的过程能够检索使用相同的语义消息队列订阅是一个逻辑队列一个订阅消息。

图3示出了使用的Azure服务总线主题和订阅的解决方式。

云计算设计模式(十六)——优先级队列模式

图3 - 实现Azure的服务总线主题和订阅优先级队列

在图3中应用程序创建多个消息和每一个消息价值分配被称为优先级的自己定义属性不管是高还是低。该应用程序的帖子,这些消息的一个话题。这个主题有两个相关的订阅,两个滤波器的消息通过检查优先级属性一位接受认购,当中优先级属性设置为的消息其它接受当中优先级属性设置为的消息

消费者读取每一个订阅的消息

优先认购有较大的游泳池。而这些消费者可能会强大且昂贵)的计算机上执行提供消费者在低优先级池的很多其它资源

请注意,没有什么特别的高,低优先级消息这个样例中指定

这些不过指定为每一个消息中的属性的标签,用于引导消息发送到一个特定的订阅。假设附加的优先级是必需的。是比較easy地创建进一步的订阅和消费者进程池来处理这些优先级。

可用于此引导代码时Queue解决方式包括这样的方法的一个实现。该解决方式包括一个名为PriorityQueue.HighPriorityQueue.Low两个工作角色的项目。这两个辅助角色继承的类被称为PriorityWorkerRole它包括用于连接到一个指定的预订OnStart方法的功能。

PriorityQueue.HighPriorityQueue.Low辅助角色连接到不同的预订他们的配置设置来定义。管理员能够配置每一个角色的不同数量要执行;通常会有PriorityQueue.Low工作者角色PriorityQueue.High辅助角色很多其它的实例

PriorityWorkerRoleRun方法安排虚拟ProcessMessage的方法(在PriorityWorkerRole定义)队列中接收到的每一个消息被执行。以下的代码显示执行ProcessMessage的方法

的QueueManagerPriorityQueue.Shared项目定义提供了辅助方法使用的Azure服务总线队列。

public class PriorityWorkerRole : RoleEntryPoint
{
  private QueueManager queueManager;
  ...

  public override void Run()
  {
    // Start listening for messages on the subscription.
    var subscriptionName = CloudConfigurationManager.GetSetting("SubscriptionName");
    this.queueManager.ReceiveMessages(subscriptionName, this.ProcessMessage);
    ...;
  }
  ...

  protected virtual async Task ProcessMessage(BrokeredMessage message)
  {
    // Simulating processing.
    await Task.Delay(TimeSpan.FromSeconds(2));
  }
}

 

PriorityQueue.HighPriorityQueue.Low辅助角色覆盖ProcessMessage的方法的默认功能以下的代码显示ProcessMessage的方法PriorityQueue.High辅助角色

Copy


protected override async Task ProcessMessage(BrokeredMessage message)
{
  // Simulate message processing for High priority messages.
  await base.ProcessMessage(message);
  Trace.TraceInformation("High priority message processed by " +
    RoleEnvironment.CurrentRoleInstance.Id + " MessageId: " + message.MessageId);
}

 

当一个应用程序将消息公布所使用的PriorityQueue.HighPriorityQueue.Low辅助角色订阅相关联的主题它指定了优先使用优先级的自己定义属性。如以下的代码演示样例

此代码(这是PriorityQueue.Sender项目WorkerRole类实现使用的QueueManager类的SendBatchAsync辅助方法发帖分批的话题。

// Send a low priority batch. 
var lowMessages = new List<BrokeredMessage>();

for (int i = 0; i < 10; i++)
{
  var message = new BrokeredMessage() { MessageId = Guid.NewGuid().ToString() };
  message.Properties["Priority"] = Priority.Low;
  lowMessages.Add(message);
}

this.queueManager.SendBatchAsync(lowMessages).Wait();
...

// Send a high priority batch.
var highMessages = new List<BrokeredMessage>();

for (int i = 0; i < 10; i++)
{
  var message = new BrokeredMessage() { MessageId = Guid.NewGuid().ToString() };
  message.Properties["Priority"] = Priority.High;
  highMessages.Add(message);
}

this.queueManager.SendBatchAsync(highMessages).Wait();

本文翻译自MSDN:http://msdn.microsoft.com/en-us/library/dn589794.aspx