首页
视频
资源
登录
原
.netcore3.1 RabbitMq 发布消息确认
4500
人阅读
2021/2/3 14:35
总访问:
2534741
评论:
0
收藏:
0
手机
分类:
RabbitMq
![](https://img.tnblog.net/arcimg/hb/585b0f1ffa7f4c2095baa20c175b32a0.png) >#.netcore3.1 RabbitMq 发布确认 [TOC] tn>在发布端一般有两种确认发布消息的模式,`Confirm`与`Tx`事务确认的模式,其中`Tx`所消耗的性能大于`Confim`所消耗的性能。所有尽量用`Confirm`,除非可靠性要求相当高。 Confirm模式 ------------ tn>我们创建一个普通的队列并,在发送消息前通过`ConfirmSelect`开启`Confirm`确认模式,并在发布完成消息后通过`WaitForConfirms`方法接收消息已经发布。我们来调试一下如下代码: ```csharp var factory = new ConnectionFactory() { HostName = "47.98.187.188", UserName = "bob", Password = "bob" }; // 创建一个链接 using (var connection = factory.CreateConnection()) { // 创建一个通道 using (var channel = connection.CreateModel()) { // 声明一个Single_Active_Consumer_Queue队列 channel.QueueDeclare( queue: "mytest", durable: true, exclusive: false, autoDelete: false, arguments: null); // 开启发布确认 channel.ConfirmSelect(); // 发布Priority_Queue队列中的消息 for (int i = 0; i < 10; i++) { var msg = Encoding.UTF8.GetBytes($"Message {i} ,Priority: 1"); channel.BasicPublish(string.Empty, "mytest", null, msg); } // 等待,直到所有发布的消息都已确认。可以传入一个超时参数 var Result = channel.WaitForConfirms(); Console.WriteLine(" Press [enter] to exit."); Console.ReadLine(); } } ``` ![](https://img.tnblog.net/arcimg/hb/3ac976feacfa4944aacb61554f23bb0e.png) ![](https://img.tnblog.net/arcimg/hb/529296fdf79d4ffebb882b46c5736084.png) ![](https://img.tnblog.net/arcimg/hb/49ba8c1949db41c28d6f1ae67165a6e8.png) ![](https://img.tnblog.net/arcimg/hb/a5b3baee3881435c9c32a12ef55c371d.png) ![](https://img.tnblog.net/arcimg/hb/83cfdd4b4a964da286c4da2f88123f50.png) Tx事务确认发布消息 ------------ tn>我们先清理一下队列中的消息,然后通过`TxSelect`方法开启事务,通过`TxCommit`方法提交消息,如果中途发布失败我们需要通过`TxRollback`回滚事务。我们来调试一下,下面的例子: ```csharp var factory = new ConnectionFactory() { HostName = "47.98.187.188", UserName = "bob", Password = "bob" }; // 创建一个链接 using (var connection = factory.CreateConnection()) { // 创建一个通道 using (var channel = connection.CreateModel()) { // 声明一个Single_Active_Consumer_Queue队列 channel.QueueDeclare( queue: "mytest", durable: true, exclusive: false, autoDelete: false, arguments: null); try { // 开启发布事务 channel.TxSelect(); // 发布Priority_Queue队列中的消息 for (int i = 0; i < 10; i++) { var msg = Encoding.UTF8.GetBytes($"Message {i} ,Priority: 1"); channel.BasicPublish(string.Empty, "mytest", null, msg); } // 确认消息提交 channel.TxCommit(); } catch (Exception ex) { // 回滚事务 channel.TxRollback(); } Console.WriteLine(" Press [enter] to exit."); Console.ReadLine(); } } ``` ![](https://img.tnblog.net/arcimg/hb/43cce4a47a7b4079a5d3b6f7c11b76c2.png) ![](https://img.tnblog.net/arcimg/hb/d27dc22e8f5c473c83f04ecba2f409a2.png) tn>我们发现在事务没有提交之前是没有消息的!提交后就有了。 ![](https://img.tnblog.net/arcimg/hb/cc8f9829fc614201bc2c17cc1c6143ac.png)
欢迎加群讨论技术,1群:677373950(满了,可以加,但通过不了),2群:656732739
👈{{preArticle.title}}
👉{{nextArticle.title}}
评价
{{titleitem}}
{{titleitem}}
{{item.content}}
{{titleitem}}
{{titleitem}}
{{item.content}}
尘叶心繁
这一世以无限游戏为使命!
博主信息
排名
6
文章
6
粉丝
16
评论
8
文章类别
.net后台框架
166篇
linux
17篇
linux中cve
1篇
windows中cve
0篇
资源分享
10篇
Win32
3篇
前端
28篇
传说中的c
4篇
Xamarin
9篇
docker
15篇
容器编排
101篇
grpc
4篇
Go
15篇
yaml模板
1篇
理论
2篇
更多
Sqlserver
4篇
云产品
39篇
git
3篇
Unity
1篇
考证
2篇
RabbitMq
23篇
Harbor
1篇
Ansible
8篇
Jenkins
17篇
Vue
1篇
Ids4
18篇
istio
1篇
架构
2篇
网络
7篇
windbg
4篇
AI
18篇
threejs
2篇
人物
1篇
嵌入式
2篇
python
13篇
HuggingFace
8篇
pytorch
9篇
opencv
6篇
最新文章
最新评价
{{item.articleTitle}}
{{item.blogName}}
:
{{item.content}}
关于我们
ICP备案 :
渝ICP备18016597号-1
网站信息:
2018-2024
TNBLOG.NET
技术交流:
群号656732739
联系我们:
contact@tnblog.net
欢迎加群
欢迎加群交流技术