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

背景

银行跨行转账业务是一个典型分布式事务场景，假设 A 需要跨行转账给  B，那么就涉及两个银行的数据，无法通过一个数据库的本地事务保证转账的 ACID ，只能够通过分布式事务来解决。

在  聊一聊如何用C#轻松完成一个SAGA分布式事务 中介绍了借助 DTM 用 SAGA 事务模式解决了上面的银行跨行转账业务。

这一篇我们就来看看如何用 TCC 的事务模式来处理这个问题。

什么是 TCC

TCC是Try、Confirm、Cancel三个词语的缩写，最早是由 Pat Helland 于 2007 年发表的一篇名为《Life beyond Distributed Transactions:an Apostate’s Opinion》的论文提出。

TCC分为3个阶段

  • Try 阶段：尝试执行，完成所有业务检查（一致性）, 预留必需的业务资源（准隔离性）

  • Confirm 阶段：如果所有分支的Try都成功了，则走到Confirm阶段。Confirm真正执行业务，不作任何业务检查，只使用 Try 阶段预留的业务资源

  • Cancel 阶段：如果所有分支的Try有一个失败了，则走到Cancel阶段。Cancel释放 Try 阶段预留的业务资源。

对于前面的跨行转账业务，最简单的做法是，在Try阶段调整余额，在Cancel阶段反向调整余额，Confirm阶段则空操作。这么做带来的问题是，如果A扣款成功，金额转入B失败，最后回滚，把A的余额调整为初始值。在这个过程中如果A发现自己的余额被扣减了，但是收款方B迟迟没有收到余额，那么会对A造成困扰。

更好的做法是，Try阶段冻结A转账的金额，Confirm进行实际的扣款，Cancel进行资金解冻，这样用户在任何一个阶段，看到的数据都是清晰明了的。

下面我们进行一个 TCC 事务的具体开发

前置工作

dotnet add package Dtmcli --version 0.4.0

注：相比 0.3.0，0.4.0 支持了 4 个新的特性，详见 https://github.com/dtm-labs/dtmcli-csharp/releases/tag/v0.4.0

成功的 TCC

先来看一下一个成功完成的 TCC 时序图。

22bdb6b3ad3561cd6d41a532706dc916.png

可以看到它的流程和 SAGA 的还是有比较大的区别。

同样的，上图的微服务1，对应我们示例的 OutApi，也就是转钱出去的那个服务。

微服务2，对应我们示例的 InApi，也就是转钱进来的那个服务。

下面我们来编写两个服务的Try/Confirm/Cancel的处理。

OutApi

app.MapPost("/api/TransOutTry", async (IBranchBarrierFactory bbFactory, HttpContext context, TransRequest req) => 
{var bb = bbFactory.CreateBranchBarrier(context.Request.Query);using var db = Db.GeConn();await bb.Call(db, async (tx) =>{Console.WriteLine($"用户【{req.UserId}】转出【{req.Amount}】Try 操作，bb={bb}");// tx 参数是事务，可和本地事务一起提交回滚await Task.CompletedTask;});return Results.Ok(TransResponse.BuildSucceedResponse());
});app.MapPost("/api/TransOutConfirm", async (IBranchBarrierFactory bbFactory, HttpContext context, TransRequest req) =>
{var bb = bbFactory.CreateBranchBarrier(context.Request.Query);using var db = Db.GeConn();await bb.Call(db, async (tx) =>{Console.WriteLine($"用户【{req.UserId}】转出【{req.Amount}】Confirm操作，bb={bb}");await Task.CompletedTask;});return Results.Ok(TransResponse.BuildSucceedResponse());
});app.MapPost("/api/TransOutCancel", async (IBranchBarrierFactory bbFactory, HttpContext context, TransRequest req) =>
{var bb = bbFactory.CreateBranchBarrier(context.Request.Query);using var db = Db.GeConn();await bb.Call(db, async (tx) =>{Console.WriteLine($"用户【{req.UserId}】转出【{req.Amount}】Cancel操作，bb={bb}");await Task.CompletedTask;});return Results.Ok(TransResponse.BuildSucceedResponse());
});

InApi

app.MapPost("/api/TransInTry", async (IBranchBarrierFactory bbFactory, HttpContext context, TransRequest req) =>
{var bb = bbFactory.CreateBranchBarrier(context.Request.Query);using var db = Db.GeConn();await bb.Call(db, async (tx) =>{Console.WriteLine($"用户【{req.UserId}】转入【{req.Amount}】Try操作，bb={bb}");await Task.CompletedTask;});return Results.Ok(TransResponse.BuildSucceedResponse());
});app.MapPost("/api/TransInConfirm", async (IBranchBarrierFactory bbFactory, HttpContext context, TransRequest req) =>
{var bb = bbFactory.CreateBranchBarrier(context.Request.Query);using var db = Db.GeConn();await bb.Call(db, async (tx) =>{Console.WriteLine($"用户【{req.UserId}】转入【{req.Amount}】Confirm操作，bb={bb}");await Task.CompletedTask;});return Results.Ok(TransResponse.BuildSucceedResponse());
});app.MapPost("/api/TransInCancel", async (IBranchBarrierFactory bbFactory, HttpContext context, TransRequest req) =>
{var bb = bbFactory.CreateBranchBarrier(context.Request.Query);using var db = Db.GeConn();await bb.Call(db, async (tx) =>{Console.WriteLine($"用户【{req.UserId}】转入【{req.Amount}】Cancel操作，bb={bb}");await Task.CompletedTask;});return Results.Ok(TransResponse.BuildSucceedResponse());
});

到此各个子事务的处理已经OK了，在上面的代码中，下面这几行是子事务屏障相关代码，只要按照这个方式来调用您的业务逻辑，子事务屏障保证重复请求、悬挂、空补偿情况出现时，您的业务逻辑不会被调用，保证了正常业务的正确进行

var bb = bbFactory.CreateBranchBarrier(context.Request.Query);
await bb.Call(db, async (tx) =>
{// 业务操作...
});

然后准备开启 TCC 事务，进行分支调用

var cts = new CancellationTokenSource();var gid = await dtmClient.GenGid(cts.Token);var res = await tccGlobalTransaction.Excecute(gid, async (tcc) =>
{// 用户1 转出30元var res1 = await tcc.CallBranch(userOutReq, outApi + "/TransOutTry", outApi + "/TransOutConfirm", outApi + "/TransOutCancel", cts.Token);// 用户2 转入30元var res2 = await tcc.CallBranch(userInReq, inApi + "/TransInTry", inApi + "/TransInConfirm", inApi + "/TransInCancel", cts.Token);Console.WriteLine($"case1, branch-out-res= {res1} branch-in-res= {res2}");
}, cts.Token);Console.WriteLine($"case1, {gid} tcc 提交结果 = {res}");

到这里，一个完整的 TCC 分布式事务就编写完成了。

需要注意的地方：

  1. 依赖 TccGlobalTransaction ，这个是单例的

  2. tcc 的 CallBranch 方法就是事务分支的调用

搭建好 dtm 的环境后，运行上面的例子，会看到下面的输出。

75b537a818eea6a0cedd0c05205012e2.png

成功的示例都是相对比较简单的。

下面来看一个 TCC 回滚的例子。

TCC 的回滚

假如银行将金额准备转入用户2时，发现用户2的账户异常，返回失败，会怎么样？我们修改代码，模拟这种情况：

在 InApi 加多一个转入Try失败的处理接口

app.MapPost("/api/TransInTryError", (IBranchBarrierFactory bbFactory, HttpContext context, TransRequest req) =>
{var bb = bbFactory.CreateBranchBarrier(context.Request.Query);Console.WriteLine($"用户【{req.UserId}】转入【{req.Amount}】Try--失败，bb={bb}");return Results.Ok(TransResponse.BuildFailureResponse());
});

再来看一下事务失败交互的时序图

dd438f254d3fd553b619b667e2af4dde.png

这个跟成功的 TCC 差别就在于，当某个子事务返回失败后，后续就回滚全局事务，调用各个子事务的 Cancel 操作，保证全局事务全部回滚。

再调整一下调用方，把转入 Try 操作替换成上面这个返回错误的接口。

var cts = new CancellationTokenSource();var gid = await dtmClient.GenGid(cts.Token);var res = await tccGlobalTransaction.Excecute(gid, async (tcc) =>
{var res1 = await tcc.CallBranch(userOutReq, outApi + "/TransOutTry", outApi + "/TransOutConfirm", outApi + "/TransOutCancel", cts.Token);var res2 = await tcc.CallBranch(userInReq, inApi + "/TransInTryError", inApi + "/TransInConfirm", inApi + "/TransInCancel", cts.Token);Console.WriteLine($"case2, branch-out-res= {res1} branch-in-res= {res2}");
}, cts.Token);Console.WriteLine($"case2, {gid} tcc 提交结果 = {res}");

需要注意的是 CallBranch 方法在对应的微服务返回失败后会抛出异常，进而触发全局事务的回滚操作，这个时候 dtm 才会触发 Cancel 的操作。

运行结果如下：

5948de1c006414987a7ed311ddacf92e.png

重点看三个地方，

  • 转入的 Cancel 操作并没有执行，因为这里模拟的是转入失败的情况，子事务屏障判定为空补偿了

  • 没有输出分支调用的结果，是因为执行第二个分支的时候没有返回成功的结果

  • 输出的提交结果为空，表明这个事务是失败的，成功的话会返回这个事务的 gid

写在最后

在这篇文章里，通过 2 个简单的例子，完整给出了编写一个 TCC 事务的过程，涵盖了正常成功完成，异常回滚的情况。

希望对研究分布式事务的您有所帮助。

本文示例代码：https://github.com/catcherwong-archive/2022/tree/main/DtmTccDemo

参考资料

  • https://segmentfault.com/a/1190000040331793

  • https://segmentfault.com/a/1190000040396649

  • https://github.com/dtm-labs/dtmcli-csharp

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/291674.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

2020-11-09

2020-11-09

阅读更多...
Xcode6.1 模拟器路径

Xcode6.1 模拟器路径

Xcode 5的iOS模拟器的应用的目录是在~/Library/Application Support/iPhone Simulator/<iOS_Version>/Applications/{Application_ID} Xcode 6的目录改为~/Library/Developer/CoreSimulator/Devices/{Device_ID}/data/Containers/Bundle/Application/{Application_ID}/这…
阅读更多...
安卓效率微商_微商人脉通app下载-微商人脉通 安卓版v2.5.5-PC6安卓网

安卓效率微商_微商人脉通app下载-微商人脉通 安卓版v2.5.5-PC6安卓网

微商人脉通app是一款很好用的微商营销软件&#xff0c;微商人脉通app可以帮你高效获取客源&#xff0c;微商人脉通app还具有丰富微商各类工具&#xff0c;微商人脉通app是做微商生意第一选择的工具&#xff01;软件介绍微商人脉通app致力于打造微商营销推广行业优秀产品&#x…
阅读更多...
linux之如何快速查看文件的大小

linux之如何快速查看文件的大小

1、linux之如何快速查看文件的大小 命令如下&#xff0c;每次都容易忘记&#xff0c;希望下次记住 du -h
阅读更多...
新年伊始 .Net7 preview1 发布！

新年伊始 .Net7 preview1 发布！

虎年伊始&#xff0c;.NET 7.0就要来了&#xff0c;还学的动吗&#xff1f;从github能看到&#xff0c;截止到2月8号&#xff0c;.NET 7.0 Preview1已经全部开发完成&#xff0c;连Preview2也完成了85%&#xff0c;这进度杠杠的&#xff01;微软这几年大力推进.NET稳定更新&…
阅读更多...
DDD：如何更好的使用值对象

DDD：如何更好的使用值对象

背景 大师们让我们多使用“值语义”的对象&#xff08;并非一定是是值对象&#xff09;&#xff0c;我们工作中也没有少使用&#xff08;int、bool、date等等&#xff09;&#xff0c;只是大多数人都没有多的自定义“值语义”的类型&#xff08;我也其中之一&#xff09;&#…
阅读更多...
数据挖掘课程实验（8个实验报告）

数据挖掘课程实验（8个实验报告）

是从实验一到实验八的 链接&#xff1a;https://download.csdn.net/download/qq_44872173/15558967
阅读更多...
hutol json null值没了_JSON数据处理框架Jackson精解第一篇-序列化与反序列化核心用法...

hutol json null值没了_JSON数据处理框架Jackson精解第一篇-序列化与反序列化核心用法...

Jackson是Spring Boot默认的JSON数据处理框架&#xff0c;但是其并不依赖于任何的Spring 库。有的小伙伴以为Jackson只能在Spring框架内使用&#xff0c;其实不是的&#xff0c;没有这种限制。它提供了很多的JSON数据处理方法、注解&#xff0c;也包括流式API、树模型、数据绑定…
阅读更多...
linux之解决在ubuntu上面打开window文件乱码问题总结

linux之解决在ubuntu上面打开window文件乱码问题总结

1、问题&#xff1a;比如我们在linux系统里面&#xff0c;通过远程桌面打开Windows的txt文件会出现乱码 2、原因&#xff1a; Linux显示在Windows编辑过的中文就会显示乱码是由于两个操作系统使用的编码不同所致。Linux下使用的编码是utf8&#xff0c;而Windows使用的是gb1803…
阅读更多...
什么是异构数据库

什么是异构数据库

异构数据库&#xff08;HDB Heterogeneous DataBase&#xff09;是多个数据库系统的集合&#xff0c;可以实现不同数据库之间数据的共享和透明访问。异构数据库中的每个数据库都拥有自己的DMBS&#xff0c;在实现数据共享的同时&#xff0c;仍保有自己的应用特性、完整性控制和…
阅读更多...
枚举法的简单应用

枚举法的简单应用

箱子里有红&#xff0c;黄&#xff0c;蓝&#xff0c;白&#xff0c;黑五种颜色玻璃球若干&#xff0c;每次任意拿出三个球&#xff0c;问拿出三种不同颜色玻璃球的可能取法&#xff0c;请输出每种排列的情况。 注解&#xff1a;利用枚举法定义五种情况&#xff0c;“enum colo…
阅读更多...
Linux网络操作系统实验报告（1~12）

Linux网络操作系统实验报告（1~12）

共12个 链接在此&#xff1a;https://download.csdn.net/download/qq_44872173/15559247 如下是目录&#xff1a; 实验一部分标题如下&#xff1a;
阅读更多...
解读WPF中的Binding

解读WPF中的Binding

1.Overview基于MVVM实现一段绑定大伙都不陌生&#xff0c;Binding是wpf整个体系中最核心的对象之一这里就来解读一下我花了纯两周时间有哪些秘密。这里我先提出几个问题应该是大家感兴趣的&#xff0c;如下&#xff1a;&#xff08;1&#xff09;INotifyPropertyChanged是如何被…
阅读更多...
maven 导入数据库

maven 导入数据库

2019独角兽企业重金招聘Python工程师标准>>> 一.mysql 配置 基本代码 1. pom.xml 文件配置:jeesite.property jdbc.typemysql jdbc.drivercom.mysql.jdbc.Driver jdbc.urljdbc:mysql://localhost:3306/yaoshi?useUnicodetrue&characterEncodingutf-8 jdbc.user…
阅读更多...
linux之多任务的同步与互斥

linux之多任务的同步与互斥

1、操作系统&#xff1a; 基本都是多任务操作系统&#xff0c;即同时有大量可调度实体在运行。在多任务操作系统中。 2、同时运行的多个任务可能产生的问题 1) 都需要访问/使用同一种资源 2) 多个任务之间有依赖关系&#xff0c;某个任务的运行依赖于另一个任务 这…
阅读更多...
下载matlab安装包太慢_MATLAB 2020a商业数学中文版软件下载安装教程

下载matlab安装包太慢_MATLAB 2020a商业数学中文版软件下载安装教程

【软件语言】&#xff1a;简体中文 【支持系统】&#xff1a;Win7/Win8/Win10【软件类别】&#xff1a;安装版【更新时间】&#xff1a;2020年5月15日【下载地址】&#xff1a;www.rjazbs.me/t-2945.html客服微信&#xff1a;rjazbsMATLAB是一款商业数学软件&#xff0c;用于算…
阅读更多...
JavaWeb应用开发实验报告下载（共12个）

JavaWeb应用开发实验报告下载（共12个）

目录如下&#xff1a;
阅读更多...
phpstorm+Xdebug断点调试PHP

phpstorm+Xdebug断点调试PHP

运行环境&#xff1a; PHPSTORM版本 : 8.0.1 PHP版本 : 5.6.2 xdebug版本&#xff1a;php_xdebug-2.2.5-5.6-vc11-x86_64.dll ps : php版本和xdebug版本一定要相对应 1. PHP安装xdebug扩展 php.ini的配置&#xff0c;下面的配置仅供参考&#xff0c;路径要换成自己的&#xff0…
阅读更多...
EF Core 6 新功能汇总（三）

EF Core 6 新功能汇总（三）

在这篇文章中&#xff0c;我将重点介绍 EF Core 6 中 LINQ 查询功能的增强。这是 EF Core 6 新功能汇总的第三篇文章&#xff1a;EF Core 6 新功能汇总&#xff08;一&#xff09;EF Core 6 新功能汇总&#xff08;二&#xff09;EF Core 6 新功能汇总&#xff08;三&#xff0…
阅读更多...
linux之mutex(互斥锁)

linux之mutex(互斥锁)

在Posix Thread中定义有一套专门用于线程同步的mutex函数 1． 创建和销毁 有两种方法创建互斥锁，静态方式和动态方式。POSIX定义了一个宏PTHREAD_MUTEX_INITIALIZER来静态初始化互斥锁，方法如下： pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIZER; 在LinuxThreads实现中，…
阅读更多...
最新文章

Copyright @ 2022~2023