Kratos支持

运行一个已有的示例

我们以 etcd 作为注册服务中心为例，按照如下步骤运行一个 kratos 的示例：

  • 启动 etcd
  1. # 请先确保已经安装 etcd
  2. etcd
  • 配置 dtm
  1. MicroService:
  2.  Driver: 'dtm-driver-kratos' # name of the driver to handle register/discover
  3.  Target: 'etcd://127.0.0.1:2379/dtmservice' # register dtm server to this url
  4.  EndPoint: 'grpc://localhost:36790'
  • 启动 dtm
  1. # 请先配置好dtm的数据库
  2. go run app/main.go -c conf.yml # conf.yml 为你对应的 dtm 配置文件
  • 运行一个 kratos 的服务
  1. git clone https://github.com/dtm-labs/dtmdriver-clients && cd dtmdriver-clients
  2. cd kratos/trans
  3. make build && ./bin/trans -conf configs/config.yaml
  • 发起一个 kratos 使用 dtm 的事务
  1. # 在 dtmdriver-clients 的目录下
  3. cd kratos/app && go run main.go

当您在 trans 的日志中看到

  1. INFO msg=config loaded: config.yaml format: yaml
  2. INFO msg=[gRPC] server listening on: [::]:9000
  3. 2022/03/30 09:35:36 transfer out 30 cents from 1
  4. 2022/03/30 09:35:36 transfer in 30 cents to 2

那就是事务正常完成了

开发接入

参考 dtm-labs/dtmdriver-clients 的代码

  1. // 下面这些导入 kratos 的 dtm 驱动
  2. import (
  3.     _ "github.com/dtm-labs/driver-kratos"
  4. )
  6. // dtm 已经经过前面的配置，注册到下面这个地址，因此在 dtmgrpc 中使用该地址
  7. var dtmServer = "etcd://localhost:2379/dtmservice"
  9. // 业务地址，下面的 busi 换成实际在 server 初始化设置的名字
  10. var busiServer = "discovery://localhost:2379/busi"
  12. // 发起一个msg事务，保证TransOut和TransIn都会完成
  13. gid := dtmgrpc.MustGenGid(dtmServer)
  14. m := dtmgrpc.NewMsgGrpc(dtmServer, gid).
  15.   Add(busiServer+"/api.trans.v1.Trans/TransOut", &busi.BusiReq{Amount: 30, UserId: 1}).
  16.   Add(busiServer+"/api.trans.v1.Trans/TransIn", &busi.BusiReq{Amount: 30, UserId: 2})
  17. m.WaitResult = true
  18. err := m.Submit()
  19. logger.FatalIfError(err)

深入理解动态调用

在 kratos 使用 dtm 的分布式事务时，许多的调用是从 dtm 服务器发起的，例如 TCC 的Confirm/Cancel，SAGA/MSG 的所有调用。

dtm 无需知道组成分布式事务的相关业务 api 的强类型，它是动态的调用这些api。

grpc 的调用，可以类比于 HTTP 的 POST，其中：

  • “/api.trans.v1.Trans/TransIn” 相当于 URL 中的 Path。请注意这个Path一定是要从TransIn的Invoke函数实现里面找
  • &busi.BusiReq{Amount: 30, UserId: 1} 相当于 Post 中 Body
  • v1.Response 相当于HTTP请求的响应

通过下面这部分代码，dtm就拿到了完整信息，就能够发起完整的调用了

Add(busiServer+"/api.trans.v1.Trans/TransIn", &busi.BusiReq{Amount: 30, UserId: 1})

其他方式接入

kratos 的微服务还有非 etcd 的其他方式，下面列出它们的接入方式

直连

对于直连这种方式，您只需要在上面 dtm 的 etcd 配置基础上，将 Target 设置为空字符串即可。

直连的情况，不需要将 dtm 注册到注册中心

Consul

对于 Consul 这种方式，需要将对于是 etcd 相关换成 consul 即可，如下

  1. #  dtm: conf.yml
  2. MicroService:
  3.  Driver: 'dtm-driver-kratos' # name of the driver to handle register/discover
  4.  Target: 'consul://127.0.0.1:8500/dtmservice' # register dtm server to this url
  5.  EndPoint: 'grpc://localhost:36790'
  1. // client:
  2. // dtm 已经经过前面的配置，注册到下面这个地址，因此在 dtmgrpc 中使用该地址
  3. var dtmServer = "consul://localhost:8500/dtmservice"
  5. // 业务地址，下面的 busi 换成实际在 server 初始化设置的名字，对于 kratos 应用地址遵循框架即可，不用变动
  6. var busiServer = "discovery://localhost:8500/busi"
  8. // 实际的调用逻辑
  9. ...

小结

欢迎使用 dtm，并 star 支持我们，一起共建 golang 的微服务生态