绵阳微信网站,公司网站建设南宁,软件开发用什么工具,o2o系统软件背景 前面写了两篇#xff08;聊一聊如何用C#轻松完成一个SAGA分布式事务和聊一聊如何用C#轻松完成一个TCC分布式事务#xff09;如何用 C# 基于 DTM 轻松实现 SAGA 和 TCC 的分布式事务#xff0c;其中有一个子事务屏障的功能#xff0c;很好的处理了空补偿、悬挂、重复请… 背景 前面写了两篇聊一聊如何用C#轻松完成一个SAGA分布式事务和聊一聊如何用C#轻松完成一个TCC分布式事务如何用 C# 基于 DTM 轻松实现 SAGA 和 TCC 的分布式事务其中有一个子事务屏障的功能很好的处理了空补偿、悬挂、重复请求等异常问题。https://dtm.pub/practice/barrier.html不过前面的例子都是基于 mysql 的有人问是否还支持其他数据库。很明显这个是支持的关系型数据库这一块除了 mysql还支持 pgsql 和 sql server 。现存的一些系统肯定还有不少是基于 sql server 开发的如果这一批系统想接入 DTM就不需要先迁库再接入了。那么接下来老黄就带大家体验一下基于 sql server 版本的 DTM 子事务屏障功能。例子会基于前面 SAGA 的例子进行改造。子事务屏障表 要先使用子事务屏障必不可少的是要准备一个子事务屏障表那么这个子事务屏障表要放在那个实例的那个库下面呢这里只需要保证要操作的业务数据和子事务屏障能在同一个本地事务里面即可。下面是针对 SQL Server 的建表 SQL。IF EXISTS (SELECT * FROM sysobjects WHERE id object_id(N’[dbo].[barrier]’) and OBJECTPROPERTY(id, N’IsUserTable’) 1)
BEGINDROP TABLE [dbo].[barrier]
ENDGOCREATE TABLE [dbo].[barrier]
([id] bigint NOT NULL IDENTITY(1,1) PRIMARY KEY,[trans_type] varchar(45) NOT NULL DEFAULT(),[gid] varchar(128) NOT NULL DEFAULT(),[branch_id] varchar(128) NOT NULL DEFAULT(),[op] varchar(45) NOT NULL DEFAULT(),[barrier_id] varchar(45) NOT NULL DEFAULT(),[reason] varchar(45) NOT NULL DEFAULT(),[create_time] datetime NOT NULL DEFAULT(getdate()) ,[update_time] datetime NOT NULL DEFAULT(getdate())
)GOCREATE UNIQUE INDEX[ix_uniq_barrier] ON[dbo].[barrier]([gid] ASC, [branch_id] ASC, [op] ASC, [barrier_id] ASC)
WITH(IGNORE_DUP_KEY ON)GO这里比较关键的是那个唯一索引有一个 IGNORE_DUP_KEY ON。这个其实就是为了等价 mysql 的 insert ignore。到这里其实准备工作就已经七七八八了。下面就来改造后例子吧要做的东西不多就是切换一些配置。切换配置 要在 InApi 里面指定子事务屏障的数据库类型和自定义的表名。在启动前进行下面的配置// 指定 子事务屏障 数据库类型为 sql server
Dtmcli.DtmImp.DbSpecialDelegate.Instance.SetCurrentDBType(sqlserver);// 指定 子事务屏障表的表名
Dtmcli.BranchBarrier.SetBarrierTableName([test].[dbo].[barrier]);对于表名这一块老黄是建议把库名也加上的。PS: 这个设置后续应该会放到配置文件中现阶段基本是保持和 go 版本类似的写法。最后不可以少的就是要改一下连接字符串和 SqlConnection 了。public class Db
{private static readonly string _conn Data Source127.0.0.1, 1433;Initial Catalogtest;user iddev;password123456;TrustServerCertificateTrue;;public static DbConnection GeConn() new Microsoft.Data.SqlClient.SqlConnection(_conn);
}到这里所有的改造就已经完成了。下面来看具体的例子演示吧。例子演示 这里演示的是 聊一聊如何用C#轻松完成一个SAGA分布式事务 里面的空补偿和幂等两个问题。先来看空补偿的再来看看幂等的日志输出和行为效果基本都是一致的。最后看看数据库里面的数据写在最后 在这篇文章里介绍了如何在子事务屏障中使用 SQL Server 作为底层存储。希望对研究分布式事务的您有所帮助。本文示例代码 https://github.com/catcherwong-archive/2022/tree/main/DtmMsSqlSample参考资料https://dtm.pub/practice/barrier.html#原理https://github.com/dtm-labs/dtmcli-csharp
