Azure Messaging-ServiceBus Messaging消息队列技术系列7-消息事务
2017-05-12 10:47
399 查看
上篇博文中我们介绍了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.发送更新订单状态消息和更新账户余额消息成功后,启动一个事务性的会话,接收并处理这两条消息。
那我们先从同一个队列中发送多条消息这个场景验证:
发送消息完成,但是未提交事务前,队列是这样的:
事务提交后Complete:
然后,我们继续研究验证同一个队列接收消息的事务性:有个前提要求:
消息接收时,如果启动事务,消息消费接收模式必须是PeekAndLock模式。
消息接收完成,如果事务不Complete,消息仍旧在消息队列中。
当接收完消息,事务未提交时:
队列中的消息是:
事务提交后:
Azure Service Bus 中消息:
消息已经被消费。
以上就是Azure ServiceBus 中对消息事务的支持。
2017/3/30
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 中对消息事务的支持。
2017/3/30
相关文章推荐
- Azure Messaging-ServiceBus Messaging消息队列技术系列7-消息事务
- Azure Messaging-ServiceBus Messaging消息队列技术系列5-重复消息:at-least-once at-most-once
- Azure Messaging-ServiceBus Messaging消息队列技术系列1-基本概念和架构
- Azure Messaging-ServiceBus Messaging消息队列技术系列4-复杂对象消息是否需要支持序列化和消息持久化
- Azure Messaging-ServiceBus Messaging消息队列技术系列4-复杂对象消息是否需要支持序列化和消息持久化
- Azure Messaging-ServiceBus Messaging消息队列技术系列4-复杂对象消息是否需要支持序列化和消息持久化
- Azure Messaging-ServiceBus Messaging消息队列技术系列4-复杂对象消息是否需要支持序列化和消息持久化
- Azure Messaging-ServiceBus Messaging消息队列技术系列6-消息回执
- Azure Messaging-ServiceBus Messaging消息队列技术系列6-消息回执
- Azure Messaging-ServiceBus Messaging消息队列技术系列4-复杂对象消息是否需要支持序列化和消息持久化
- Azure Messaging-ServiceBus Messaging消息队列技术系列3-消息顺序保证
- Azure Messaging-ServiceBus Messaging消息队列技术系列8-服务总线配额
- Azure Messaging-ServiceBus Messaging消息队列技术系列4-复杂对象消息是否需要支持序列化和消息持久化
- Azure Messaging-ServiceBus Messaging消息队列技术系列-索引篇
- Azure Messaging-ServiceBus Messaging消息队列技术系列4-复杂对象消息是否需要支持序列化和消息持久化
- 服务端技术进阶(五)分布式系统解决之道:目录、消息队列、事务系统及其他
- Azure Messaging-ServiceBus Messaging
- 消息队列基础 RabbitMQ与AMQP协议详解——超大规模高可用OpenStack核心技术深入解析系列(二)
- 服务端技术进阶(五)分布式系统解决之道:目录、消息队列、事务系统及其他
- 消息队列基础 RabbitMQ与AMQP协议详解——超大规模高可用OpenStack核心技术深入解析系列(二)