NET为什么推荐它作为RabbitMQ消息队列的首选开发工具
支持.Net Core(2.0及以上)/.Net Framework(4.5及以上),可以部署在Docker, Windows, Linux, Mac。
RabbitMQ作为一款主流的消息队列工具早已广受欢迎。相比于其它的MQ工具,RabbitMQ支持的语言更多、功能更完善。
本文提供一种市面上 最/极 简单的使用RabbitMQ的方式,只需要会调用以下三个方法,你就几乎可以掌握整个RabbitMQ的使用:
(1)SendMessage,发送一个消息
(2)GetMessage,获取一个消息
(3)UseMessage,使用一个消息(连续使用)
为了调用以上三个方法,首先需要从NuGet引用DeveloperSharp.RabbitMQ包,并在App.config/Web.config里面添加如下配置(.NET6 / VS2022中已有App.config这个单项添加):
说明:上述配置中分别设置了RabbitMQ应用所在的服务器IP地址hostName、端口port、用户名userName、密码password(请把这四项的对应值修改成你自己那边的RabbitMQ的对应值)
下面,我们给出一个使用了上述SendMessage、GetMessage、UseMessage三个方法的示例。该示例的功能说明如下: 先向RabbitMQ服务器上名为"aa"的队列发送了5个消息, 然后从RabbitMQ服务器上的"aa"队列中获取,并打印出第1个消息, 最后再连续从RabbitMQ服务器上的"aa"队列中获取剩余4个消息,并把它们写入名为fj.txt的文件。
代码如下:
using DeveloperSharp.RabbitMQ; -------------------------- static void Main(string[] args) { //发送5个消息(使用SendMessage) RabbitMQHelper.SendMessage("aa", "世界1,你好!"); RabbitMQHelper.SendMessage("aa", "世界2,你好!"); RabbitMQHelper.SendMessage("aa", "世界3,你好!"); RabbitMQHelper.SendMessage("aa", "世界4,你好!"); RabbitMQHelper.SendMessage("aa", "世界5,你好!"); //获取1个消息(使用GetMessage) string OneMessage = RabbitMQHelper.GetMessage("aa").Message; Console.WriteLine(OneMessage); //向fj.txt这个文本文件中写入剩余的4个消息(使用UseMessage) RabbitMQHelper.UseMessage("aa", t => { System.IO.File.AppendAllText("D:/fj.txt", t.Message); return true; }); }
运行结果如下:
【控制台显示出】: 世界1,你好!
【fj.txt文件中显示出】: 世界2,你好!世界3,你好!世界4,你好!世界5,你好!
三个方法的详细功能说明(辅助参考):
(1)发送一个消息 void SendMessage(string QueueName, string Message, Dictionary Header = null) (2)获取一个消息 RabbitMQMessage GetMessage(string QueueName) (3)使用一个消息(连续使用) void UseMessage(string QueueName, Func Use) 附加说明: (I)Use返回值为true时,代表当前消息已被有效处理并会被服务器删除。然后程序自动进入下一条消息的使用。 若Use返回值为false时,代表当前消息未被有效处理但仍会被服务器删除。然后程序自动进入下一条消息的使用。 若Use返回值为null时,代表当前消息会被服务器重新队列分配到其它可用的实例上再处理。然后程序自动进入下一条消息的使用。 若Use内部发生未被处理的异常,程序会停止。 (II)RabbitMQMessage对象定义如下: public class RabbitMQMessage { public string Message; public IDictionary Header; public string Id; //此处系统自动生成的Id具有分布式唯一Id的特性。 }
延时队列&死信队列
有些场景下,我们希望为使用的消息设定有效期。在有效期内,这些消息有效可用;但过期后,这些消息将变得无效不可用,同时,它们还将自动被丢弃进一个称之为"死信"的队列。
为了说明这些概念,我们还是来举一个具体的例子。该例子的功能说明如下: 首先,在RabbitMQ服务器上定义一个名为"bbq"、且其中存放的消息会在60秒后过期失效的队列。 然后,在RabbitMQ服务器上获取与"bbq"队列对应的【死信队列】。并连续从该【死信队列】中获取消息并把它们写入名为BB.txt的文件。 最后,向RabbitMQ服务器上的"bbq"队列发送3个消息。
代码如下:
using DeveloperSharp.RabbitMQ;//从NuGet引用DeveloperSharp.RabbitMQ包 -------------------------- //定义bbq队列,其中存放的消息会在60秒后过期 var myQ = RabbitMQHelper.SetQueue("bbq", 60000); //获取与bbq队列对应的【死信队列】 var expQ = RabbitMQHelper.GetQueue("bbq"); //向BB.txt这个文本文件中连续写入【死信队列】中的消息 expQ.UseMessage(t => { System.IO.File.AppendAllText("D:/BB.txt", t.Message); return true; }); //向bbq队列发送3个消息 myQ.SendMessage("jinA"); myQ.SendMessage("jinB"); myQ.SendMessage("jinC"); /* //【附加题】:若去掉注释让此语句执行,【死信队列】中将不会获得消息(为啥?自己推理) RabbitMQHelper.UseMessage("bbq", t => { return true;//若此处返回false,【死信队列】将会获得消息 }); */
运行以上程序:
60秒之内,【BB.txt文件】中没有内容
60秒以后,【BB.txt文件】中显示出: jinAjinBjinC
通过以上例子,我们可简单预测一下,延时队列&死信队列常用在"限时消费"、"过期处理"等场景。生活中最常见示例如:订单请在10分钟内支付完毕、等等之类功能...
年末新机潮来临!4000预算,Reno9Pro和荣耀80Pro应该怎么选?不知不觉又到年底,近期手机圈又有不少新机发布,数码产品买新不买旧,想要在这个时候换购新机的朋友选择就很多了。比如最近发布的荣耀80Pro与OPPOReno9Pro便是4000价位段
加拿大在世界杯回归中证明无畏,将比利时推到悬崖边两支各有11名球员的球队分别在90分钟和补时时间内踢球。通常只有一个队赢。偶尔,他们也会画画。但当一方获胜时,通常会被门前的残酷无情分开。这是一个简单而真实的陈述。周三,在艾哈迈德
铜价无常铜是重要的工业金属,素有铜博士之称,对外界因素的变化相当敏感,随着不利和有利消息面的变化,价格波动又大又快,让人防不胜防。举个近期大家身同感受的例子,短短不到半个月的时间,铜价就有
导致德国队输球的onelove到底是什么?在今年卡塔尔世界杯上,欧洲强队德国队在小组赛第一场就12输给了日本队。这一结果令人意外。但是,德国队输得并不冤。在比赛开始前,德国队拍合照的时候,球员们集体捂嘴,以此抗议国际足联。
新秀第一!新秀第一!火箭17号秀防守端一骑绝尘,进攻潜力也极佳NBA新赛季已经打了一个月了,早些时候官方发布的新秀排行尤其惹人注意,排在前面三位的分别是马图林艾维跟班切罗并,不过他们也并没有太让人意外,反而是排在第六名的塔里伊森,他的出现倒是
这种廉价的长寿食物,防癌抗癌功效奇?网上输入玉米须三个字,会跳出很多关于玉米须的功效与作用之类的词条。也经常有患者问,玉米是不是能治癌?玉米须能利尿降血糖降压是真的吗?到底应该怎么看待玉米和玉米须的功效呢?真的有那么
一篇文章让你认识脾胃生活中,很多人都感觉自己或多或少有些脾胃的毛病,那么,你了解脾胃吗?一篇文章带你认识。一脾胃的功能大家知道脾胃有什么功能吗?脾胃可以消化饮食,生成气血,营养全身,其次,我们脾胃每天
风险区的环卫工人一天天一巷巷地走守好后防线视频加载中海珠区南洲街大塘片区管控区范围1。17平方公里当中有10条大街横街窄巷更是超过600条根据要求涉阳场所每天要求不少于两次消杀包括居民楼内的楼梯和扶手可以说消杀在管控区内每
湖南涉外经济学院2022年统招专升本详情解析湖南涉外经济学院2022年统招专升本录取数据湖南涉外经济学院2022年招生专业共计45个,总计划招生2340人(不含274的免试计划),实际录取2675人(普通考生脱贫考生2519
希望在被爱的同时,也学会如何爱人最近看了关于陪孩子终身成长这本书,书中主要的内容是关于如何与孩子相处怎样教育孩子怎么帮助孩子找到归属感价值感,建立终身成长的心态。从书中的内容结合自身经历更加能够明白孩子叛逆背后是
我们阳了,女儿死了,家也散了!河南90后夫妻要的通告来了这是一个不愉快的故事!故事中一个四个月大的宝宝,永远离开了我们!四个月的宝宝懵懵懂懂,只会对着最亲的人憨笑,只会牙牙学语,只会饿了要吃奶,哭了要人抱!四个月的宝宝,不会翻身,也不会