.NET分布式事务--TransactionScop
概述
SqlTransaction可以解决同一个数据库的事务控制,但是,不能解决不同数据库的事务控制,今天就说一说,这个的解决方法,即:TransactionScope的应用。
本篇博客的的思路就是先进行一些相应的配置(开启DTC服务,配置MSDTC,配置防火墙,配置数据库管理系统),然后再进行一个实例的展示(代码),最后进行简单原理的介绍和总结。
了解了本篇博客的流程和结构后,接下来就看相应具体的内容吧!
开启DTC服务
方式一
计算机—管理—服务—Distributed(分布式)Link Tracking Client—属性—开启
方式二
字符命令子界面输入:net start msdtc
设置MSDTC
命令界面输入:dcomcnfg.exe(或者:控制面板—管理工具—组件服务)
防火墙设置
有两种方法:1、直接关闭防火墙(不建议使用,以前数据库连接的时候这样干过);2、进行如下图的设置
数据库管理系统设置
因为要实现多个数据库系统之间事务的控制,所以,数据库系统也需要做相应的设置,具体如下图。
代码
下面是一个简单的Demo,实现了两个功能:1、同一数据库系统,不同数据库的事务控制;2、不同数据库系统的事务控制。
控制台代码
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Transactions; namespace 事务.分布式 { class Program { static void Main(string[] args) { #region 同一个数据库服务器,操作不同的数据库 //using (TransactionScope tran = new TransactionScope()) //{ // OperateDataBase operateDataBase = new OperateDataBase(); // int i = operateDataBase.Execute1(); // int j = operateDataBase.Execute2(); // tran.Complete(); //} #endregion #region 不同的数据库服务器 using (TransactionScope tran = new TransactionScope()) { OperateDifferentDataBaseServer operateDifferentDataBaseServer = new OperateDifferentDataBaseServer(); int i = operateDifferentDataBaseServer.Execute1(); int j = operateDifferentDataBaseServer.Execute2(); tran.Complete(); } #endregion } } }
OperateDataBase.cs类(同一数据库服务器,不同数据库)
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Data; using System.Data.SqlClient; using System.Configuration; namespace 事务.分布式 { public class OperateDataBase { private SqlConnection sqlCon1; private SqlConnection sqlCon2; private SqlCommand sqlCom; #region 数据库系统1—数据库1—连接对象 private void GetConnection1() { if (sqlCon1 == null) { sqlCon1 = new SqlConnection(ConfigurationManager.ConnectionStrings["strCon1"].ToString()); } if (sqlCon1.State == ConnectionState.Closed) { sqlCon1.Open(); } } #endregion #region 数据库系统1—数据库2—连接对象 private void GetConnection2() { if (sqlCon2 == null) { sqlCon2 = new SqlConnection(ConfigurationManager.ConnectionStrings["strCon2"].ToString()); } if (sqlCon2.State == ConnectionState.Closed) { sqlCon2.Open(); } } #endregion #region 数据库系统1—数据库1—添加数据 public int Execute1() { GetConnection1(); sqlCom = new SqlCommand("insert into DataTable2(id,name) values(1,‘张三‘)"); sqlCom.Connection = sqlCon1; return sqlCom.ExecuteNonQuery(); } #endregion #region 数据库系统1—数据库2—添加数据 public int Execute2() { GetConnection2(); sqlCom = new SqlCommand("insert into DataTable2(id,name) values(1,‘李四‘)"); sqlCom.Connection = sqlCon2; return sqlCom.ExecuteNonQuery(); } #endregion } }
OperateDifferentDataBaseServer.cs(不同数据库系统)
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Data; using System.Data.SqlClient; using System.Configuration; namespace 事务.分布式 { public class OperateDifferentDataBaseServer { private SqlConnection sqlCon1; private SqlConnection sqlCon2; private SqlCommand sqlCom; #region 数据库服务器系统1—数据库连接对象 private void GetConnection1() { if (sqlCon1 == null) { sqlCon1 = new SqlConnection(ConfigurationManager.ConnectionStrings["strConS1"].ToString()); } if (sqlCon1.State == ConnectionState.Closed) { sqlCon1.Open(); } } #endregion #region 数据库服务器系统2—数据库连接对象 private void GetConnection2() { if (sqlCon2 == null) { sqlCon2 = new SqlConnection(ConfigurationManager.ConnectionStrings["strConS2"].ToString()); } if (sqlCon2.State == ConnectionState.Closed) { sqlCon2.Open(); } } #endregion #region 数据服务器系统1—添加数据 public int Execute1() { GetConnection1(); sqlCom = new SqlCommand("insert into DataTable2(id,name) values(17,‘张三‘)"); sqlCom.Connection = sqlCon1; return sqlCom.ExecuteNonQuery(); } #endregion #region 数据库管理系统2—添加数据 public int Execute2() { GetConnection2(); sqlCom = new SqlCommand("insert into DataTable2(id,name) values(17,‘李四‘)"); sqlCom.Connection = sqlCon2; return sqlCom.ExecuteNonQuery(); } #endregion } }配置文件的代码和数据库代码,可以通过阅读上面的代码,自己写出来,这里就不提供了
简单原理的介绍
我们系统在多台计算机上,那么,到底哪些机子需要进行上面的配置呢?这里大致说一下它的原理。
要想实现A机上运行代码,并且通过代码实现事务控制B机和C机上的数据库系统,那么,最基本的一点,A机要能和B机和C机进行一些特殊的交流,这个交流的实现就依赖于相应的服务,即我们要开启相应的服务,这个服务不是简单的开启,需要我们进行一些设置,开启服务后,我们还要告诉防火墙,你给我放行这个口或这个程序,这些完成后,我们再需要做的就是进行数据库系统的设置,最后做的就是相应的编程了。
总结
这个demo的实现大概用了一整天的时间,其间谢谢欢哥和磊磊的帮助。
下图是关于TransactionScope的总结图
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。