事务分组专题

事务分组是什么?

事务分组是seata的资源逻辑,类似于服务实例。在file.conf中的my_test_tx_group就是一个事务分组。

通过事务分组如何找到后端集群?

  1. 首先程序中配置了事务分组(GlobalTransactionScanner 构造方法的txServiceGroup参数)
  2. 程序会通过用户配置的配置中心去寻找service.vgroupMapping .[事务分组配置项],取得配置项的值就是TC集群的名称
  3. 拿到集群名称程序通过一定的前后缀+集群名称去构造服务名,各配置中心的服务名实现不同
  4. 拿到服务名去相应的注册中心去拉取相应服务名的服务列表,获得后端真实的TC服务列表

为什么这么设计,不直接取服务名?

这里多了一层获取事务分组到映射集群的配置。这样设计后,事务分组可以作为资源的逻辑隔离单位,出现某集群故障时可以快速failover,只切换对应分组,可以把故障缩减到服务级别,但前提也是你有足够server集群。

事务分组使用案例

seata注册、配置中心分为两类,内置file、第三方注册(配置)中心如nacos等等,注册中心和配置中心之间没有约束,可各自使用不同类型。

file注册中心和配置中心

Server端

  1. registry {
  2. # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  3. type = "file" ---------------> 使用file作为注册中心
  4. }
  5. config {
  6. # file、nacos 、apollo、zk、consul、etcd3
  7. type = "file" ---------------> 使用file作为配置中心
  8. file {
  9. name = "file.conf"
  10. }
  11. }
  • file、db模式启动server,见文章上方节点:启动Server

Client端

  1. registry {
  2. # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  3. type = "file" ---------------> 使用file作为注册中心
  4. }
  5. config {
  6. # file、nacos 、apollo、zk、consul、etcd3
  7. type = "file" ---------------> 使用file作为配置中心
  8. file {
  9. name = "file.conf" ---------------> 配置参数存储文件
  10. }
  11. }
  12. spring.cloud.alibaba.seata.tx-service-group=my_test_tx_group ---------------> 事务分组配置
  13. file.conf:
  14. service {
  15. vgroupMapping.my_test_tx_group = "default"
  16. default.grouplist = "127.0.0.1:8091"
  17. }
  • 读取配置

通过FileConfiguration本地加载file.conf的配置参数

  • 获取事务分组

spring配置,springboot可配置在yml、properties中,服务启动时加载配置,对应的值”my_test_tx_group”即为一个事务分组名,若不配置,默认获取属性spring.application.name的值+”-fescar-service-group”

  • 查找TC集群名

拿到事务分组名”my_test_tx_group”拼接成”service.vgroupMapping.my_test_tx_group”查找TC集群名clusterName为”default”

  • 查询TC服务

拼接”service.”+clusterName+”.grouplist”找到真实TC服务地址127.0.0.1:8091

nacos注册中心和配置中心

Server端

  1. registry {
  2. # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  3. type = "nacos" ---------------> 使用nacos作为注册中心
  4. nacos {
  5. serverAddr = "localhost" ---------------> nacos注册中心所在ip
  6. namespace = "" ---------------> nacos命名空间id""nacos保留public空间控件,用户勿配置namespace = "public"
  7. cluster = "default" ---------------> seata-servernacos的集群名
  8. }
  9. }
  10. config {
  11. # file、nacos 、apollo、zk、consul、etcd3
  12. type = "nacos" ---------------> 使用nacos作为配置中心
  13. nacos {
  14. serverAddr = "localhost"
  15. namespace = ""
  16. cluster = "default"
  17. }
  18. }
  • 脚本

script—>config-center下的3个文件nacos-config.pynacos-config.sh、config.txt
txt为参数明细(包含Server和Client),sh为linux脚本,windows可下载git来操作,py为python脚本。

  • 导入配置

用命令执行脚本导入seata配置参数至nacos,在nacos控制台查看配置确认是否成功

  • 注册TC

启动seata-server注册至nacos,查看nacos控制台服务列表确认是否成功

Client端

  1. spring.cloud.alibaba.seata.tx-service-group=my_test_tx_group ---------------> 事务分组配置
  2. registry {
  3. # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  4. type = "nacos" ---------------> nacos获取TC服务
  5. nacos {
  6. serverAddr = "localhost"
  7. namespace = ""
  8. }
  9. }
  10. config {
  11. # file、nacos 、apollo、zk、consul、etcd3
  12. type = "nacos" ---------------> 使用nacos作为配置中心
  13. nacos {
  14. serverAddr = "localhost"
  15. namespace = ""
  16. }
  17. }
  • 读取配置

通过NacosConfiguration远程读取seata配置参数

  • 获取事务分组

springboot可配置在yml、properties中,服务启动时加载配置,对应的值”my_test_tx_group”即为一个事务分组名,若不配置,默认获取属性spring.application.name的值+”-fescar-service-group”

  • 查找TC集群名

拿到事务分组名”my_test_tx_group”拼接成”service.vgroupMapping.my_test_tx_group”从配置中心查找到TC集群名clusterName为”default”

  • 查找TC服务

根据serverAddr和namespace以及clusterName在注册中心找到真实TC服务列表

注:serverAddr和namespace与Server端一致,clusterName与Server端cluster一致