kratos分布式事务最佳实践

　　背景
　　随着业务的快速发展、业务复杂度越来越高，微服务作为最佳解决方案之一，它解耦服务，降低复杂度，增加可维护性的同时，也带来一部分新问题。
　　当我们需要跨服务保证数据一致性时，原先的数据库事务力不从心，无法将跨库、跨服务的多个操作放在一个事务中。这样的应用场景非常多，我们可以列举出很多：跨行转账场景，数据不在一个数据库，但需要保证余额扣减和余额增加要么同时成功，要么同时失败发布文章后，更新文章总数等统计信息。其中发布文章和更新统计信息通常在不同的微服务中微服务化之后的订单系统出行旅游需要在第三方系统同时定几张票
　　面对这些本地事务无法解决的场景，我们需要分布式事务的解决方案，保证跨服务、跨数据库更新数据的一致性。
　　dtm作为一款非常流行的分布式事务框架，已经支持接入多种微服务框架，下面我们就来着重介绍一下https：github。comgokratoskratos如何接入dtm，解决分布式事务的问题运行一个例子
　　我们来看一个可运行的例子，然后再看如何自己开发完成一个完整的分布式事务
　　下面以etcd作为注册服务中心，可以按照如下步骤运行一个kratos的示例：配置dtm
　　MicroService：
　　Driver：dtmdriverkratosnameofthedrivertohandleregisterdiscover
　　Target：discovery：127。0。0。1：2379dtmserviceregisterdtmservertothisurl
　　EndPoint：grpc：localhost：36790启动etcd
　　前提：已安装etcd
　　etcd启动dtm
　　请先配置好dtm的数据库
　　gorunappmain。gocconf。ymlconf。yml为你对应的dtm配置文件运行一个kratos的服务
　　gitclonehttps：github。comdtmlabsdtmdriverclientscddtmdriverclients
　　cdkratostrans
　　makebuild。bintransconfconfigsconfig。yaml发起一个kratos使用dtm的事务
　　在dtmdriverclients的目录下
　　cdkratosappgorunmain。go
　　当您在trans的日志中看到INFOmsgconfigloaded：config。yamlformat：yamlINFOmsg〔gRPC〕serverlisteningon：〔：：〕：90002022033009：35：36transferout30centsfrom12022033009：35：36transferin30centsto2
　　那就是事务正常完成了开发接入
　　参考https：github。comdtmlabsdtmdriverclients的代码下面这些导入kratos的dtm驱动import（github。comdtmlabsdriverkratos）dtm已经经过前面的配置，注册到下面这个地址，因此在dtmgrpc中使用该地址vardtmServerdiscovery：localhost：2379dtmservice业务地址，下面的busi换成实际在server初始化设置的名字varbusiServerdiscovery：localhost：2379busi发起一个msg事务，保证TransOut和TransIn都会完成gid：dtmgrpc。MustGenGid（dtmServer）m：dtmgrpc。NewMsgGrpc（dtmServer，gid）。Add（busiServerapi。trans。v1。TransTransOut，busi。BusiReq｛Amount：30，UserId：1｝）。Add（busiServerapi。trans。v1。TransTransIn，busi。BusiReq｛Amount：30，UserId：2｝）m。WaitResulttrueerr：m。Submit（）logger。FatalIfError（err）深入理解动态调用
　　在kratos使用dtm的分布式事务时，许多的调用是从dtm服务器发起的，例如TCC的ConfirmCancel，SAGAMSG的所有调用。
　　dtm无需知道组成分布式事务的相关业务api的强类型，它是动态的调用这些api。
　　grpc的调用，可以类比于HTTP的POST，其中：api。trans。v1。TransTransIn相当于URL中的Path。请注意这个Path一定是要从TransIn的Invoke函数实现里面找busi。BusiReq｛Amount：30，UserId：1｝相当于Post中Bodyv1。Response相当于HTTP请求的响应
　　通过下面这部分代码，dtm就拿到了完整信息，就能够发起完整的调用了
　　Add（busiServerapi。trans。v1。TransTransIn，busi。BusiReq｛Amount：30，UserId：1｝）其他方式接入
　　kratos的微服务还有非etcd的其他方式，下面列出它们的接入方式直连
　　对于直连这种方式，您只需要在上面dtm的etcd配置基础上，将Target设置为空字符串即可。
　　直连的情况，不需要将dtm注册到注册中心联系我们
　　项目地址：https：github。comdtmlabsdtm欢迎访问，并star支持我们
　　kratos地址：https：github。comgokratoskratos