Azure Messaging-ServiceBus Messaging消息队列技术系列7-消息事
上篇博文中我们介绍了Azure Messaging-ServiceBus Messaging消息回执机制。 Azure Messaging-ServiceBus Messaging消息回执机制 本文中我们主要研究消息的事务。直奔主题:
那消息事务的实际应用场景有哪些呢?例如: 1.启动一个事务性的会话,将发送更新订单状态消息和更新账户余额消息放到一个事务中,消息发送失败后 rollback,确认消息未被发送。 那我们先从同一个队列中发送多条消息这个场景验证: 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 = TransactionScope()) 12 { 13 var order1 = CreateSalesOrder(114 var order2 = CreateSalesOrder(215 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 ReceiveMessageTransactional() 4 var queueReveiveClient = sbUtils.GetReceiveQueueClient(queueName,ReceiveMode.PeekLock); 6 7 queueReveiveClient.Receive(); 8 message1.Complete(); 9 10 message2.Complete(); 11 Console.WriteLine(Received but uncomplete!13 14 Console.WriteLine(15 } 16 } 当接收完消息,事务未提交时: 队列中的消息是: 事务提交后: Azure Service Bus 中消息: 消息已经被消费。 以上就是Azure ServiceBus 中对消息事务的支持。 ? 2017/3/30 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |