Apache Seata配置管理原理解析

本文来自 Apache Seata官方文档，欢迎访问官网，查看更多深度文章。
本文来自 Apache Seata官方文档，欢迎访问官网，查看更多深度文章。

Apache Seata配置管理原理解析

说到Seata中的配置管理，大家可能会想到Seata中适配的各种配置中心，其实今天要说的不是这个，虽然也会简单分析Seata和各配置中心的适配过程，但主要还是讲解Seata配置管理的核心实现

Server启动流程

在讲配置中心之前，先简单介绍一下Server端的启动流程，因为这一块就涉及到配置管理的初始化，核心流程如下：

  1. 程序入口在Server#main方法中
  2. 获取port的几种形式：从容器中获取；从命令行获取；默认端口
  3. 解析命令行参数：host、port、storeMode等参数，这个过程可能涉及到配置管理的初始化
  4. Metric相关：无关紧要，跳过
  5. NettyServer初始化
  6. 核心控制器初始化：Server端的核心，还包括几个定时任务
  7. NettyServer启动

代码如下，删除了非核心代码

public static void main(String[] args) throws IOException {// 获取port的几种形式：从容器中获取；从命令行获取；默认端口, use to logback.xmlint port = PortHelper.getPort(args);System.setProperty(ConfigurationKeys.SERVER_PORT, Integer.toString(port));// 解析启动参数，分容器和非容器两种情况ParameterParser parameterParser = new ParameterParser(args);// Metric相关MetricsManager.get().init();// NettyServer初始化NettyRemotingServer nettyRemotingServer = new NettyRemotingServer(workingThreads);// 核心控制器初始化DefaultCoordinator coordinator = new DefaultCoordinator(nettyRemotingServer);coordinator.init();// NettyServer启动nettyRemotingServer.init();
}

为社么说步骤3中肯能涉及到配置管理的初始化呢？核心代码如下：

if (StringUtils.isBlank(storeMode)) {storeMode = ConfigurationFactory.getInstance().getConfig(ConfigurationKeys.STORE_MODE,SERVER_DEFAULT_STORE_MODE);
}

如果在启动参数中没有特别指定storeMode，就会通过ConfigurationFactory相关API去获取该配置，在ConfigurationFactory.getInstance()这行代码中，涉及到两部分内容：ConfigurationFactory静态代码初始化和Configuration初始化。接下来我们重点分析这部分内容

配置管理初始化

ConfigurationFactory初始化

我们知道在Seata中有两个关键配置文件：一个是registry.conf，这是核心配置文件，必须要有；另一个是file.conf，只有在配置中心是File的情况下才需要用到。ConfigurationFactory静态代码块中，其实主要就是加载registry.conf文件，大概如下：

1、在没有手动配置的情况，默认读取registry.conf文件，封装成一个FileConfiguration对象，核心代码如下：

Configuration configuration = new FileConfiguration(seataConfigName,false);
FileConfigFactory.load("registry.conf", "registry");
FileConfig fileConfig = EnhancedServiceLoader.load(FileConfig.class, "CONF", argsType, args);

2、配置增强：类似代理模式，获取配置时，在代理对象里面做一些其他处理，下面详细介绍

Configuration extConfiguration = EnhancedServiceLoader.load(ExtConfigurationProvider.class).provide(configuration);

3、将步骤2中的代理对象赋值给CURRENT_FILE_INSTANCE引用，在很多地方都直接用到了CURRENT_FILE_INSTANCE这个静态引用

CURRENT_FILE_INSTANCE = extConfiguration == null ? configuration : extConfiguration;

可以简单的认为：CURRENT_FILE_INSTANCE对应的就是registry.conf里面的内容。我认为registry.conf这个文件名取的不太好，歧义太大，叫做bootstrap.conf是不是更好一些？

Configuration初始化

Configuration其实就是对应配置中心，Seata目前支持的配置中心很多，几乎主流的配置中心都支持，如：apollo、consul、etcd、nacos、zk、springCloud、本地文件。当使用本地文件作为配置中心的时候，涉及到file.conf的加载，当然这是默认的名字，可以自己配置。到这里，大家也基本上知道了registry.conf和file.conf的关系了。

Configuration作为单例放在ConfigurationFactory中，所以Configuration的初始化逻辑也是在ConfigurationFactory中，大概流程如下：
1、先从registry.conf文件中读取config.type属性，默认就是file

configTypeName = CURRENT_FILE_INSTANCE.getConfig(ConfigurationKeys.FILE_ROOT_CONFIG + ConfigurationKeys.FILE_CONFIG_SPLIT_CHAR+ ConfigurationKeys.FILE_ROOT_TYPE);

2、基于config.type属性值加载配置中心，比如默认是:file，则先从registry.conf文件中读取config.file.name读取本地文件配置中心对应的文件名，然后基于该文件名创建FileConfiguration对象，这样就将file.conf中的配置加载到内存中了。同理，如果配置的是其他配置中心，则会通过SPI初始化其他配置中心。还有一点需要注意的是，在这阶段，如果配置中心是本地文件，则会为其创建代理对象；如果不是本地文件，则通过SPI加载对应的配置中心

if (ConfigType.File == configType) {String pathDataId = String.join("config.file.name");String name = CURRENT_FILE_INSTANCE.getConfig(pathDataId);configuration = new FileConfiguration(name);try {// 配置增强 代理extConfiguration = EnhancedServiceLoader.load(ExtConfigurationProvider.class).provide(configuration);} catch (Exception e) {LOGGER.error("failed to load extConfiguration:{}", e.getMessage(), e);}
} else {configuration = EnhancedServiceLoader.load(ConfigurationProvider.class, Objects.requireNonNull(configType).name()).provide();
}

3、基于步骤2创建的Configuration对象，为其再创建一层代理，这个代理对象有两个作用：一个是本地缓存，不需要每次获取配置的时候都从配置中获取；另一个是监听，当配置发生变更会更新它维护的缓存。如下：

if (null != extConfiguration) {configurationCache = ConfigurationCache.getInstance().proxy(extConfiguration);
} else {configurationCache = ConfigurationCache.getInstance().proxy(configuration);
}

到这里，配置管理的初始化就完成了。Seata通过先先加载registry.conf文件获取对应的配置中心信息、注册中心，然后再根据获取到的的对应信息初始化配置中心。在使用本地文件作为配置中心的情况下，默认是加载file.conf文件。然后再为对应的配置中心创建对应的代理对象，使其支持本地缓存和配置监听

整理流程还是比较简单，在这里我要抛出几个问题：

  1. 什么是配置增强？Seata中的配置增强是怎么做的？
  2. 如果使用本地文件作为配置中心，就必须要将配置定义在file.conf文件中。如果是Spring应用，能不能直接将对应的配置项定义在application.yaml中？
  3. 在上面说的步骤2中，为什么在使用本地文件配置中心的情况下，要先为Configuration创建对应配置增强代理对象，而其他配置中心不用？

这3个问题都是紧密联系的，都和Seata的配置增加相关。下面详细介绍

配置管理增强

配置增强，简单来说就是为其创建一个代理对象，在执行目标独对象的目标方法时候，执行代理逻辑，从配置中心的角度来讲，就是在通过配置中心获取对应配置的时候，执行代理逻辑。

  1. 通过ConfigurationFactory.CURRENT_FILE_INSTANCE.getgetConfig(key)获取配置
  2. 加载registry.conf文件创建FileConfiguration对象configuration
  3. 基于SpringBootConfigurationProvider为configuration创建代理对象configurationProxy
  4. 从configurationProxy中获取配置中心的连接信息file zk nacos 等
  5. 基于连接信息创建配中心Configuration对象configuration2
  6. 基于SpringBootConfigurationProvider为configuration2创建代理对象configurationProxy2
  7. 执行configurationProxy2的代理逻辑
  8. 基于key找到对应的SpringBean
  9. 执行SpringBean的getXxx方法

配置增强实现

上面也简单提到过配置增强，相关代码如下：

EnhancedServiceLoader.load(ExtConfigurationProvider.class).provide(configuration);
  1. 首先通过SPI机获取一个ExtConfigurationProvider对象，在Seata中默认只有一个实现：SpringBootConfigurationProvider
  2. 通过ExtConfigurationProvider#provider方法为Configuration创建代理对象

核心代码如下:

public Configuration provide(Configuration originalConfiguration) {return (Configuration) Enhancer.create(originalConfiguration.getClass(), new MethodInterceptor() {@Overridepublic Object intercept(Object proxy, Method method, Object[] args, MethodProxy methodProxy)throws Throwable {if (method.getName().startsWith("get") && args.length > 0) {Object result = null;String rawDataId = (String) args[0];if (args.length == 1) {result = get(convertDataId(rawDataId));} else if (args.length == 2) {result = get(convertDataId(rawDataId), args[1]);} else if (args.length == 3) {result = get(convertDataId(rawDataId), args[1], (Long) args[2]);}if (result != null) {//If the return type is String,need to convert the object to stringif (method.getReturnType().equals(String.class)) {return String.valueOf(result);}return result;}}return method.invoke(originalConfiguration, args);}});
}private Object get(String dataId) throws IllegalAccessException, InstantiationException {String propertyPrefix = getPropertyPrefix(dataId);String propertySuffix = getPropertySuffix(dataId);ApplicationContext applicationContext = (ApplicationContext) ObjectHolder.INSTANCE.getObject(OBJECT_KEY_SPRING_APPLICATION_CONTEXT);Class<?> propertyClass = PROPERTY_BEAN_MAP.get(propertyPrefix);Object valueObject = null;if (propertyClass != null) {try {Object propertyBean = applicationContext.getBean(propertyClass);valueObject = getFieldValue(propertyBean, propertySuffix, dataId);} catch (NoSuchBeanDefinitionException ignore) {}} else {throw new ShouldNeverHappenException("PropertyClass for prefix: [" + propertyPrefix + "] should not be null.");}if (valueObject == null) {valueObject = getFieldValue(propertyClass.newInstance(), propertySuffix, dataId);}return valueObject;
}

1、如果方法是以get开头，并且参数个数为1/2/3，则执行其他的获取配置的逻辑，否则执行原生Configuration对象的逻辑
2、我们没必要纠结为啥是这样的规则，这就是Seata的一个约定
3、其他获取配置的逻辑，就是指通过Spring的方式获取对应配置值

到这里已经清楚了配置增强的原理，同时，也可以猜测得出唯一的ExtConfigurationProvider实现SpringBootConfigurationProvider，肯定是和Spring相关

配置增强与Spring

在介绍这块内容之前，我们先简单介绍一下Seata的使用方式：

  1. 非Starter方式：引入依赖 seata-all, 然后手动配置几个核心的Bean
  2. Starter方式： 引入依赖seata-spring-boot-starter，全自动准配，不需要自动注入核心Bean

SpringBootConfigurationProvider就在seata-spring-boot-starter模块中，也就是说，当我们通过引入seata-all的方式来使用Seata时，配置增强其实没有什么作用，因为此时根本找不到ExtConfigurationProvider实现类，自然就不会增强。

那seata-spring-boot-starter是如何将这些东西串联起来的？

1、首先，在seata-spring-boot-starter模块的resources/META-INF/services目录下，存在一个spring.factories文件，内容分如下

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
io.seata.spring.boot.autoconfigure.SeataAutoConfiguration,\# 暂时不管
io.seata.spring.boot.autoconfigure.HttpAutoConfiguration

2、在SeataAutoConfiguration文件中，会创建以下Bean： GlobalTransactionScanner 、SeataDataSourceBeanPostProcessor、SeataAutoDataSourceProxyCreator、SpringApplicationContextProvider。前3个和我们本文要讲的内容不相关，主要关注SpringApplicationContextProvider，核心代码非常简单，就是将ApplicationContext保存下来：

public class SpringApplicationContextProvider implements ApplicationContextAware {@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {ObjectHolder.INSTANCE.setObject(OBJECT_KEY_SPRING_APPLICATION_CONTEXT, applicationContext);}
}

3、然后，在SeataAutoConfiguration文件中，还会将一些xxxProperties.Class和对应的Key前缀缓存到PROPERTY_BEAN_MAP中。``xxxProperties就简单理解成application.yaml`中的各种配置项：

static {PROPERTY_BEAN_MAP.put(SEATA_PREFIX, SeataProperties.class);PROPERTY_BEAN_MAP.put(CLIENT_RM_PREFIX, RmProperties.class);PROPERTY_BEAN_MAP.put(SHUTDOWN_PREFIX, ShutdownProperties.class);...省略...
}

至此，整个流程其实已经很清晰，在有SpringBootConfigurationProvider配置增强的时候，我们获取一个配置项的流程如下：

  1. 先根据p配置项Key获取对应的xxxProperties对象
  2. 通过ObjectHolder中的ApplicationContext获取对应xxxProperties的SpringBean
  3. 基于xxxProperties的SpringBean获取对应配置的值
  4. 至此，通过配置增强，我们成功的获取到application.yaml中的值

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/pingmian/41906.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Linux系统基础命令行指令——Ubuntu

Linux系统基础命令行指令——Ubuntu

基础指令 更新指令 sudo apt update sudo apt upgrade 切换超级管理员 su root 切换路径 //相对、绝对 cd 路径回上一级路径 cd ..cd ../.. 退两级路径 查看当前目录 pwd查看指定路径内容 ls //常见搭配 ls -al 创建目录 mkdir 路径 创建文件 touc…
阅读更多...
47.HOOK引擎优化支持CALL与JMP位置做HOOK

47.HOOK引擎优化支持CALL与JMP位置做HOOK

免责声明&#xff1a;内容仅供学习参考&#xff0c;请合法利用知识&#xff0c;禁止进行违法犯罪活动&#xff01; 上一个内容&#xff1a;46.修复HOOK对代码造成的破坏 以 46.修复HOOK对代码造成的破坏 它的代码为基础进行修改 优化的是让引擎支持从短跳JMP&#xff08;E9&…
阅读更多...
第三十章 方法大全（Python）

第三十章 方法大全（Python）

文章目录 一、日期1、time模块 一、日期 1、time模块 import time方法描述time.sleep(secs)程序暂停执行指定的秒数 time.sleep(secs)参数&#xff1a;secs&#xff1a;推迟执行的秒数Delay execution for a given number of seconds. The argument may bea floating point …
阅读更多...
美光科技在2024年1γ工艺技术在10纳米级别启动EUV试产

美光科技在2024年1γ工艺技术在10纳米级别启动EUV试产

美光科技&#xff08;Micron&#xff09;在2024年针对其1γ&#xff08;1-gamma&#xff09;工艺技术在10纳米级别启动EUV&#xff08;极紫外光刻&#xff09;试产&#xff0c;这标志着存储行业巨头在EUV采用上的重要一步&#xff0c;尽管相比英特尔和台积电等其他半导体制造商…
阅读更多...
【PWN · ret2shellcode | sandbox-bypass | 格式化字符串】[2024CISCN · 华东北赛区]pwn1_

【PWN · ret2shellcode | sandbox-bypass | 格式化字符串】[2024CISCN · 华东北赛区]pwn1_

一道栈ret2shellcodesandbox&#xff08;seccomp&#xff09;格式化字符串的题目 前言 ret2shellcode&#xff0c;已经不是简单的放到栈上、ret这样一个简单的过程。套一层seccomp的沙箱&#xff0c;打ORW又遇到open受限等等&#xff0c;考虑的蛮多。过程中收获最多的可以说是…
阅读更多...
Hugging face Transformers（2）—— Pipeline

Hugging face Transformers（2）—— Pipeline

Hugging Face 是一家在 NLP 和 AI 领域具有重要影响力的科技公司&#xff0c;他们的开源工具和社区建设为NLP研究和开发提供了强大的支持。它们拥有当前最活跃、最受关注、影响力最大的 NLP 社区&#xff0c;最新最强的 NLP 模型大多在这里发布和开源。该社区也提供了丰富的教程…
阅读更多...
【系统架构设计师】计算机组成与体系结构 ⑩ ( 磁盘管理 | 磁盘移臂调度算法 | 先来先服务算法 | 最短寻道时间优先 | 扫描算法 | 循环扫描算法 )

【系统架构设计师】计算机组成与体系结构 ⑩ ( 磁盘管理 | 磁盘移臂调度算法 | 先来先服务算法 | 最短寻道时间优先 | 扫描算法 | 循环扫描算法 )

文章目录 一、磁盘移臂调度算法1、磁盘移臂调度算法简介2、先来先服务算法3、最短寻道时间优先4、扫描算法5、循环扫描算法 二、最短寻道时间优先算法示例 一、磁盘移臂调度算法 1、磁盘移臂调度算法简介 磁盘 数据块读取 的 性能 主要由 寻道时间旋转延时 决定 ; 旋转延时 …
阅读更多...
ROS 2官方文档（基于humble版本）学习笔记（四）

ROS 2官方文档（基于humble版本）学习笔记（四）

ROS 2官方文档&#xff08;基于humble版本&#xff09;学习笔记&#xff08;四&#xff09; 2.客户端库使用colcon构建包&#xff08;package&#xff09;创建工作空间&#xff08;workspace&#xff09;构建工作空间执行测试&#xff08;tests&#xff09;导入环境&#xff08…
阅读更多...
第十四届蓝桥杯省赛C++B组G题【子串简写】题解（AC）

第十四届蓝桥杯省赛C++B组G题【子串简写】题解（AC）

题目大意 给定字符串 s s s&#xff0c;字符 a , b a, b a,b&#xff0c;问字符串 s s s 中有多少个 a a a 开头 b b b 结尾的子串。 解题思路 20pts 使用二重循环枚举左端点和右端点&#xff0c;判断是否为 a a a 开头 b b b 结尾的字符串&#xff0c;是则答案加一…
阅读更多...
一阶滞后滤波法

一阶滞后滤波法

一阶滞后滤波法 一阶滞后滤波法：取a=0到1，本次滤波结果=(1-a)乘以本次采样值+a乘以上次滤波结果。 优点： 对周期性干扰具有良好的抑制作用；适用于波动频率较高的场合。 缺点： 相位滞后，灵敏度低；滞后程度取决于a值大小；不能消除滤波频率高于采样频率1/2的干扰信号。 …
阅读更多...
Stable Diffusion：最全详细图解

Stable Diffusion：最全详细图解

Stable Diffusion&#xff0c;作为一种革命性的图像生成模型&#xff0c;自发布以来便因其卓越的生成质量和高效的计算性能而受到广泛关注。不同于以往的生成模型&#xff0c;Stable Diffusion在生成图像的过程中&#xff0c;采用了独特的扩散过程&#xff0c;结合深度学习技术…
阅读更多...
精通Perl正则表达式修饰符：提升文本处理能力的艺术

精通Perl正则表达式修饰符：提升文本处理能力的艺术

Perl语言以其强大的文本处理能力而闻名&#xff0c;其中正则表达式是其核心特性之一。正则表达式本身非常强大&#xff0c;但Perl提供的修饰符&#xff08;Modifiers&#xff09;进一步扩展了正则表达式的灵活性和表达能力。本文将深入探讨Perl中正则表达式修饰符的使用&#x…
阅读更多...
2024亚太杯数学建模竞赛（B题）的全面解析

2024亚太杯数学建模竞赛（B题）的全面解析

你是否在寻找数学建模比赛的突破点&#xff1f;数学建模进阶思路&#xff01; 作为经验丰富的数学建模团队&#xff0c;我们将为你带来2024亚太杯数学建模竞赛&#xff08;B题&#xff09;的全面解析。这个解决方案包不仅包括完整的代码实现&#xff0c;还有详尽的建模过程和解…
阅读更多...
【C++：类的基础认识和this指针】

【C++：类的基础认识和this指针】

C的类与C语言的struct结构体有啥区别&#xff1f; 默认的访问限定符不同 类的简要 关键字&#xff1a;class{}里面是类的主体&#xff0c;特别注意&#xff1a;{}后面的&#xff1b;不可以省略类中的变量叫做成员变量&#xff0c;类中的函数叫做成员函数类中访问有三种访问权限…
阅读更多...
单/多线程--协程--异步爬虫

单/多线程--协程--异步爬虫

免责声明:本文仅做技术交流与学习... 目录 了解进程和线程 单个线程(主线程)在执行 多线程 线程池 协程(爬虫多用) 假异步:(同步) 真异步: 爬虫代码模版 异步-爬虫 同步效果--19秒 异步效果--7秒 了解进程和线程 ​ # --------------------> # ------> # …
阅读更多...
Anaconda新建python版本

Anaconda新建python版本

由于新版本的Anaconda自带的python是3.11的&#xff0c;国内镜像一些库&#xff0c;不好下载。特更新为常见的python3.9 1.新建环境&#xff0c;指定新python版本 #conda create --name 名称 python(版本) #示例 conda create --name liuenv python3.9 #指定环境的存储位置 c…
阅读更多...
MinIO:开源对象存储解决方案的领先者

MinIO:开源对象存储解决方案的领先者

MinIO:开源对象存储解决方案的领先者 MinIO 是一款开源的对象存储系统&#xff0c;致力于提供高性能、可伸缩、安全的数据存储解决方案。 官方解释&#xff1a;MinIO 是一个基于Apache License v2。0开源协议的对象存储服务。它兼容亚马逊S3云存储服务接口&#xff0c;非常适…
阅读更多...
WAIC：生成式 AI 时代的到来，高通创新未来！

WAIC：生成式 AI 时代的到来，高通创新未来！

目录 01 在终端侧算力上&#xff0c;动作最快的就是高通 02 模型优化&#xff0c;完成最后一块拼图 在WAIC上&#xff0c;高通展示的生成式AI创新让我们看到了未来的曙光。 生成式 AI 的爆发带来了意想不到的产业格局变化&#xff0c;其速度之快令人惊叹。 仅在一个月前&…
阅读更多...
SchedulingConfigurer使用教程

SchedulingConfigurer使用教程

SchedulingConfigurer使用教程&#xff1a;Java定时任务的高阶使用 在 Java 开发中&#xff0c;定时任务的管理和执行是一个常见需求。Spring 提供了多种方式来处理定时任务&#xff0c;其中 SchedulingConfigurer 是一个强大且灵活的接口&#xff0c;允许我们对定时任务进行更…
阅读更多...
说一下浏览器中的强缓存和协商缓存的区别

说一下浏览器中的强缓存和协商缓存的区别

写在前面 对于一道高频的面试题&#xff0c;可能很多小伙伴还不知道这两者的概念&#xff0c;不知道是用来做什么的&#xff0c;以及有什么好处&#xff0c;强缓存和协商缓存是 Web 缓存机制的重要组成部分&#xff0c;它们在优化 Web 应用性能方面发挥了重要作用&#xff0c;…
阅读更多...
最新文章

Copyright @ 2022~2023