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

上篇博文中我们介绍了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.发送更新订单状态消息和更新账户余额消息成功后,启动一个事务性的会话,接收并处理这两条消息。

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

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

   public static void SendMessageTransactional()
{
var sbUtils = new ServiceBusUtils(); //创建队列
sbUtils.CreateQueue(queueName, false); //多次发送消息到OrderQueue
var queueSendClient = sbUtils.GetQueueClient(queueName); using (var trans = new TransactionScope())
{
var order1 = CreateSalesOrder();
var order2 = CreateSalesOrder();
var message1 = sbUtils.Create(order1);
var message2 = sbUtils.Create(order2);
queueSendClient.Send(message1);
queueSendClient.Send(message2);
Console.WriteLine("Send but uncomplete!");
trans.Complete(); Console.WriteLine("Complete!");
}
}

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

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

事务提交后Complete:

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

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

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

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

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

 public static void ReceiveMessageTransactional()
{
var sbUtils = new ServiceBusUtils();
var queueReveiveClient = sbUtils.GetReceiveQueueClient(queueName, ReceiveMode.PeekLock);
using (var trans = new TransactionScope())
{
var message1 = queueReveiveClient.Receive();
message1.Complete();
var message2 = queueReveiveClient.Receive();
message2.Complete();
Console.WriteLine("Received but uncomplete!");
trans.Complete(); Console.WriteLine("Complete!");
}
}

当接收完消息,事务未提交时:

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

队列中的消息是:

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

事务提交后:

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

Azure Service Bus 中消息:

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

消息已经被消费。

以上就是Azure ServiceBus 中对消息事务的支持。

2017/3/30

上一篇:Java基础学习笔记十六 集合框架(二)


下一篇:YII中面包屑制作(当前位置:网站首页 >> 会员登陆)