tnblog
首页
视频
资源
登录

.netcore3.1 RabbitMq 发布消息确认

5740人阅读 2021/2/3 14:35 总访问:3286472 评论:0 收藏:0 手机
分类: RabbitMq

.netcore3.1 RabbitMq 发布确认

在发布端一般有两种确认发布消息的模式,ConfirmTx事务确认的模式,其中Tx所消耗的性能大于Confim所消耗的性能。所有尽量用Confirm,除非可靠性要求相当高。

Confirm模式

我们创建一个普通的队列并,在发送消息前通过ConfirmSelect开启Confirm确认模式,并在发布完成消息后通过WaitForConfirms方法接收消息已经发布。我们来调试一下如下代码:

  1. var factory = new ConnectionFactory()
  2. {
  3. HostName = "47.98.187.188",
  4. UserName = "bob",
  5. Password = "bob"
  6. };
  7. // 创建一个链接
  8. using (var connection = factory.CreateConnection())
  9. {
  10. // 创建一个通道
  11. using (var channel = connection.CreateModel())
  12. {
  13. // 声明一个Single_Active_Consumer_Queue队列
  14. channel.QueueDeclare(
  15. queue: "mytest",
  16. durable: true,
  17. exclusive: false,
  18. autoDelete: false,
  19. arguments: null);
  20. // 开启发布确认
  21. channel.ConfirmSelect();
  22. // 发布Priority_Queue队列中的消息
  23. for (int i = 0; i < 10; i++)
  24. {
  25. var msg = Encoding.UTF8.GetBytes($"Message {i} ,Priority: 1");
  26. channel.BasicPublish(string.Empty, "mytest", null, msg);
  27. }
  28. // 等待,直到所有发布的消息都已确认。可以传入一个超时参数
  29. var Result = channel.WaitForConfirms();
  30. Console.WriteLine(" Press [enter] to exit.");
  31. Console.ReadLine();
  32. }
  33. }

Tx事务确认发布消息

我们先清理一下队列中的消息,然后通过TxSelect方法开启事务,通过TxCommit方法提交消息,如果中途发布失败我们需要通过TxRollback回滚事务。我们来调试一下,下面的例子:

  1. var factory = new ConnectionFactory()
  2. {
  3. HostName = "47.98.187.188",
  4. UserName = "bob",
  5. Password = "bob"
  6. };
  7. // 创建一个链接
  8. using (var connection = factory.CreateConnection())
  9. {
  10. // 创建一个通道
  11. using (var channel = connection.CreateModel())
  12. {
  13. // 声明一个Single_Active_Consumer_Queue队列
  14. channel.QueueDeclare(
  15. queue: "mytest",
  16. durable: true,
  17. exclusive: false,
  18. autoDelete: false,
  19. arguments: null);
  20. try
  21. {
  22. // 开启发布事务
  23. channel.TxSelect();
  24. // 发布Priority_Queue队列中的消息
  25. for (int i = 0; i < 10; i++)
  26. {
  27. var msg = Encoding.UTF8.GetBytes($"Message {i} ,Priority: 1");
  28. channel.BasicPublish(string.Empty, "mytest", null, msg);
  29. }
  30. // 确认消息提交
  31. channel.TxCommit();
  32. }
  33. catch (Exception ex)
  34. {
  35. // 回滚事务
  36. channel.TxRollback();
  37. }
  38. Console.WriteLine(" Press [enter] to exit.");
  39. Console.ReadLine();
  40. }
  41. }

我们发现在事务没有提交之前是没有消息的!提交后就有了。


欢迎加群讨论技术,1群:677373950(满了,可以加,但通过不了),2群:656732739

评价

net core 使用 EF Code First

下面这些内容很老了看这篇:https://www.tnblog.net/aojiancc2/article/details/5365 项目使用多层,把数据库访问...

.net mvc分部页,.net core分部页

.net分部页的三种方式第一种:@Html.Partial(&quot;_分部页&quot;)第二种:@{ Html.RenderPartial(&quot;分部页&quot;);}...

StackExchange.Redis操作redis(net core支持)

官方git开源地址https://github.com/StackExchange/StackExchange.Redis官方文档在docs里边都是官方的文档通过nuget命令下...

.net core 使用session

tip:net core 2.2后可以直接启用session了,不用在自己添加一次session依赖,本身就添加了使用nuget添加引用Microsoft.AspN...

通俗易懂,什么是.net?什么是.net Framework?什么是.net core?

朋友圈@蓝羽 看到一篇文章写的太详细太通俗了,搬过来细细看完,保证你对.NET有个新的认识理解原文地址:https://www.cnblo...

asp.net core2.0 依赖注入 AddTransient与AddScoped的区别

asp.net core主要提供了三种依赖注入的方式其中AddTransient与AddSingleton比较好区别AddTransient瞬时模式:每次都获取一...

.net core 使用 Kestrel

Kestrel介绍 Kestrel是一个基于libuv的跨平台web服务器 在.net core项目中就可以不一定要发布在iis下面了Kestrel体验可以使...

net core中使用cookie

net core中可以使用传统的cookie也可以使用加密的cookieNET CORE中使用传统cookie设置:HttpContext.Response.Cookies.Appe...

net core项目结构简单分析

一:wwwrootwwwroot用于存放网站的静态资源,例如css,js,图片与相关的前端插件等lib主要是第三方的插件,例如微软默认引用...

net core使用EF之DB First

一.新建一个.net core的MVC项目新建好项目后,不能像以前一样直接在新建项中添加ef了,需要用命令在添加ef的依赖二.使用Nug...

.net core使用requestresponse下载文件下载excel等

使用request获取内容net core中request没有直接的索引方法,需要点里边的Query,或者formstringbase64=Request.Form[&quot;f...

iframe自适应高度与配合net core使用

去掉iframe边框frameborder=&quot;0&quot;去掉滚动条scrolling=&quot;no&quot;iframe 自适应高度如果内容是固定的,那么就...

net core启动报错Unable to configure HTTPS endpoint. No server certificate was specified

这是因为net core2.1默认使用的https,如果使用Kestrel web服务器的话没有安装证书就会报这个错其实仔细看他的错误提示,其...

net core中使用url编码与解码操作

net core中暂时还没有以前asp.net与mvc中的server对象。获取url的编码与解码操作不能使用以前的server对象来获取。使用的是...

下载net core

官方下载地址:https://dotnet.microsoft.com/download 进来之后就可以看到最新的下载版本可以直接点击下载,也可以下载其...
这一世以无限游戏为使命!
排名
2
文章
623
粉丝
44
评论
93
docker中Sware集群与service
尘叶心繁 : 想学呀!我教你呀
一个bug让程序员走上法庭 索赔金额达400亿日元
叼着奶瓶逛酒吧 : 所以说做程序员也要懂点法律知识
.net core 塑形资源
剑轩 : 收藏收藏
映射AutoMapper
剑轩 : 好是好,这个对效率影响大不大哇,效率高不高
ASP.NET Core 服务注册生命周期
剑轩 : http://www.tnblog.net/aojiancc2/article/details/167
ICP备案 :渝ICP备18016597号-1
网站信息:2018-2025TNBLOG.NET
技术交流:群号656732739
联系我们:contact@tnblog.net
公网安备:50010702506256
欢迎加群交流技术