.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的总结图



.NET分布式事务--TransactionScop,古老的榕树,5-wow.com

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。