Azure Messaging-ServiceBus Messaging消息队列技术系列7-消息事务

首页 > 代码库 > Azure Messaging-ServiceBus Messaging消息队列技术系列7-消息事务

Azure Messaging-ServiceBus Messaging消息队列技术系列7-消息事务

2024-09-11 11:38:15 220人阅读

上篇博文中我们介绍了Azure Messaging-ServiceBus Messaging消息回执机制。

Azure Messaging-ServiceBus Messaging消息回执机制

本文中我们主要研究消息的事务。直奔主题：

Service Bus Queues支持事务，基于TransactionScope
Service Bus Queues provide support for local transactions in the context of a single queue.
事务的限制：事务只能包含一个Queue或者Topic，订阅不能放在事务中，同时事务不支持其他系统，例如数据库

那消息事务的实际应用场景有哪些呢？例如：

1.启动一个事务性的会话，将发送更新订单状态消息和更新账户余额消息放到一个事务中，消息发送失败后 rollback，确认消息未被发送。
2.发送更新订单状态消息和更新账户余额消息成功后，启动一个事务性的会话，接收并处理这两条消息。

那我们先从同一个队列中发送多条消息这个场景验证：

技术分享

 1   public static void SendMessageTransactional() 2         { 3             var sbUtils = new ServiceBusUtils(); 4  5             //创建队列 6             sbUtils.CreateQueue(queueName, false); 7  8             //多次发送消息到OrderQueue 9             var queueSendClient = sbUtils.GetQueueClient(queueName);10 11             using (var trans = new TransactionScope())12             {13                 var order1 = CreateSalesOrder(1);14                 var order2 = CreateSalesOrder(2);15                 var message1 = sbUtils.Create(order1);16                 var message2 = sbUtils.Create(order2);17                 queueSendClient.Send(message1);18                 queueSendClient.Send(message2);19                 Console.WriteLine("Send but uncomplete!");20                 trans.Complete();21 22                 Console.WriteLine("Complete!");23             }            24         }

发送消息完成，但是未提交事务前，队列是这样的：

技术分享

事务提交后Complete:

技术分享

然后，我们继续研究验证同一个队列接收消息的事务性：有个前提要求：

消息接收时，如果启动事务，消息消费接收模式必须是PeekAndLock模式。

消息接收完成，如果事务不Complete，消息仍旧在消息队列中。

技术分享

 1 public static void ReceiveMessageTransactional() 2         { 3             var sbUtils = new ServiceBusUtils(); 4             var queueReveiveClient = sbUtils.GetReceiveQueueClient(queueName, ReceiveMode.PeekLock); 5             using (var trans = new TransactionScope()) 6             { 7                 var message1 = queueReveiveClient.Receive(); 8                 message1.Complete(); 9                 var message2 = queueReveiveClient.Receive();10                 message2.Complete();11                 Console.WriteLine("Received but uncomplete!");12                 trans.Complete();13 14                 Console.WriteLine("Complete!");15             }16         }