支持.Net Core(2.0及以上)與.Net Framework(4.5及以上)
本文所述方案近期被江蘇省某億級數(shù)據(jù)量+高并發(fā)的政府"物聯(lián)網(wǎng)"項(xiàng)目采用，獲得圓滿成功?。?/span>
【目錄】
-
發(fā)送消息、獲取消息、使用消息
-
延時(shí)隊(duì)列 & 死信隊(duì)列
-
展望
RabbitMQ作為一款主流的消息隊(duì)列工具早已廣受歡迎。相比于其它的MQ工具，RabbitMQ支持的語言更多、功能更完善。
1.發(fā)送消息、獲取消息、使用消息
本文提供一種市面上最/極簡單的使用RabbitMQ的方式，只需要會調(diào)用以下三個(gè)方法，你就幾乎可以掌握整個(gè)RabbitMQ的使用：
（1）???? SendMessage，發(fā)送一個(gè)消息
（2）???? GetMessage，獲取一個(gè)消息
（3）???? UseMessage，使用一個(gè)消息（連續(xù)使用）
?
為了調(diào)用以上三個(gè)方法，首先需要從NuGet引用DeveloperSharp.RabbitMQ包。
然后，對RabbitMQ消息服務(wù)器的鏈接信息進(jìn)行配置（分.Net Core與.Net Framework兩種情況）：
若是在.Net Core環(huán)境下，你則需要在appsettings.json文件中添加“DeveloperSharp.RabbitMQ”節(jié)點(diǎn)（如下配置示例），并把a(bǔ)ppsettings.json文件放到程序執(zhí)行目錄中（即bin目錄下與dll、exe等文件的同一目錄中）（放錯(cuò)了位置會報(bào)錯(cuò)）
{ "DeveloperSharp.RabbitMQ":[{ "HostName":"135.208.12.236", "UserName":"sa", "Password":"aevin.gang", "Port":5672 }] }
?
若是在.Net Framework環(huán)境下，你則需要在App.config/Web.config里面添加如下配置：
<appSettings> <add key="RabbitMQConnectionString" value="hostName=135.208.12.236,port=5672,userName=sa,password=aevin.gang" /> </appSettings>
說明：上述配置中分別設(shè)置了RabbitMQ應(yīng)用所在的服務(wù)器IP地址hostName、端口port、用戶名userName、密碼password（請把這四項(xiàng)的對應(yīng)值修改成你自己那邊的RabbitMQ的對應(yīng)值）
?
下面，我們給出一個(gè)使用了上述SendMessage、GetMessage、UseMessage三個(gè)方法的示例。該示例的功能說明如下：
- 先向RabbitMQ服務(wù)器上名為“aa”的隊(duì)列發(fā)送了5個(gè)消息，
- 然后從RabbitMQ服務(wù)器上的“aa”隊(duì)列中獲取，并打印出第1個(gè)消息，
- 最后再連續(xù)從RabbitMQ服務(wù)器上的“aa”隊(duì)列中獲取剩余4個(gè)消息，并把它們寫入名為fj.txt的文件。
代碼如下：
using DeveloperSharp.RabbitMQ; -------------------------- static void Main(string[] args) { //發(fā)送5個(gè)消息（使用SendMessage） RabbitMQHelper.SendMessage("aa", "世界1，你好！"); RabbitMQHelper.SendMessage("aa", "世界2，你好！"); RabbitMQHelper.SendMessage("aa", "世界3，你好！"); RabbitMQHelper.SendMessage("aa", "世界4，你好！"); RabbitMQHelper.SendMessage("aa", "世界5，你好！"); //獲取1個(gè)消息（使用GetMessage） string OneMessage = RabbitMQHelper.GetMessage("aa").Message; Console.WriteLine(OneMessage); //向fj.txt這個(gè)文本文件中寫入4個(gè)消息（使用UseMessage） RabbitMQHelper.UseMessage("aa", t => { System.IO.File.AppendAllText("D:/fj.txt", t.Message); return true; }); }
運(yùn)行結(jié)果如下：
【控制臺顯示出】：世界1，你好！
【fj.txt文件中顯示出】：世界2，你好！世界3，你好！世界4，你好！世界5，你好！
?
（上述示例中，由于SendMessage是同步方法，故“世界1，你好！”~“世界5，你好！”會按順序顯示。若我們把SendMessage方法全部改為異步的SendMessageAsync，則顯示結(jié)果將不再是按順序來的，很有可能顯示成類似這樣：“世界3，你好！世界1，你好！世界5，你好！世界2，你好！世界4，你好！”）
?
三個(gè)方法的詳細(xì)功能說明（輔助參考）：
（1）發(fā)送一個(gè)消息 void SendMessage(string QueueName, string Message, Dictionary<string, object> Header = null) //異步方法：SendMessageAsync （2）獲取一個(gè)消息 RabbitMQMessage GetMessage(string QueueName) //異步方法：GetMessageAsync （3）使用一個(gè)消息（連續(xù)使用） void UseMessage(string QueueName, Func<RabbitMQMessage, bool?> Use) //異步方法：UseMessageAsync 附加說明： （I）Use返回值為true時(shí)，代表當(dāng)前消息已被有效處理并會被服務(wù)器刪除。然后程序自動(dòng)進(jìn)入下一條消息的使用。 若Use返回值為false時(shí)，代表當(dāng)前消息未被有效處理但仍會被服務(wù)器刪除。然后程序自動(dòng)進(jìn)入下一條消息的使用。 若Use返回值為null時(shí)，代表當(dāng)前消息會被服務(wù)器重新隊(duì)列分配到其它可用的實(shí)例上再處理。然后程序自動(dòng)進(jìn)入下一條消息的使用。 若Use內(nèi)部發(fā)生未被處理的異常，程序會停止。 （II）RabbitMQMessage對象定義如下： public class RabbitMQMessage { public string Message; public IDictionary<string, object> Header; public string Id; //此處系統(tǒng)自動(dòng)生成的Id是分布式唯一Id。 }
?
2.延時(shí)隊(duì)列 & 死信隊(duì)列
有些場景下，我們希望為使用的消息設(shè)定有效期。在有效期內(nèi)，這些消息有效可用；但過期后，這些消息將變得無效不可用，同時(shí)，它們還將自動(dòng)被丟棄進(jìn)一個(gè)稱之為“死信”的隊(duì)列。
為了說明這些概念，我們還是來舉一個(gè)具體的例子。該例子的功能說明如下：
- 首先，在RabbitMQ服務(wù)器上定義一個(gè)名為"bbq"、且其中存放的消息會在60秒后過期失效的隊(duì)列。
- 然后，在RabbitMQ服務(wù)器上定義一個(gè)與"bbq"隊(duì)列對應(yīng)的死信隊(duì)列。并連續(xù)從該死信隊(duì)列中獲取消息并把它們寫入名為BB.txt的文件。
- 最后，向RabbitMQ服務(wù)器上的"bbq"隊(duì)列發(fā)送3個(gè)消息。
?代碼如下：
using DeveloperSharp.RabbitMQ;//從NuGet引用DeveloperSharp.RabbitMQ包 -------------------------- //定義bbq隊(duì)列，其中存放的消息會在60秒后過期 var myQ = RabbitMQHelper.SetQueue("bbq", 60000); //定義與bbq隊(duì)列對應(yīng)的死信隊(duì)列 var expQ = RabbitMQHelper.GetQueue("bbq"); //向BB.txt這個(gè)文本文件中連續(xù)寫入死信隊(duì)列中的消息 expQ.UseMessage(t => { System.IO.File.AppendAllText("D:/BB.txt", t.Message); return true; }); //向bbq隊(duì)列發(fā)送3個(gè)消息 myQ.SendMessage("jinA"); myQ.SendMessage("jinB"); myQ.SendMessage("jinC"); /* //【附加題】：若去掉注釋讓此語句執(zhí)行，死信隊(duì)列中將不會獲得消息(為啥？自己推理) RabbitMQHelper.UseMessage("bbq", t => { return true;//若此處返回false，死信隊(duì)列將會獲得消息 }); */
運(yùn)行以上程序：
60秒之內(nèi)，【BB.txt文件】中沒有內(nèi)容
60秒以后，【BB.txt文件】中顯示出：jinAjinBjinC
?
通過以上例子，我們可簡單預(yù)測一下，延時(shí)隊(duì)列&死信隊(duì)列常用在“限時(shí)消費(fèi)”、“過期處理”等場景。生活中最常見示例如：訂單請?jiān)?0分鐘內(nèi)支付完畢、等等之類功能...
?
（其它說明：為了演示便利，文本前面給出的幾個(gè)代碼示例中，把SendMessage、GetMessage、UseMessage三個(gè)方法都放到了同一段代碼程序中，這樣做不好，偶爾會造成一些資源沖突。在實(shí)際使用中，最好是把它們分開分別放到三段不同的代碼程序中，以獲取最佳效果。比如：三個(gè)按鈕，之類...）
?
使用消息服務(wù)對解耦分布式系統(tǒng)、實(shí)現(xiàn)發(fā)布/訂閱、提高系統(tǒng)性能、等方面都有巨大用處，相信本文會擴(kuò)展你的思維認(rèn)知，讓你在相關(guān)技術(shù)解決方案上有更多靈活思路+聯(lián)想空間！
?
原文鏈接：http://www.developersharp.cc/content12.html
結(jié)尾
下面是我的公眾號，里面有很多高價(jià)值技術(shù)文章，是你刻苦努力也積累不到的經(jīng)驗(yàn)，能助力個(gè)人快速成長。
你也可以加入我們（添加微信：894988403，備注“進(jìn)群”），向大佬學(xué)習(xí)，探行業(yè)內(nèi)幕，享時(shí)代機(jī)遇。文章來源：http://www.zghlxwxcb.cn/news/detail-711446.html
文章來源地址http://www.zghlxwxcb.cn/news/detail-711446.html
到了這里，關(guān)于它讓你1小時(shí)精通RabbitMQ消息隊(duì)列、且能扛高并發(fā)的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
