.Net全網(wǎng)最火RabbitMQ操作【強(qiáng)烈推薦】
當(dāng)前位置：點(diǎn)晴教程→知識(shí)管理交流
→『 技術(shù)文檔交流 』
導(dǎo)讀 本文自1年前的1.0版本推出以來(lái)，已被業(yè)界大量科技公司采用。同時(shí)也得到了.Net圈內(nèi)多位大佬的關(guān)注+推薦，文章也被多家頂級(jí).Net/C#公眾號(hào)轉(zhuǎn)載。 現(xiàn)在更新到了7.0版本，更好的服務(wù)各位.Neter。 【正文】 支持.Net/.Net Core/.Net Framework，可以部署在Docker, Windows, Linux, Mac。 RabbitMQ作為一款主流的消息隊(duì)列工具早已廣受歡迎。相比于其它的MQ工具，RabbitMQ支持的語(yǔ)言更多、功能更完善。
本文提供一種市面上最/極簡(jiǎn)單的使用RabbitMQ的方式，只需要會(huì)調(diào)用以下三個(gè)方法，你就幾乎可以掌握整個(gè)RabbitMQ的使用： （1） SendMessage，發(fā)送一個(gè)消息 （2） GetMessage，獲取一個(gè)消息 （3） UseMessage，使用一個(gè)消息（連續(xù)使用）
為了調(diào)用以上三個(gè)方法，首先需要從NuGet引用DeveloperSharp.RabbitMQ包。 然后，對(duì)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ò)了位置會(huì)報(bào)錯(cuò)） { "Logging": { "LogLevel": { "Default": "Information", "Microsoft.AspNetCore": "Warning" } }, "AllowedHosts": "*", "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> 說(shuō)明：上述配置中分別設(shè)置了RabbitMQ應(yīng)用所在的服務(wù)器IP地址hostName、端口port、用戶名userName、密碼password（請(qǐng)把這四項(xiàng)的對(duì)應(yīng)值修改成你自己那邊的RabbitMQ的對(duì)應(yīng)值）
（注意：DeveloperSharp.RabbitMQ包在7.0版本以前，.Net Core下也支持App.config/Web.config配置。但在7.0及以后版本中，.Net Core下只支持appsettings.json文件配置）
下面，我們給出一個(gè)使用了上述SendMessage、GetMessage、UseMessage三個(gè)方法的示例。該示例的功能說(shuō)明如下：
代碼如下： 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è)文本文件中寫(xiě)入4個(gè)消息（使用UseMessage） RabbitMQHelper.UseMessage("aa", t => { System.IO.File.AppendAllText("D:/fj.txt", t.Message); return true; }); } 運(yùn)行結(jié)果如下： 【控制臺(tái)顯示出】：世界1，你好！ 【fj.txt文件中顯示出】：世界2，你好！世界3，你好！世界4，你好！世界5，你好！
（上述示例中，由于SendMessage是同步方法，故“世界1，你好！”~“世界5，你好！”會(huì)按順序顯示。若我們把SendMessage方法全部改為異步的SendMessageAsync，則顯示結(jié)果將不再是按順序來(lái)的，很有可能顯示成類似這樣：“世界3，你好！世界1，你好！世界5，你好！世界2，你好！世界4，你好！”） 三個(gè)方法的詳細(xì)功能說(shuō)明（輔助參考）： （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 附加說(shuō)明： （I）Use返回值為true時(shí)，代表當(dāng)前消息已被有效處理并會(huì)被服務(wù)器刪除。然后程序自動(dòng)進(jìn)入下一條消息的使用。 若Use返回值為false時(shí)，代表當(dāng)前消息未被有效處理但仍會(huì)被服務(wù)器刪除。然后程序自動(dòng)進(jìn)入下一條消息的使用。 若Use返回值為null時(shí)，代表當(dāng)前消息會(huì)被服務(wù)器重新隊(duì)列分配到其它可用的實(shí)例上再處理。然后程序自動(dòng)進(jìn)入下一條消息的使用。 若Use內(nèi)部發(fā)生未被處理的異常，程序會(huì)停止。 （II）RabbitMQMessage對(duì)象定義如下： public class RabbitMQMessage { public string Message; public IDictionary<string, object> Header; public string Id; //此處系統(tǒng)自動(dòng)生成的Id具有UUID的特性。 }
延時(shí)隊(duì)列&死信隊(duì)列 有些場(chǎng)景下，我們希望為使用的消息設(shè)定有效期。在有效期內(nèi)，這些消息有效可用；但過(guò)期后，這些消息將變得無(wú)效不可用，同時(shí)，它們還將自動(dòng)被丟棄進(jìn)一個(gè)稱之為“死信”的隊(duì)列。 為了說(shuō)明這些概念，我們還是來(lái)舉一個(gè)具體的例子。該例子的功能說(shuō)明如下：
代碼如下： using DeveloperSharp.RabbitMQ;//從NuGet引用DeveloperSharp.RabbitMQ包 -------------------------- //定義bbq隊(duì)列，其中存放的消息會(huì)在60秒后過(guò)期 var myQ = RabbitMQHelper.SetQueue("bbq", 60000); //定義與bbq隊(duì)列對(duì)應(yīng)的死信隊(duì)列 var expQ = RabbitMQHelper.GetQueue("bbq"); //向BB.txt這個(gè)文本文件中連續(xù)寫(xiě)入死信隊(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"); /* //【附加題】：若去掉注釋讓此語(yǔ)句執(zhí)行，死信隊(duì)列中將不會(huì)獲得消息(為啥？自己推理) RabbitMQHelper.UseMessage("bbq", t => { return true;//若此處返回false，死信隊(duì)列將會(huì)獲得消息 }); */ 運(yùn)行以上程序： 60秒之內(nèi)，【BB.txt文件】中沒(méi)有內(nèi)容 60秒以后，【BB.txt文件】中顯示出：jinAjinBjinC
通過(guò)以上例子，我們可簡(jiǎn)單預(yù)測(cè)一下，延時(shí)隊(duì)列&死信隊(duì)列常用在“限時(shí)消費(fèi)”、“過(guò)期處理”等場(chǎng)景。生活中最常見(jiàn)示例如：訂單請(qǐng)?jiān)?0分鐘內(nèi)支付完畢、等等之類功能...
（其它說(shuō)明：為了演示便利，文本前面給出的幾個(gè)代碼示例中，把SendMessage、GetMessage、UseMessage三個(gè)方法都放到了同一段代碼程序中，這樣做不好，偶爾會(huì)造成一些資源沖突。在實(shí)際使用中，最好是把它們分開(kāi)分別放到三段不同的代碼程序中，以獲取最佳效果。比如：三個(gè)按鈕，之類...）
使用消息服務(wù)對(duì)解耦分布式系統(tǒng)、實(shí)現(xiàn)發(fā)布/訂閱、提高系統(tǒng)性能、等方面都有巨大用處，相信本文會(huì)擴(kuò)展你的思維認(rèn)知，讓你在相關(guān)技術(shù)解決方案上有更多靈活思路+聯(lián)想空間！ 原文鏈接：http://www.developersharp.cc/content12.html 服務(wù)條款：http://www.developersharp.cc/buy.html 該文章在 2023/6/12 11:14:06 編輯過(guò) |
關(guān)鍵字查詢
相關(guān)文章
正在查詢... 
|
400 186 1886
