SEATA 配置中心与注册中心通讯机制

整个分布式的事务的交互，需要三个部分，注册中心（nacos），seata server 和 seata client

第一部分 seata server的注册与配置项数据获取

要让seata server 使用配置中心，需要修改registry.conf 文件

registry {
  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa 选择一种注册中心才方式
  type = "nacos"

  nacos {
    application = "seata-server"
    serverAddr = "localhost"
    namespace = "public"
    cluster = "default"
    username = "nacos"
    password = "nacos"
  }
  eureka {
    serviceUrl = "http://localhost:8761/eureka"
    application = "default"
    weight = "1"
  }
  redis {
    serverAddr = "localhost:6379"
    db = "0"
  }
  zk {
    cluster = "default"
    serverAddr = "127.0.0.1:2181"
    session.timeout = 6000
    connect.timeout = 2000
  }
  consul {
    cluster = "default"
    serverAddr = "127.0.0.1:8500"
  }
  etcd3 {
    cluster = "default"
    serverAddr = "http://localhost:2379"
  }
  sofa {
    serverAddr = "127.0.0.1:9603"
    application = "default"
    region = "DEFAULT_ZONE"
    datacenter = "DefaultDataCenter"
    cluster = "default"
    group = "SEATA_GROUP"
    addressWaitTime = "3000"
  }
  file {
    name = "file.conf"
  }
}

config {
  # file、nacos 、apollo、zk、consul、etcd3 选择一种获取配置数据的方式，这里选择从nacos配置中心获取server的配置数据。
  type = "nacos"

  nacos {
    serverAddr = "localhost"
    namespace = "public"
    group = "SEATA_GROUP"
    username = "nacos"
    password = "nacos"
  }
  consul {
    serverAddr = "127.0.0.1:8500"
  }
  apollo {
    app.id = "seata-server"
    apollo.meta = "http://192.168.1.204:8801"
    namespace = "application"
  }
  zk {
    serverAddr = "127.0.0.1:2181"
    session.timeout = 6000
    connect.timeout = 2000
  }
  etcd3 {
    serverAddr = "http://localhost:2379"
  }
  file {
    name = "file.conf"
  }
}

修改好了registry.conf 之后，我们要把server 端的配置项注入到nacos配置中心，这样我们才能在seata server 启动的时候，从nacos 注册中心拿到 server 需要的数据，这个数据的刷入方法如下。

将https://github.com/seata/seata/blob/1.1.0/script/config-center/config.txt
文件中的数据保存到server 端 conf 文件夹下，保存的文件名为config.txt（必须是这个名字，如果不想改后面的python 脚本的话,具体内容的意义，看file.example 这个文件，在seata-server的conf 目录下，建议把client开头的都去掉，由每个client 独立配置）。下载 https://github.com/seata/seata/blob/1.1.0/script/config-center/nacos/nacos-config.py
文件，保存到conf 目录下，然后修改一下nacos-config.py

修改
for line in open('../config.txt'): 
为
for line in open('./config.txt'):

运行

最后一个参数是nacos 配置中心的地址+端口
python nacos-config.py localhost:8848

数据导入完成

image.png

seata client配置注册中心与配置中心，通过注册中心与TC连接

客户端seata的配置参数如下

# 这里要与 server端 config.txt 中 service.vgroupMapping.<group-name>=default 对应，例如这里对应的值就为service.vgroupMapping.storage-service-group=default
spring.cloud.alibaba.seata.tx-service-group=storage-service-group
#不禁用全局事务
seata.service.disable-global-transaction=false
#启用seata自动配置
seata.enabled=true
# 不自动代理DataSource
seata.enable-auto-data-source-proxy=false
# 告诉seata使用nacos注册中心
seata.registry.type=nacos
seata.config.nacos.namespace=public
#告诉seata使用nacos配置中心
seata.config.type=nacos

client 是如何通过seata.registry.type=nacos 与 seata.config.type=nacos 配置实现与注册中心，配置中心通讯的呢？

一切的核心都在 io.seata.discovery.registry.RegistryFactory 与 io.seata.config.ConfigurationFactory

RegistryFactory.getInstance() 静态方法会使用ConfigurationFactory 取读取seata.registry.type的值，然后更具不同的值生成不同的io.seata.discovery.registry.RegistryService 如果type 为nacos，那么具体实现类就是NacosRegistryServiceImpl ,NacosRegistryServiceImpl会读取registry.conf的配置初始化nacos 注册中心客户端并连接到nacos，注册中心的连接就完成了。
ConfigurationFactory.getInstance() 会读取 seata.config.type的值，生成对应的io.seata.config.Configuration，具体实现类是NacosConfiguration。NacosConfiguration 会读取registry.conf的配置初始化nacos 配置中心客户端并连接到配置中心的连接就完成了。

如果遇到no available service 'null' found, please make sure registry config correct 基本上都是下面这两项没配对的原因。注意client与server的版本要一致。

# 告诉seata使用nacos注册中心
seata.registry.type=nacos
seata.config.nacos.namespace=public
#告诉seata使用nacos配置中心
seata.config.type=nacos