SpringBoot配置文件讀取過程分析

来源:https://www.cnblogs.com/yuanbeier/archive/2022/07/17/16488973.html
-Advertisement-
Play Games

整體流程分析 SpringBoot的配置文件有兩種 ,一種是 properties文件,一種是yml文件。在SpringBoot啟動過程中會對這些文件進行解析載入。在SpringBoot啟動的過程中,配置文件查找和解析的邏輯在listeners.environmentPrepared(environ ...


整體流程分析

SpringBoot的配置文件有兩種 ,一種是 properties文件,一種是yml文件。在SpringBoot啟動過程中會對這些文件進行解析載入。在SpringBoot啟動的過程中,配置文件查找和解析的邏輯在listeners.environmentPrepared(environment)方法中。

void environmentPrepared(ConfigurableEnvironment environment) {
    for (SpringApplicationRunListener listener : this.listeners) {
        listener.environmentPrepared(environment);
    }
}

依次遍歷監聽器管理器的environmentPrepared方法,預設只有一個 EventPublishingRunListener 監聽器管理器,代碼如下,

@Override
public void environmentPrepared(ConfigurableEnvironment environment) {
    this.initialMulticaster
        .multicastEvent(new ApplicationEnvironmentPreparedEvent(this.application, this.args, environment));
}

監聽管理器的多播器有中有11個,其中針對配置文件的監聽器類為 ConfigFileApplicationListener,會執行該類的 onApplicationEvent方法。代碼如下,

@Override
public void onApplicationEvent(ApplicationEvent event) {
    if (event instanceof ApplicationEnvironmentPreparedEvent) {
        // 執行 ApplicationEnvironmentPreparedEvent 事件
        onApplicationEnvironmentPreparedEvent((ApplicationEnvironmentPreparedEvent) event);
    }
    if (event instanceof ApplicationPreparedEvent) {
        onApplicationPreparedEvent(event);
    }
}

onApplicationEnvironmentPreparedEvent的邏輯為:先從/META-INF/spring.factories文件中獲取實現了EnvironmentPostProcessor介面的環境變數後置處理器集合,再把當前的 ConfigFileApplicationListener 監聽器添加到 環境變數後置處理器集合中(ConfigFileApplicationListener實現了EnvironmentPostProcessor介面),然後迴圈遍歷 postProcessEnvironment 方法,並傳入 事件的SpringApplication 對象和 環境變數。

private void onApplicationEnvironmentPreparedEvent(ApplicationEnvironmentPreparedEvent event) {
    List<EnvironmentPostProcessor> postProcessors = loadPostProcessors();
    postProcessors.add(this);
    AnnotationAwareOrderComparator.sort(postProcessors);
    for (EnvironmentPostProcessor postProcessor : postProcessors) {
        postProcessor.postProcessEnvironment(event.getEnvironment(), event.getSpringApplication());
    }
}

在ConfigFileApplicationListener 的postProcessEnvironment方法中(其他幾個環境變數後置處理器與讀取配置文件無關),核心是創建了一個Load對象,並且調用了load()方法。

protected void addPropertySources(ConfigurableEnvironment environment, ResourceLoader resourceLoader) {
    RandomValuePropertySource.addToEnvironment(environment);
    new Loader(environment, resourceLoader).load();
}
  1. Loader是ConfigFileApplicationListener 的一個內部類,在Loader的構造方法中,會生成具體屬性文件的資源載入類並賦值給this.propertySourceLoaders。代碼如下,
Loader(ConfigurableEnvironment environment, ResourceLoader resourceLoader) {
    this.environment = environment;
    this.placeholdersResolver = new PropertySourcesPlaceholdersResolver(this.environment);
    this.resourceLoader = (resourceLoader != null) ? resourceLoader : new DefaultResourceLoader();
    //從 /META-INF/spring.factories 中載入 PropertySourceLoader 的實現類
    this.propertySourceLoaders = SpringFactoriesLoader.loadFactories(PropertySourceLoader.class,
                                                                     getClass().getClassLoader());
}

從 /META-INF/spring.factories 中載入 PropertySourceLoader 的實現類,在具體解析資源文件的時候用到。具體的實現類如下,

org.springframework.boot.env.PropertySourceLoader=\
org.springframework.boot.env.PropertiesPropertySourceLoader,\
org.springframework.boot.env.YamlPropertySourceLoader
  1. Loader類的load方法是載入配置文件的入口方法,代碼如下,
void load() {
    FilteredPropertySource.apply(...)
}

FilteredPropertySource.apply()方法先判斷是否存在以 defaultProperties 為名的 PropertySource 屬性對象,如果不存在則執行operation.accept,如果存在則先替換,再執行operation.accept方法。代碼如下:

static void apply(ConfigurableEnvironment environment, String propertySourceName, Set<String> filteredProperties,
                  Consumer<PropertySource<?>> operation) {
    // 在環境變數中獲取 屬性資源管理對象
    MutablePropertySources propertySources = environment.getPropertySources();
    // 根據 資源名稱 獲取屬性資源對象
    PropertySource<?> original = propertySources.get(propertySourceName);
    // 如果為null,則執行 operation.accept
    if (original == null) {
        operation.accept(null);
        return;
    }
    //根據propertySourceName名稱進行替換
    propertySources.replace(propertySourceName, new FilteredPropertySource(original, filteredProperties));
    try {
        operation.accept(original);
    }
    finally {
        propertySources.replace(propertySourceName, original);
    }
}
  1. operation.accept是一個函數介面,配置文件的解析和處理都在該方法中。具體的邏輯為:先初始化待處理的屬性文件,再遍歷解析待處理的屬性文件並解析結果放在this.loaded中,然後添加this.loaded的數據至環境變數 this.environment.getPropertySources() 中,最後設置環境變數的ActiveProfiles屬性。代碼如下,
// 待處理的屬性文件
this.profiles = new LinkedList<>();
// 已處理的屬性文件
this.processedProfiles = new LinkedList<>();
this.activatedProfiles = false;
// 已經載入的 屬性文件和屬性
this.loaded = new LinkedHashMap<>();
// 添加 this.profiles 的 null 和 預設的屬性文件
initializeProfiles();
// 迴圈 this.profiles 載入
while (!this.profiles.isEmpty()) {
    Profile profile = this.profiles.poll();
    // 如果是主屬性文件則先添加到環境變數中的 addActiveProfile
    if (isDefaultProfile(profile)) {
        addProfileToEnvironment(profile.getName());
    }
    // 真正載入邏輯
    load(profile, this::getPositiveProfileFilter,
         addToLoaded(MutablePropertySources::addLast, false));
    this.processedProfiles.add(profile);
}
// 載入 profile 為null 的
load(null, this::getNegativeProfileFilter, addToLoaded(MutablePropertySources::addFirst, true));
// 添加已經載入的 屬性文件和屬性至 環境變數 this.environment.getPropertySources() 中 
addLoadedPropertySources();
//根據已處理的屬性文件設置環境變數的ActiveProfiles
applyActiveProfiles(defaultProperties);

配置文件解析過程

  1. 如上的load()的邏輯為:先獲取所有的查找路徑,再遍歷查找路徑並且獲取屬性配置文件的名稱,最後根據名稱和路徑進行載入。這裡會在 file:./config/,file:./,classpath:/config/,classpath:/ 四個不同的目錄進行查找。優先順序從左至右。
private void load(Profile profile, DocumentFilterFactory filterFactory, DocumentConsumer consumer) {
    // 獲取 預設的 classpath:/,classpath:/config/,file:./,file:./config/ 文件路徑
    // 根據路徑查找具體的屬性配置文件
    getSearchLocations().forEach((location) -> {
        // 判斷是否為文件夾
        boolean isFolder = location.endsWith("/");
        // 獲取 屬性配置文件的名稱
        Set<String> names = isFolder ? getSearchNames() : NO_SEARCH_NAMES;
        // 根據名稱遍歷進行載入具體路徑下的具體的屬性文件名
        names.forEach((name) -> load(location, name, profile, filterFactory, consumer));
    });
}
  1. getSearchLocations()獲取屬性文件搜索路徑,如果環境變數中包括了 spring.config.location 則使用環境變數中配置的值,如果沒有則使用預設的 file:./config/,file:./,classpath:/config/,classpath:/文件路徑。代碼如下,
// 獲取搜索路徑
private Set<String> getSearchLocations() {
    // 如果環境變數中包括了 spring.config.location 則使用 環境變數配置的值。
    if (this.environment.containsProperty(CONFIG_LOCATION_PROPERTY)) {
        return getSearchLocations(CONFIG_LOCATION_PROPERTY);
    }
    // 獲取 環境變數 spring.config.additional-location 的值
    Set<String> locations = getSearchLocations(CONFIG_ADDITIONAL_LOCATION_PROPERTY);
    // 添加預設的 classpath:/,classpath:/config/,file:./,file:./config/ 搜索文件
    // 倒敘排列後 為 file:./config/,file:./,classpath:/config/,classpath:/
    locations.addAll(
        asResolvedSet(ConfigFileApplicationListener.this.searchLocations, DEFAULT_SEARCH_LOCATIONS));
    return locations;
}
  1. getSearchNames()獲取屬性文件搜索名稱,如果環境變數中有設置 spring.config.name 屬性,則獲取設置的名稱,如果沒有設置配置文件名稱的環境變數則返回名稱為 application。代碼如下,
private Set<String> getSearchNames() {
    // 如果 環境變數中有設置 spring.config.name 屬性,則獲取設置的 名稱
    if (this.environment.containsProperty(CONFIG_NAME_PROPERTY)) {
        String property = this.environment.getProperty(CONFIG_NAME_PROPERTY);
        return asResolvedSet(property, null);
    }
    // 如果沒有設置環境變數 則返回名稱為 application
    return asResolvedSet(ConfigFileApplicationListener.this.names, DEFAULT_NAMES);
}
  1. names.forEach((name) -> load(location, name, profile, filterFactory, consumer))中的load() 的邏輯為:先判斷文件名name是否為null,如果為null則通過遍歷屬性資源載入器並且根據location進行載入屬性資源文件;如果不為null ,則通過遍歷屬性資源載入器和遍歷屬性資源載入器的擴展名,根據location和 name 來載入屬性資源文件,從配置文件可知,先會遍歷執行 PropertiesPropertySourceLoader 的擴展名 ,然後遍歷執行YamlPropertySourceLoader的擴展名 。代碼如下,
private void load(String location, String name, Profile profile, DocumentFilterFactory filterFactory,
                  DocumentConsumer consumer) {
    // 如果文件名稱為null
    if (!StringUtils.hasText(name)) {
        // 遍歷屬性資源載入器
        for (PropertySourceLoader loader : this.propertySourceLoaders) {
            // 根據屬性資源載入的擴展名稱進行過濾
            if (canLoadFileExtension(loader, location)) {
                load(loader, location, profile, filterFactory.getDocumentFilter(profile), consumer);
                return;
            }
        }
        throw new IllegalStateException("File extension of config file location '" + location
                                        + "' is not known to any PropertySourceLoader. If the location is meant to reference "
                                        + "a directory, it must end in '/'");
    }
    Set<String> processed = new HashSet<>();
    // 遍歷屬性資源載入器
    for (PropertySourceLoader loader : this.propertySourceLoaders) {
        // 遍歷屬性資源載入器的擴展名
        for (String fileExtension : loader.getFileExtensions()) {
            if (processed.add(fileExtension)) {
                // 傳入具體的屬性文件路徑和尾碼名,進行載入屬性資源文件
                loadForFileExtension(loader, location + name, "." + fileExtension, profile, filterFactory,
                                     consumer);
            }
        }
    }
}
  1. loadForFileExtension()關鍵代碼是load()方法,代碼如下。
private void loadForFileExtension(PropertySourceLoader loader, String prefix, String fileExtension,
                                  Profile profile, DocumentFilterFactory filterFactory, DocumentConsumer consumer) {
    DocumentFilter defaultFilter = filterFactory.getDocumentFilter(null);
    DocumentFilter profileFilter = filterFactory.getDocumentFilter(profile);
    if (profile != null) {
        // Try profile-specific file & profile section in profile file (gh-340)
        String profileSpecificFile = prefix + "-" + profile + fileExtension;
        load(loader, profileSpecificFile, profile, defaultFilter, consumer);
        load(loader, profileSpecificFile, profile, profileFilter, consumer);
        // Try profile specific sections in files we've already processed
        for (Profile processedProfile : this.processedProfiles) {
            if (processedProfile != null) {
                String previouslyLoaded = prefix + "-" + processedProfile + fileExtension;
                load(loader, previouslyLoaded, profile, profileFilter, consumer);
            }
        }
    }
    // Also try the profile-specific section (if any) of the normal file
    // 拼接文件路徑和尾碼名後,進行載入屬性資源文件
    load(loader, prefix + fileExtension, profile, profileFilter, consumer);
}
  1. 如上代碼的load()方法主要邏輯為:先根據傳入的文件路徑生成 Resource 對象,如果該Resource 對象存在則解析成具體的documents對象,然後根據DocumentFilter 過濾器進行匹配,匹配成功則添加到 loaded 中,再進行倒敘排列。最後遍歷 loaded 對象,調用consumer.accept ,將 profile 和 document 添加至 this.loaded 對象。
private void load(PropertySourceLoader loader, String location, Profile profile, DocumentFilter filter,
                  DocumentConsumer consumer) {
    try {
        // 根據文件路徑 獲取資源
        Resource resource = this.resourceLoader.getResource(location);
        // 如果為 null 則返回
        if (resource == null || !resource.exists()) {
            if (this.logger.isTraceEnabled()) {
                StringBuilder description = getDescription("Skipped missing config ", location, resource,
                                                           profile);
                this.logger.trace(description);
            }
            return;
        }
        if (!StringUtils.hasText(StringUtils.getFilenameExtension(resource.getFilename()))) {
            if (this.logger.isTraceEnabled()) {
                StringBuilder description = getDescription("Skipped empty config extension ", location,
                                                           resource, profile);
                this.logger.trace(description);
            }
            return;
        }
        String name = "applicationConfig: [" + location + "]";
        // 根據資源 和 屬性資源解析器載入 List<Document> ,併進行緩存
        List<Document> documents = loadDocuments(loader, name, resource);
        if (CollectionUtils.isEmpty(documents)) {
            if (this.logger.isTraceEnabled()) {
                StringBuilder description = getDescription("Skipped unloaded config ", location, resource,
                                                           profile);
                this.logger.trace(description);
            }
            return;
        }
        List<Document> loaded = new ArrayList<>();
        // 遍歷 documents
        for (Document document : documents) {
            // 如果匹配則添加
            if (filter.match(document)) {
                addActiveProfiles(document.getActiveProfiles());
                addIncludedProfiles(document.getIncludeProfiles());
                loaded.add(document);
            }
        }
        // 倒敘排列
        Collections.reverse(loaded);
        if (!loaded.isEmpty()) {
           	//遍歷 loaded 對象,調用consumer.accept ,將 profile 和 document 添加至 this.loaded 對象
            loaded.forEach((document) -> consumer.accept(profile, document));
            if (this.logger.isDebugEnabled()) {
                StringBuilder description = getDescription("Loaded config file ", location, resource, profile);
                this.logger.debug(description);
            }
        }
    }
    catch (Exception ex) {
        throw new IllegalStateException("Failed to load property source from location '" + location + "'", ex);
    }
}
  1. 至此配置文件解析全部處理完成,最終會把解析出來的配置文件和配置屬性值添加到了 this.loaded 對象中。
  2. 總結一下,預設情況下,屬性配置文件的搜索路徑為 file:./config/,file:./,classpath:/config/,classpath:/ ,優先順序從左往右;配置文件名稱為 application,擴展名為"properties", "xml","yml", "yaml",優先順序從左往右。如果同一個配置屬性配置在多個配置文件中,則取優先順序最高的那個配置值。

環境變數設置配置屬性

  1. addLoadedPropertySources()方法,主要邏輯為:添加已經載入的屬性文件添加至環境變數 this.environment 中 。代碼如下,
private void addLoadedPropertySources() {
    // 獲取環境變數的 PropertySources對象
    MutablePropertySources destination = this.environment.getPropertySources();
    List<MutablePropertySources> loaded = new ArrayList<>(this.loaded.values());
    // 倒序排列
    Collections.reverse(loaded);
    String lastAdded = null;
    Set<String> added = new HashSet<>();
    for (MutablePropertySources sources : loaded) {
        for (PropertySource<?> source : sources) {
            if (added.add(source.getName())) {
                // 添加 PropertySource 至 destination
                addLoadedPropertySource(destination, lastAdded, source);
                lastAdded = source.getName();
            }
        }
    }
}
  1. applyActiveProfiles()主要邏輯為:根據已處理的屬性文件設置環境變數environment的ActiveProfiles屬性。
// 設置環境變數的ActiveProfiles
private void applyActiveProfiles(PropertySource<?> defaultProperties) {
    List<String> activeProfiles = new ArrayList<>();
    if (defaultProperties != null) {
        Binder binder = new Binder(ConfigurationPropertySources.from(defaultProperties),
                                   new PropertySourcesPlaceholdersResolver(this.environment));
        activeProfiles.addAll(getDefaultProfiles(binder, "spring.profiles.include"));
        if (!this.activatedProfiles) {
            activeProfiles.addAll(getDefaultProfiles(binder, "spring.profiles.active"));
        }
    }
    this.processedProfiles.stream().filter(this::isDefaultProfile).map(Profile::getName)
        .forEach(activeProfiles::add);
    this.environment.setActiveProfiles(activeProfiles.toArray(new String[0]));
}


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 首先是關於本人對一個新事物的理解路線 對html的認知: what:首先我得知道它是什麼?html是一門超文本標記語言,它不是一門編程語言 why:它為什麼會存在?它存在的意義是什麼?隨著互聯網的發展,人們通常通過手機、電腦等網路渠道獲取信息和生產生活,故它的存在是為了製作網頁 how:這門語言該怎 ...
  • XML 可擴展標記語言(Extensive Markup Language),標簽中的元素名是可以自己隨意寫,可拓展是相對於html來說 標記語言:由一對尖括弧括起來<內容>,就稱為標記,標簽;代碼都是由標簽組成,就稱為標記語言 作用 用來當做配置文件 xml的配置文件和properties的配置文 ...
  • JavaScript JavaScript(簡稱“JS”)是一種具有函數優先的輕量級,解釋型或即時編譯型的高級編程語言,弱類型,腳本語言 三大部分 核心(ECMAScript):語法、類型、語句、關鍵字等 文檔對象模型(DOM):專門用於完成網頁之間的交互 瀏覽器對象模型(BOM):主要用於對瀏覽器 ...
  • web系統架構體系 B/S(Browser/Server):瀏覽器實現 優點: 規範、使用方便、本身實現成本低 容易升級、便於維護 缺點: 沒有網路,無法使用 保存數據量有限,和伺服器交互頻率高、耗費流量 安全性差一點 C/S(Client/Server):客戶端實現 優點: 可以在無網路環境下使用 ...
  • 這是一款支持多種語言的源代碼編輯器editrocket,這款編輯器有著非常強的相容性,易學易用,具有語法高亮,代碼創建和sidekicks ,導航等多種功能,是初學代碼小伙伴們的得力助手。 詳情:EditRocket for Mac(源代碼編輯器) 功能亮點 源代碼編輯器 包括巨集,編碼插入,插件,超 ...
  • 實現簡單的信息錄入系統: <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport ...
  • 參數過長 影響: 方法不易被理解、使用,方法簽名容易不穩定,不易維護 解決方法:反覆使用提煉方法+內聯方法,消除多餘參數 ​ 儘量把方法移進相關的類中 ​ 如實體類中的get方法在其他類中沒有被調用可以刪除 ​ 實際工作中,可以結合參數數量、以及自身對業務的理解,在 最小知道 和 保持對象完整性 之 ...
  • 很多開發同學對SQL優化如數家珍,卻對MySQL架構一知半解。豈不是只見樹葉,不見森林,終將陷入細節中不能自拔。 今天就一塊學習MySQL分層架構,深入瞭解MySQL底層實現原理,以及每層的作用,我們常見的SQL優化到底在哪一層做了優化? ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...