聊一聊DTM子事务屏障功能之SQL Server版

Posted dotNET跨平台

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了聊一聊DTM子事务屏障功能之SQL Server版相关的知识,希望对你有一定的参考价值。

背景

前面写了两篇(聊一聊如何用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)  
BEGIN
  DROP TABLE [dbo].[barrier]
END

GO

CREATE 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())
)

GO

CREATE 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 Source=127.0.0.1, 1433;Initial Catalog=test;user id=dev;password=123456;TrustServerCertificate=True;";

    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

以上是关于聊一聊DTM子事务屏障功能之SQL Server版的主要内容,如果未能解决你的问题,请参考以下文章

聊一聊如何用C#轻松完成一个TCC分布式事务

#聊一聊悟空编辑器#spring框架事务相关知识点Spring框架教程

聊一聊 MySQL 中的事务及其实现原理

聊一聊分布式事务那些事儿

聊一聊Spring中的 Transaction基本实现

深入聊一聊 Spring AOP 实现机制