?? ? ? ?說到隊列的話，大家一定不會陌生，但是扯到優先級隊列的話，還是有一部分同學是不清楚的，可能是不知道怎么去實現吧，其實呢，，，這東西已經爛大街了。。。很簡單，用“堆”去實現的，在我們系統中有一個訂單催付的場景，我們客戶的客戶在tmall，taobao下的訂單,taobao會及時將訂單推送給我們，如果在用戶設定的時間內未付款那么就會給用戶推送一條短信提醒，很簡單的一個功能對吧，但是，tmall商家對我們來說，肯定是要分大客戶和小客戶的對吧，比如像施華蔻，百雀林這樣大商家一年起碼能夠給我們貢獻幾百萬，所以理應當然，他們的訂單必須得到優先處理，而曾經我們的后端系統是使用redis來存放的定時輪詢，大家都知道redis只能用List做一個簡簡單單的消息隊列，并不能實現一個優先級的場景，所以訂單量大了后采用rabbitmq進行改造和優化,如果發現是大客戶的訂單給一個相對比較高的優先級，否則就是默認優先級，好了，廢話不多說，我們來看看如何去設置。?

一：優先級隊列

　　既然是優先級隊列，那么必然要在Queue上開一個口子貼上一個優先級的標簽，為了看怎么設置，我們用一下rabbitmq的監控UI，看看這個里面是如何

手工的創建優先級隊列。

? ? ? 從這個圖中可以看到在Arguments欄中有特別多的小屬性，其中有一項就是"Maximum priority"，這項的意思就是說可以定義優先級的最大值，其實

想想也是，不可能我們定義的優先級是一個非常大的數字，比如int.MaxValue,大多情況下都是10以內的數字就可以了，再或者我們曾今接觸過的 MSMQ，

它的優先級只是一些枚舉值，什么High，Normal，Low，不知道大家可否記得？ 下面來看下代碼中該如何實現呢？？？?

1. 在Queue上附加優先級屬性

Dictionary<string, object> dic = new Dictionary<string, object>(); dic.Add("x-max-priority", 20); channel.QueueDeclare(queue: "hello",durable: true,exclusive: false,autoDelete: false,arguments: dic);

?上面的代碼做了一個簡單的隊列聲明，queuename="hello"，持久化，排外。。。然后把"x-max-priority"塞入到字典中作為arguments參數，看起來還

是非常簡單吧~~~?

2. 在Message上指定優先級屬性

var properties = channel.CreateBasicProperties();properties.Priority = 1;channel.BasicPublish(exchange: "",routingKey: "hello",basicProperties: null,body: body);

?

通過上面的代碼可以看到，在Message上設置優先級，我是通過在channel通道上設置Priority屬性，之后塞到basicProperties中就可以了，好了，有上面這兩

個基礎之后，下面就可以開始測試了，準備向rabbitmq推送10條記錄，其中第5條的優先級最高，所以應該首先就print出來，如下圖：

static void Main(string[] args) { ? ?var sb = new StringBuilder(); ? ?
? ?for (int i = 0; i < 11; i++){sb.Append(i);} ?
? ?var factory = new ConnectionFactory() { HostName = "192.168.23.136", UserName = "datamip", Password = "datamip" }; ?
? ?using (var connection = factory.CreateConnection()){ ? ? ?
? ? ? ?using (var channel = connection.CreateModel()){channel.ExchangeDeclare(exchange: "mydirect", type: ExchangeType.Direct, durable: true);Dictionary<string, object> dic = new Dictionary<string, object>();dic.Add("x-max-priority", 20); ? ? ?
? ? ? ? ? ?for (int i = 0; i < 10; i++){channel.QueueDeclare(queue: "hello",durable: true,exclusive: false,autoDelete: false,arguments: dic); ? ? ? ? ? ? ?
? ? ? ?string message = string.Format("{0} {1}", i, sb.ToString()); ? ? ? ? ? ? ? ?

var body = Encoding.UTF8.GetBytes(message); ? ? ? ? ? ? ? ?var properties = channel.CreateBasicProperties();properties.Priority = (i == 5) ? (byte)10 : (byte)i;channel.BasicPublish(exchange: "",routingKey: "hello",basicProperties: properties,body: body);Console.WriteLine(" [x] Sent {0}", i);}}}Console.WriteLine(" Press [enter] to exit.");Console.ReadLine(); }

?

圖中可以看到10條消息我都送到rabbitmq中去了，接下來打開consume端，來看看所謂的index=5 是否第一個送出來？？

static void Main(string[] args) { ? ?
? ?for (int m = 0; m < int.MaxValue; m++){ ? ?
? ? ? ?var factory = new ConnectionFactory() { HostName = "192.168.23.136", UserName = "datamip", Password = "datamip" }; ? ? ?
? ? ?using (var connection = factory.CreateConnection()) ? ? ? using (var channel = connection.CreateModel()){ ? ? ? ?
? ? ? ?var result = channel.BasicGet("hello", true); ? ? ? ? ?? ?if (result != null){ ? ? ? ? ?
? ? ? ? ?var str = Encoding.UTF8.GetString(result.Body);Console.WriteLine("{0} ?消息內容 {1}", m, str);System.Threading.Thread.Sleep(1);}}}Console.WriteLine(" Press [enter] to exit.");Console.ReadLine(); }

?

一切都是這么的完美，接下來為了進行可視化驗證，你可以在WebUI中觀察觀察，可以發現在Queue上面多了一個 Pri 標記，有意思吧。

?

?

好了，這么重要的功能，是不是已經讓你足夠興奮啦， 希望大家能夠好好的在實際場景中運用吧

原文地址：http://www.cnblogs.com/huangxincheng/p/6029214.html

---

.NET社區新聞，深度好文，微信中搜索dotNET跨平臺或掃描二維碼關注

總結

以上是生活随笔為你收集整理的体验Rabbitmq强大的【优先级队列】之轻松面对现实业务场景的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。