例子

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

一个 Azure的 解决方案， 可以实现 服务总线 话题， 其中 一个应用程序 可以发布消息 ， 以同样的方式 作为一个 队列。 消息 可以包含 在 应用程序定义的 自定义属性 的形式 的元数据。 服务总线 订阅可以 与 主题 相关联，并且 这些订阅 可以筛选 根据 它们的属性 信息。 当一个应用程序 将消息发送到 一个 主题 ，该消息 被定向到 从那里 它 可以 被消费者 阅读相应的 订阅。 消费者 的过程 可以检索 使用 相同的语义 消息队列 （ 订阅 是一个逻辑 队列 ） 从 一个 订阅 消息。

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

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


在图3中 的 应用程序创建 多个 消息和 每个消息 与 价值 分配 被称为 优先级 的自定义属性 ， 无论是 高还是低。 该应用程序 的帖子 ，这些 消息 的一个话题。 这个主题 有两个相关的 订阅， 这 两个滤波器 的消息 通过检查 优先级属性 。 一位 接受 认购 ，其中 优先级 属性设置为 高 的消息 ， 而 其他 接受 其中 优先级 属性设置为 低 的消息 。 消费者 池 读取 每个订阅 的消息 。 高 优先认购 有较大的 游泳池， 而这些 消费者 可能会 更 强大 （ 且昂贵）的 计算机上运行 有 提供 比 消费者在 低优先级 池的更多 资源 。

请注意， 没有什么 特别的 高，低 优先级消息 在 这个例子中 指定 。 这些 仅仅是 指定为 每个消息中 的属性 的标签， 并 用于引导 消息发送到 一个 特定 的订阅。 如果 附加的 优先级 是必需的， 它 是比较 容易地创建 进一步 的订阅和 消费者 进程池 来处理这些 优先级。

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

该 PriorityQueue.High 和 PriorityQueue.Low 辅助角色 连接到 不同的预订 ， 他们的 配置设置 来定义。 管理员可以配置 每个角色的 不同数量 要运行 ; 通常 会有 比 PriorityQueue.Low 工作者角色 的 PriorityQueue.High 辅助角色 更多的实例 。

在 PriorityWorkerRole 类 的 Run方法 安排 虚拟 ProcessMessage的 方法（在 PriorityWorkerRole 类 定义） 的 队列中 接收到的每个 消息被 执行。 下面的代码显示 了 运行 和 ProcessMessage的 方法 。 在 类 的QueueManager ， 在 PriorityQueue.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));
  }
}

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);
}

// 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();

内容总结

以上是互联网集市为您收集整理的云计算设计模式（十六）——优先级队列模式全部内容，希望文章能够帮你解决云计算设计模式（十六）——优先级队列模式所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端