当我们需要更改两个系统中的数据时，双写入就会出现问题：数据库（SQL 或 NoSQL）和 Apache Kafka（例如）。必须可靠地/自动地更新数据库并发布消息。最终一致性是可以接受的，但不一致是不能接受的。

如果没有两阶段提交 (2PC)，双写入会导致不一致。

但在大多数情况下，2PC 并不是一个选择。

事务发件箱是一种微服务架构模式，其中单独的消息中继进程将插入数据库的事件发布到消息代理。

并行运行的多个消息中继进程会导致发布重复项（2 个进程读取 OUTBOX 表中的相同记录）或无序（如果每个进程只读取 OUTBOX 表的一部分）。

单个消息中继进程也可能多次发布消息。消息中继可能会在处理 OUTBOX 记录之后但在记录它已完成此操作的事实之前崩溃。当消息中继重新启动时，它将再次发布相同的消息。

如何在事务发件箱模式中实现消息中继，以便将重复消息或无序的风险降至最低，并且该概念适用于所有 SQL 和 NoSQL 数据库？

我们在一台机器上遇到问题,并显示错误消息:

"服务器XXX上的MSDTC不可用."

代码使用TransactionScope来包装一些LingToSql数据库代码; 交易中还有一些原始的Ado.net.

由于只访问了一个sql数据库(2005),为什么要使用分布式事务呢？

(我不想知道如何启用MSDTC,因为代码需要在服务器上使用其当前设置)

我想确认实体框架的ObjectContext.Connection.BeginTransaction()方法返回的事务是否使用MSDTC(Microsoft分布式事务处理协调器)的支持？

有没有办法在没有MSDTC支持的情况下使用交易？

背景

有一个消息队列域.此域可能适用于某些消息队列技术.在这种特殊情况下,它绑定到Windows Azure Service Bus.

某些项目具有注册Windows Azure Service Bus主题(基本上是消息队列)的操作.

注册新的消息队列意味着:

1. 启动域事务(即数据库事务).
2. 添加带有一些关联信息的消息队列域对象(例如用户注册它或者属于整个消息队列的应用程序).
3. 使用控制反转来处理消息队列服务器中的实际队列注册(在这种情况下,它将针对Windows Azure Service Bus发生).
4. 如果没有出错,域事务将被调用,并且关联的域对象将被持久化或更新.

在背景之上,如果域事务成功结束并且Windows Azure Service Bus主题注册正常工作,它应该可以正常工作.

问题

但是,如果域事务成功结束但Windows Azure Service Bus无法注册主题 - 即消息队列 - 会发生什么？

是的,你是一个破碎的域名.

如果在域事务启动之前进行Windows Azure Service Bus主题注册会发生什么？好吧,如果一切顺利,没问题.但现在问题已经被颠倒了:如果Windows Azure Service Bus主题被正确注册但后来域事务失败会发生什么？

是的,第二种情况比第一种情况要好,因为操作已经注册了一个无用的消息队列,但域名不知道它.现在主要的问题是,不确定数量的事务可能会失败,并且未知数量的消息队列将一无所获.

试想一下,如果这是一个严肃而庞大的商业服务:许多无用的消息队列和一个系统管理员(一个人)每月删除无用的消息队列.

那么什么 - 现在的问题 - ？

由于我发现选择使用无用的消息队列比拥有破坏的域更好,我选择以这种方式继续前进,但是... 有Windows Azure任何类型的分布式事务机制以包含任何远程对象在原子事务中创建,包括其他特定于域的操作？,如果没有-可惜我认为,这是实际情况-你将如何解决这个情况？

注意:

我正在寻找这样的东西,因为我真的不喜欢有一个根本无法处理其用例的域名.我宁愿避免这种情况,让域名正常运行并控制一切.

一些有趣的链接......

我发现了一些关于这个主题的有趣链接:

http://blogs.msdn.com/b/clemensv/archive/2012/07/30/transactions-in-windows-azure-with-service-bus-an-email-discussion.aspx

大家好我们已经开始使用事务范围,下面是代码片段.我们需要了解的是,在每次使用连接后,我们的底线是否会处理/关闭特定连接？所以,自关闭以来,transaction.complete如何运作？

using (TransactionScope transScope = new TransactionScope())
{
   try
   {
      string myConnStringLocal = "User Id=***;Password=****;Host=" + globalSettings.settingLocalIP + ";Database=" + globalSettings.settingLocalDB;
      using (MySqlConnection connectionLocal = new MySqlConnection(myConnStringLocal))
      {
         try{
         connectionLocal.Open();
         }
         Catch(Exception e)
         {

         }
         finally{
         connectionLocal.Close();
         }
      }

      string myConnStringCentral = "User Id=***;Password=*****;Host=" + globalSettings.settingCentralIP + ";Database=" + globalSettings.settingCentralDB;
      using (MySqlConnection connectionCentral = new MySqlConnection(myConnStringCentral))
      {
         try{
         connectionCentral.Open();
         }
         Catch(Exception e)
         {

         }
         finally{
         connectionCentral.Close();
         }

      }
      string myConnStringCentralCopy = "User Id=*****;Password=*****;Host=" + globalSettings.settingCentralCopyIP + ";Database=" + globalSettings.settingCentralCopyDB;
      using …