标签：queue 订单状态 new t action 状态 src 支持 pre lock
上篇博文中我们介绍了Azure Messaging-ServiceBus Messaging消息回执机制。
Azure Messaging-ServiceBus Messaging消息回执机制
本文中我们主要研究消息的事务。直奔主题：
那消息事务的实际应用场景有哪些呢？例如：
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 中对消息事务的支持。
2017/3/30
Azure Messaging-ServiceBus Messaging消息队列技术系列7-消息事务
标签：queue 订单状态 new t action 状态 src 支持 pre lock
原文地址：http://www.cnblogs.com/yezuhui/p/6844468.html
