如何基于RabbitMQ实现优先级队列

转载:http://www.cnblogs.com/aarond/p/rabbitmq.html

概述

因为种种缘由，RabbitMQ到目前为止，官方尚未实现优先级队列，只实现了Consumer的优先级处理。

可是，迫于种种缘由，应用层面上又须要优先级队列，所以需求来了：如何为RabbitMQ加入优先级队列特性。

查询资料后，得知RabbitMQ虽然官方没有支持此特性，可是社区已经有相关优先级队列插件了，而且这个插件被列在RabbitMQ官方网站中了。

地址以下：http://www.rabbitmq.com/community-plugins.html

插件安装

不要马上下载这个url中的那个连接，要先根据你想要更新目标的rabbitmq版本再去另一个地方下载相应插件，如：

会列出两大版本的插件目录（选择对应目录进入下载，不然会报错...）：

 

插件如何安装？

进入rabbitmq安装目录，进入plugins目录，将上面这个ez文件拷贝到plugins目录中，而后运行命令来enable这个插件

centos下，默认路径在:/usr/lib/rabbitmq/lib/rabbitmq_server-3.3.4/plugins（版本号可能会变化）

windows下，默认路径在:C:\Program Files\RabbitMQ Server\rabbitmq_server-3.3.4\plugins（版本号可能会变化）

把ez文件拷贝过去，而后运行列举插件列表命令：

找到这个优先级队列插件名为：rabbitmq_priority_queue

执行：rabbitmq-plugins enable rabbitmq_priority_queue

ok，从新启动rabbitmq-server服务。

这样，server端的配置算完成了。

 

C#代码端须要做出的更改

下面看看客户端类库的编写：

咱们先要定义优先级枚举，继承自byte，由于RabbitMQ的C#客户端优先级是用byte来传递的：

先定义3个级别的优先级：低、中、高（其实能够定义不少级别，只是为了简化，所以只定义了3个级别）

有2个地方须要改动：

1. 
   

   1. 申明队列时须要加入自定义的属性

   2. 发送消息到rabbitmq时，设置自定义属性

 

internal static IDictionary<string, object> QueueArguments
        {            get
            {
                IDictionary<string, object> arguments=new Dictionary<string, object>();
                arguments["x-max-priority"] = 10;//定义队列优先级为10个级别                return arguments;
            }
        }

  

channel.QueueDeclare("queueName", true, false, false, QueueArguments);//QueueArguments就是上面定义的这个dictionary

  

var headers = channel.CreateBasicProperties();

headers.Priority = (byte)msg.Priority;//在这里把继承自byte的枚举转换成bytechannel.BasicPublish("exchange", "route", headers, SerializerUtility.Serialize2Bytes(msg));

  

 其余注意的地方

在装了优先级队列插件的rabbitmq-server实例中，全部的Durable队列必须用如上的方式，设置x-max-priority属性，不然rabbitmq-server服务会crash