上篇博文中我们介绍了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 }
当接收完消息，事务未提交时：
队列中的消息是：
事务提交后：
Azure Service Bus 中消息：
消息已经被消费。
以上就是Azure ServiceBus 中对消息事务的支持。
http://www.cnblogs.com/tianqing/p/6648887.html
更多精彩分享
- 构建混合应用方式之Azure WCF中继 2017-07-26 16:20:39.78
- 构建混合应用方式之Azure混合连接 2017-07-11 09:30:44.493
- Azure IoT 技术研究系列2-设备注册到Azure IoT Hub 2017-07-05 15:50:27.387
- Azure IoT 技术研究系列1-入门篇 2017-07-05 10:30:16.337
- Azure Messaging-ServiceBus Messaging消息队列技术系列6-消息回执 2017-06-29 16:03:29.473
- Python 操作 Azure Blob Storage 2017-06-23 15:22:14.817
- Azure Messaging-ServiceBus Messaging消息队列技术系列5-重复消息：at-least-once at-most-once 2017-06-20 16:34:43.907
- Azure经典门户创建VM，如何设置使用静态IP地址？ 2017-06-14 16:55:43.723
- 微软.NET年芳15：我在Azure上搭建Photon服务器(C#.NET) 2017-06-08 14:39:18.22
- 在Azure China用自定义镜像创建Azure VM Scale Set 2017-06-02 16:12:57.997
构建混合应用方式之Azure混合连接