Seata客户端使用配置中心

时间：2024-11-14 16:36:43

Seata-0.8.1~1.0.0客户端启动过程分析

1. 加载registry配置

transactionServiceGroup默认为${}-fescar-service-group
可以通过指定

核心类： static {} 初始化CURRENT_FILE_INSTANCE

  1. 加载registry(环境隔离)

    • 先从读取的value{seataConfigName}

    • 如果seataConfigName为null再从获取SEATA_CONFIG_NAME的value{seataConfigName}

    • 如果{seataConfigName}为null，则{seataConfigName}为默认值registry

    • 先从读取seataEnv的value{seataEnv}

    • 如果{seataEnv}为null，再从获取SEATA_ENV的value{seataEnv}

    • 如果{seataEnv}为null读取{seataConfigName}.conf，否则读取{seataConfigName}-{seataEnv}.conf

    • 得到{registryConfiguration}

    • 加载registry后，读取的value{configType}

    • configType为file时，加载file-{seataEnv}.conf(FileConfiguration)，否则创建对应类型的Configuration(NacosConfiguration, ApolloConfiguration, ConsulConfiguration, EtcdConfiguration, ZookeeperConfiguration)

    • 得到{configConfiguration}

PS：使用nacos做配置中心时，如果namespace是public应该这么配置namespace = “”

2. TM启动

  1. 获取TmRpcClient实例

    1. 初始化NettyClientConfig

      1. 从{configConfiguration}中获取与NettyClientConfig类相关的配置有

        -selector-thread-size
-selector-thread-prefix
-worker-thread-prefix

-thread-size





# rpc通讯配置

    2. 启动客户端与相关定时器

      1. 获取是否降级配置

      2. 初始化netty的bootstrap

      3. 启动定时重连定时器(连接seata-server)

      4. 启动合并消息定时器，并运行合并消息任务()

连接seata-server

核心类：#getInstance() 获取注册中心实例

  1. 先从{registryConfiguration}对象中的value
  • file模式
  1. 从{configConfiguration} 对象中，读取service.vgroup_mapping.{transactionServiceGroup}的value{clusterName}
  2. 通过service.{clusterName}.grouplist查找ip:port列表用;分隔
  3. 通过ip:port连接seata-server
  • nacos模式
  1. 从{configConfiguration}对象中，读取service.vgroup_mapping.{transactionServiceGroup}的value{clusterName}
  2. 如果本地缓存{CLUSTER_ADDRESS_MAP}中存在{clusterName}对应的ip:port列表，直接进行3.3步
  3. 不存在
    1. 创建nacos的NamingInstance
      1. 读取nacos serverAddr, 先从的value{nacosServerAddr} 为null则从{configConfiguration}对象中读取的value{nacosServerAddr}
      2. 读取namespce, 先从的value{namespace} 为null则从{configConfiguration}对象中读取的value{namespace}
    2. 获取所有的server实例
      1. 根据serverAddr(这里就是一个字符串)和{clusterName}请求nacos server获取所有的seata-server ip:port列表，并缓存到本地
      2. 开启nacos的subscribe监听，刷新{CLUSTER_ADDRESS_MAP}
    3. 通过ip:port连接seata-server
  • Eureka模式
    1. 根据, 创建eurekaClient实例
    2. 从{configConfiguration}对象中，读取service.vgroup_mapping.{transactionServiceGroup}的value{clusterName}
    3. 获取eureka上所有注册的application
    4. 返回名称为{clusterName}的ip:port列表
    5. 通过ip:port连接seata-server
  • Consul模式
    1. 根据创建ConsulClient实例
    2. 从{configConfiguration}对象中，读取service.vgroup_mapping.{transactionServiceGroup}的value{clusterName}
    3. ConsulClient实例根据获取说有的ip:port列表
    4. 返回名称为{clusterName}的ip:port列表
    5. 通过ip:port连接seata-server
  • Etcd模式
    1. 根据registry.创建Etcd实例
    2. 从{configConfiguration}对象中，读取service.vgroup_mapping.{transactionServiceGroup}的value{clusterName}
    3. Etcd实例根据registry-seata-{registry.}获取说有的ip:port列表
    4. 返回名称为{clusterName}的ip:port列表
    5. 通过ip:port连接seata-server
  • Redis模式(目前只有单机模式)

    1. 根据, 创建JedisPool实例

      (可选配置, , , , , , , , , , , , )

    2. 从{configConfiguration}对象中，读取service.vgroup_mapping.{transactionServiceGroup}的value{clusterName}

    3. 从JedisPool实例中回去Jedis对象，从jedis对象中hgetAll({})拿到所有的ip:port列表

    4. 返回名称为{clusterName}的ip:port列表

    5. 通过ip:port连接seata-server

  • Zookeeper模式
    1. 从{configConfiguration}对象中，读取service.vgroup_mapping.{transactionServiceGroup}的value{clusterName}
    2. 根据, , 创建zkClient实例
    3. 从/registry/zk/{clusterName}获取所有的ip:port列表
    4. 通过ip:port连接seata-server
  • sofa模式
    1. 初始化sofa配置, 优先从中获取, , , , , , 获取不到从{configConfiguration}中获取相应的配置
    2. 从{configConfiguration}对象中，读取service.vgroup_mapping.{transactionServiceGroup}的value{clusterName}
    3. 获取sofaRegistry实例并注册监听器，监听器根据{clusterName}获取ip:port列表
    4. 通过ip:port连接seata-server

PS：当获取不到ip:port列表时，会报no available server to connect，此时需要检查一下配置中心上是否配置了service.vgroup_mapping.{transactionServiceGroup}

优先从中读取，读取不到再从对应的配置类中读取。

FileConfiguration: 读取file-{seataEnv}.conf中service.vgroup_mapping.{transactionServiceGroup}

NacosConfiguration: 读取对应namespace中service.vgroup_mapping.{transactionServiceGroup}的值

ApolloConfiguration: 读取service.vgroup_mapping.{transactionServiceGroup}的值

ConsulConfiguration: 读取service.vgroup_mapping.{transactionServiceGroup}的值

EtcdConfiguration: 读取service.vgroup_mapping.{transactionServiceGroup}的值

ZookeeperConfiguration: 会从zookeeper的/config/service.vgroup_mapping.{transactionServiceGroup}读取

3. RM启动

  1. 获取RmRpcClient实例
  2. 设置资源管理器(ResourceManager)
  3. 设置客户端消息监听器
  4. 连接seata-server(与TM相同)

PS:如有错误，请留言纠正

相关文章