开源：Taurus.DTC 微服务分布式事务框架，支持 .Net 和 .Net Core 双系列版本

2024/1/12 14:02:59

编程Tag： Taurus.MVC 微服务框架（双语言支持：.Net Core/Java） cyq.data taurus.dtc .net core 分布式事务

本文主要是介绍开源：Taurus.DTC 微服务分布式事务框架，支持 .Net 和 .Net Core 双系列版本，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

前言：

在经过1年多的深思，十几年的框架编写技术沉淀下，花了近一个月的时间，终于又为 .Net 及 .Net Core 的微服务系列框架贡献当中的一个重要组件。

1、开源地址：

https://github.com/cyq1162/Taurus.DTC

2、Nuget 包引用ID：

由于 CYQ.Data Orm 组件本身支持10多种数据库，因此提供的包，只根据消息队列的需要分拆提供。

默认Taurus.DTC 支持同时使用 RabbitMQ 和 Kafka 两种消息队列。

如果一个项目中只用RabbitMQ，则引入 Tarurus.DTC.RabbitMQ，减少对 Kafka 的依赖包。

3、Taurus.DTC 微服务分布式事务框架基础说明：

基础说明：

1、框架分为 Client（客户端，即调用端）和 Server（服务端，即服务提供方）。

2、项目需要选择数据存储类型（数据库或分布式缓存）和数据传输类型（消息队列）。

3、框架的名称空间：Taurus.Plugin.DistributedTransaction。

4、框架在设计上采用异步最终一致性的设计理念，并实现了无需入侵业务数据库的机制。

数据存储：

可选择数据库（MSSQL、MySql、Oracle、PostgreSql 等 CYQ.Data 所支持的10多种数据库之一）

MSSQL配置示例如下：

{
  "ConnectionStrings": {
    "DTC.Server.Conn": "server=.;database=MSLog;uid=sa;pwd=123456"
  }
}

也可选择分布式缓存存储，配置示例如下（二者选其一即可）：

{
  "AppSettings": {
  "Redis.Servers":"127.0.0.1:6379 ,192.168.1.111:6379-withpassword",
  "MemCache.Servers":"127.0.0.1:11211" 
  }
}

消息队列：

目前消息队列支持 RabbitMQ 或者 Kafka（配置其中一方即可）：

{
  "AppSettings": {
  "DTC.Server.Rabbit":"127.0.0.1;guest;guest;/",//ip;username;password;virtualpath;
  "DTC.Server.Kafka":"127.0.0.1:9092" 
  }
}

以上配置为Server端，客户端更改 Server 为 Client 即可。

名称空间下提供类库使用：

DTC：

Client 端：提供三个方法，事务提交、事务回滚、任务发布。
DTC.Client.CommitAsync(...) //事务提交
DTC.Client.RollBacktAsync(...) //事务回滚
DTC.Client.PublishTaskAsync(...) //发布任务


Server 端：提供一个方法，事务订阅
DTC.Server.Subscribe(...) //订阅事务回调。

DTCConfig：

左侧为代码，右侧为配置 AppSettings 的 key
// 是否启用，默认 true
DTCConfig.Client.IsEnable，对应配置项：DTC.Client.IsEnable
// 是否打印追踪日志，日志写入App_Data\log 目录。
DTCConfig.Client.IsPrintTraceLog，对应配置项：DTC.Client.IsPrintTraceLog
// 配置数据库存储链接，链接 key 是在 ConnectionStrings 中。
DTCConfig.Client.Conn，对应配置项：DTC.Client.Conn
//配置数据库对应生成的表名：默认DTC_Client
DTCConfig.Client.TableName，对应配置项：DTC.Client.TableName
//配置使用的RabbitMQ消息队列，配置格式为：ip;username;password;virtualpath;
DTCConfig.Client.Rabbit，对应配置项：DTC.Client.Rabbit
//配置使用的Kafka消息队列，配置格式为：ip:port
DTCConfig.Client.Kafka，对应配置项：DTC.Client.Kafka
//以下为定时线程任务配置：
//扫描的间隔时间
DTCConfig.Client.Worker.ScanDBSecond，对应配置项：DTC.Client.ScanDBSecond
//事务或任务确认完成状态时，清除模式是删除还是转移到历史表，对应：DTC_Client_History
DTCConfig.Client.Worker.ConfirmClearMode，对应配置项：DTC.Client.ConfirmClearMode
//事务或任务未完成状态时，保留秒数。
DTCConfig.Client.Worker.TimeoutKeepSecond，对应配置项：DTC.Client.TimeoutKeepSecond
//事务或任务未完成状态时，清除模式是删除还是转移到历史表，对应：DTC_Client_History
DTCConfig.Client.Worker.TimeoutClearMode，对应配置项：DTC.Client.TimeoutClearMode
//事务或任务未完成状态时，最大可重试次数。
DTCConfig.Client.Worker.MaxRetries，对应配置项：DTC.Client.MaxRetries

Server 和 Client 的配置属性一致，仅 Client 换成 Server。

DTC 特性标准和方法回调参数：

Server 端：
特性标注：DTCServerSubscribe
回调参数：DTCServerSubscribePara 

Client 端：
特性标注：DTCClientCallBack
回调参数：DTCClientCallBackPara

4、Server 端使用 .Net Core 示例：

1、Nuget 搜索 Taurus.DTC 引入工程项目中。

2、Program 或 Startup 添加服务使用引入：

  services.AddTaurusMvc(); // 服务添加
  app.UseTaurusDtc(StartType.Server); //服务使用，启用服务端

3、appsettings.json 配置基本属性：

  {
  "ConnectionStrings": {
    "DTC.Server.Conn": "host=localhost;port=3306;database=cyqdata;uid=root;pwd=123456;Convert Zero Datetime=True;"
  },
  "AppSettings": {
    "DTC.Server.Rabbit": "127.0.0.1;guest;guest;/" //IP;UserName;Password;VirtualPaath
}

4、选择数据库对应的依赖组件，如MySql，可以：

Nuget 上可以搜索 MySql.Data 、或者 CYQ.Data.MySql (会自动引入MySql.Data)  都可， 引入项目即可。

5、代码编写，可以参考源码中提供的示例代码，如下：

    public class ServerController : Taurus.Mvc.Controller
    {
    /// <summary>
    /// provide a Create api , and it provide a transation , call https://localhost:5001/server/create
    /// </summary>
    [HttpPost]
    [Require("name")]
    public void Create(string name)
    {
        //do something insert
        int createID = 123456;
        //here will receive a header:X-Request-ID 
        if (DTC.Server.Subscribe(createID.ToString(), "OnCreate")) // 事务相关信息保存，以便后续回调处理提交或回滚
        {
            Console.WriteLine("call : DTC.Server.Subscribe call.");
        }
        Write(createID, true);
    }


    [DTCServerSubscribe("OnCreate")] //订阅回调，处理提交或回滚
    private static bool AnyMethodNameForOnCreateCallBack(DTCServerSubscribePara para)
    {
        para.CallBackContent = "what message you need?";
        Console.WriteLine("call back :" + para.ExeType + " , content :" + para.Content);
        if (para.ExeType == ExeType.Commit) { return true; }
        if (para.ExeType == ExeType.RollBack)
        {
            string createID = para.Content;
            //return DeleteByID(createID);
            return true;
        }
        return false;
    }

    [DTCServerSubscribe("ToDoTask")] // 订阅任务
    private static bool DoSomeTask(DTCServerSubscribePara para)
    {
        Console.WriteLine("call :" + para.ExeType + " , content :" + para.Content);
        para.CallBackContent = "I do ok.";
        return true;
    }

}

5、Client 端使用 .Net Core 示例：