spring-boot-2.0.3不一樣系列之源碼篇 - SpringApplication的run方法(一)之SpringApplicationRunListener,絕對有值得你看的地方

来源:https://www.cnblogs.com/youzhibing/archive/2018/09/10/9603119.html
-Advertisement-
Play Games

前言 Springboot啟動源碼系列還只寫了一篇,已經過去一周,又到了每周一更的時間了(是不是很熟悉?),大家有沒有很期待了?我會儘量保證啟動源碼系列每周一更,爭取不讓大家每周的期望落空。一周之中可能會插入其他內容的博文,可能和springboot啟動源碼有關,也可能和啟動源碼無關。 路漫漫其修遠 ...


前言

  Springboot啟動源碼系列還只寫了一篇,已經過去一周,又到了每周一更的時間了(是不是很熟悉?),大家有沒有很期待了?我會儘量保證啟動源碼系列每周一更,爭取不讓大家每周的期望落空。一周之中可能會插入其他內容的博文,可能和springboot啟動源碼有關,也可能和啟動源碼無關。

  路漫漫其修遠兮,吾將上下而求索!

  github:https://github.com/youzhibing

  碼雲(gitee):https://gitee.com/youzhibing

前情回顧

  這篇是在spring-boot-2.0.3不一樣系列之源碼篇 - springboot源碼一,絕對有值得你看的地方spring-boot-2.0.3不一樣系列之番外篇 - springboot事件機制,絕對有值得你看的地方這兩篇的基礎上進行的,沒看的小伙伴可以先去看看這兩篇。如果大家不想去看,這裡我幫大家簡單回顧下。

  spring-boot-2.0.3不一樣系列之源碼篇 - springboot源碼一,絕對有值得你看的地方

    SpringApplication的構造方法主要做了以下3件事:

      1、推測web應用類型,並賦值到屬性webApplicationType

      2、設置屬性List<ApplicationContextInitializer<?>> initializers和List<ApplicationListener<?>> listeners

        中途讀取了類路徑下所有META-INF/spring.factories的屬性,並緩存到了SpringFactoriesLoader的cache緩存中,而這個cache會在本文中用到

      3、 推斷主類,並賦值到屬性mainApplicationClass

  spring-boot-2.0.3不一樣系列之番外篇 - springboot事件機制,絕對有值得你看的地方

    事件機制是基於觀察者模式實現的。主要包括幾下4個角色:

      事件源:觸發事件的主體

      事件:事件本身,指的是EventObject中的source,具體可以是任何數據(包括事件源),用來傳遞數據

      事件監聽器:當事件發生時,負責對事件的處理

      事件環境:整個事件所處的上下文,對整個事件提供支持

SpringApplicationRunListener

  run方法的源代碼如下

/**
 * Run the Spring application, creating and refreshing a new
 * {@link ApplicationContext}.
 * @param args the application arguments (usually passed from a Java main method)
 * @return a running {@link ApplicationContext}
 */
public ConfigurableApplicationContext run(String... args) {
    // 秒錶,用於記錄啟動時間;記錄每個任務的時間,最後會輸出每個任務的總費時
    StopWatch stopWatch = new StopWatch();
    stopWatch.start();
    // spring應用上下文,也就是我們所說的spring根容器
    ConfigurableApplicationContext context = null;
    // 自定義SpringApplication啟動錯誤的回調介面
    Collection<SpringBootExceptionReporter> exceptionReporters = new ArrayList<>();
    // 設置jdk系統屬性java.awt.headless,預設情況為true即開啟;更多java.awt.headless信息大家可以去查閱資料,這不是本文重點
    configureHeadlessProperty();
    // 獲取啟動時監聽器
    SpringApplicationRunListeners listeners = getRunListeners(args)
    // 觸發啟動事件,相應的監聽器會被調用,這是本文重點
    listeners.starting(); 
    try {
        ApplicationArguments applicationArguments = new DefaultApplicationArguments(
                args);
        ConfigurableEnvironment environment = prepareEnvironment(listeners,
                applicationArguments);
        configureIgnoreBeanInfo(environment);
        Banner printedBanner = printBanner(environment);
        context = createApplicationContext();
        exceptionReporters = getSpringFactoriesInstances(
                SpringBootExceptionReporter.class,
                new Class[] { ConfigurableApplicationContext.class }, context);
        prepareContext(context, environment, listeners, applicationArguments,
                printedBanner);
        refreshContext(context);
        afterRefresh(context, applicationArguments);
        stopWatch.stop();
        if (this.logStartupInfo) {
            new StartupInfoLogger(this.mainApplicationClass)
                    .logStarted(getApplicationLog(), stopWatch);
        }
        listeners.started(context);
        callRunners(context, applicationArguments);
    }
    catch (Throwable ex) {
        handleRunFailure(context, ex, exceptionReporters, listeners);
        throw new IllegalStateException(ex);
    }

    try {
        listeners.running(context);
    }
    catch (Throwable ex) {
        handleRunFailure(context, ex, exceptionReporters, null);
        throw new IllegalStateException(ex);
    }
    return context;
}
View Code

  再講今天的主角之前,我們先來看看ConfigurableApplicationContext,從名字來看就是:配置應用上下文,會根據class路徑下的類初始化配置合適的應用上下文,比如是普通的spring應用(非web應用),還是web應用上下文。類圖和類繼承圖如下

  ConfigurableApplicationContext類圖

  ConfigurableApplicationContext類繼承圖

  ConfigurableApplicationContext不會在本文詳解,他的創建會在後續的博文中講到,這裡只是一個提醒。今天的主角是以下兩行代碼

SpringApplicationRunListeners listeners = getRunListeners(args)
listeners.starting();

  我們今天的目的就是看看這兩行代碼到底做了些什麼

getRunListeners

  我們先看看SpringApplicationRunListeners和SpringApplicationRunListener。

    SpringApplicationRunListeners的類註釋很簡單:

      一個存SpringApplicationRunListener的集合,裡面有些方法,後續都會講到;

    SpringApplicationRunListener的介面註釋也簡單:

      監聽SpringApplication的run方法。通過SpringFactoriesLoader載入SpringApplicationRunListener(一個或多個),SpringApplicationRunListener的實現類必須聲明一個接收SpringApplication實例和String[]數組的公有構造方法。

  接下來我們看看getRunListeners方法,源代碼如下

private SpringApplicationRunListeners getRunListeners(String[] args) {
        Class<?>[] types = new Class<?>[] { SpringApplication.class, String[].class };
        return new SpringApplicationRunListeners(logger, getSpringFactoriesInstances(
                SpringApplicationRunListener.class, types, this, args));
    }

  初略來看的話,就是返回一個新的SpringApplicationRunListeners實例對象;

  細看的話,發現有個getSpringFactoriesInstances方法的調用,這個方法大家還記得嗎?(詳情請看spring-boot-2.0.3不一樣系列之源碼篇 - springboot源碼一,絕對有值得你看的地方)getSpringFactoriesInstances在SpringApplication的構造方法中調用了兩次,分別用來設置屬性List<ApplicationContextInitializer<?>> initializers和List<ApplicationListener<?>> listeners。getSpringFactoriesInstances在第一次被調用時會將類路徑下所有的META-INF/spring.factories的文件中的屬性進行載入並緩存到SpringFactoriesLoader的緩存cache中,下次被調用的時候就直接從SpringFactoriesLoader的cache中取數據了。這次就是從SpringFactoriesLoader的cache中取SpringApplicationRunListener類型的類(全限定名),然後實例化後返回。我們來跟下這次getSpringFactoriesInstances獲取的的內容

  EventPublishingRunListener的構造方法中,構造了一個SimpleApplicationEventMulticaster對象,並將SpringApplication的listeners中的全部listener賦值到SimpleApplicationEventMulticaster對象的屬性defaultRetriever(類型是ListenerRetriever)的applicationListeners集合中,如下圖

 

  總的來說,getRunListeners做了什麼事呢?就是獲取SpringApplicationRunListener類型的實例(EventPublishingRunListener對象),並封裝進SpringApplicationRunListeners對象,然後返回這個SpringApplicationRunListeners對象。說的再簡單點,getRunListeners就是準備好了運行時監聽器EventPublishingRunListener。

listeners.starting()

  我們看看starting方法做了些什麼事

  構建了一個ApplicationStartingEvent事件,並將其發佈出去,其中調用了resolveDefaultEventType方法,該方法返回了一個封裝了事件的預設類型(ApplicationStartingEvent)的ResolvableType對象。我們接著往下看,看看這個發佈過程做了些什麼

  multicastEvent

    源代碼如下

@Override
public void multicastEvent(final ApplicationEvent event, @Nullable ResolvableType eventType) {
    ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event));
    for (final ApplicationListener<?> listener : getApplicationListeners(event, type)) {
        Executor executor = getTaskExecutor();
        if (executor != null) {
            executor.execute(() -> invokeListener(listener, event));
        }
        else {
            invokeListener(listener, event);
        }
    }
}

    初略的看,就是遍歷getApplicationListeners(event, type),然後對每個listener進行invokeListener(listener, event)

  getApplicationListeners

    根據其註釋可知,該方法作用:返回與給定事件類型匹配的ApplicationListeners集合,非匹配的偵聽器會被提前排除;允許根據緩存的匹配結果來返回。

    從上圖可知,主要涉及到3個點:緩存retrieverCache、retrieveApplicationListeners已經retrieveApplicationListeners中調用的supportsEvent方法。流程是這樣的:

      1、緩存中是否有匹配的結果,有則返回

      2、若緩存中沒有匹配的結果,則從this.defaultRetriever.applicationListeners中過濾,這個this表示的EventPublishingRunListener對象的屬性initialMulticaster(也就是SimpleApplicationEventMulticaster對象,而defaultRetriever.applicationListeners的值也是在EventPublishingRunListener構造方法中初始化的

      3、過濾過程,遍歷defaultRetriever.applicationListeners集合,從中找出ApplicationStartingEvent匹配的listener,具體的匹配規則需要看各個listener的supportsEventType方法(有兩個重載的方法)

      4、將過濾的結果緩存到retrieverCache

      5、將過濾出的結果返回回去

    我們看看,過濾出的listener對象有哪些

  invokeListener

    其註釋:使用給定的事件調用給定的監聽器

    getApplicationListeners方法過濾出的監聽器都會被調用,過濾出來的監聽器包括LoggingApplicationListener、BackgroundPreinitializer、DelegatingApplicationListener、LiquibaseServiceLocatorApplicationListener、EnableEncryptablePropertiesBeanFactoryPostProcessor五種類型的對象。這五個對象的onApplicationEvent都會被調用。

    那麼這五個監聽器的onApplicationEvent都做了些什麼了,我這裡大概說下,細節的話大家自行去跟源碼

      LoggingApplicationListener:初始化日誌系統,預設是logback,支持3種,優先順序從高到低:logback > log4j > javalog

      BackgroundPreinitializer:另起一個線程實例化Initializer並調用其run方法,包括驗證器、消息轉換器等等

      DelegatingApplicationListener:此時什麼也沒做

      LiquibaseServiceLocatorApplicationListener:此時什麼也沒做

      EnableEncryptablePropertiesBeanFactoryPostProcessor:僅僅列印了一句日誌,其他什麼也沒做

總結

  事件機制要素

    這裡和大家一起把事件4要素找出來

    事件源:SpringApplication

    事件:ApplicationStartingEvent

    監聽器:過濾後的監聽器,具體5個上文中已經說過

    事件環境:EventPublishingListener,提供環境支持事件,並且發佈事件(starting方法)

  監聽器數量

    項目中集成的功能的多少的不同,從spring.factories載入的屬性數量也不同,自然監聽器數量也會有所不同;如果大家看源碼的時候發現比我的多或者少,不要驚慌,這是很正常的,因為我們集成的功能有所差別。

  友情提醒

    博文中有些地方分析的不是特別細,需要大家自行去跟源碼,沒涉及到複雜的模式,相信大家也都能看懂。過濾監聽器的時候用到了supportsEvent方法,這個方法裡面涉及到了適配器模式,改天我結合session共用給大家分析下適配器模式。

  高光時刻

    有時候,不是對手有多強大,只是我們不敢去嘗試;勇敢踏出第一步,你會發現自己比想象中更優秀!誠如海因斯第一次跑進人類10s大關時所說:上帝啊,原來那扇門是虛掩著的!

參考

  springboot源碼


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

-Advertisement-
Play Games
更多相關文章
  • 引用: JavaScript Cookie - by runoob.com Cookie是儲存在電腦文本文件中的數據,用於保存訪問者的信息,並可以在下次打開頁面時引用。 頁面在設置/引用訪問者信息時,需要在JavaScript中對Cookie進行設置,獲取和檢索三個函數。 例如當訪問者首次訪問網頁時 ...
  • nodejs 簡單的封裝一些mysql模塊 實現一個方法根據不同傳參進行增刪改查 首先要 npm install mysql 代碼如下 傳入參數如下 objHost 資料庫的基本信息如下 sql 就是sql語句 添加 修改 刪除 查找 callback回調 操作完成後拿到數據的回調 add 在添加時 ...
  • JavaScript有兩種數據類型,基礎數據類型和引用數據類型。基礎數據類型都是按值訪問的,我們可以直接操作保存在變數中的實際的值。而引用類型如Array,我們不能直接操作對象的堆記憶體空間。引用類型的值都是按引用訪問的,即保存在變數對象中的一個地址,該地址與堆記憶體的實際值相關聯。 一、深拷貝和淺拷貝 ...
  • 閱讀目錄 為什麼需要事務 事務的來源 分散式系統中的事務問題 分散式事務的解決方案 結語 暫時還未涉及的園友們,可以收藏防身哦~ 為什麼需要事務 事務的來源 分散式系統中的事務問題 分散式事務的解決方案 結語 暫時還未涉及的園友們,可以收藏防身哦~ 為什麼需要事務 事務的來源 分散式系統中的事務問題 ...
  • 一、引言 .Net技術棧目前還沒有像spring cloud相對完整一整微服務架構棧,隨著業務發展系統架構演進,自行構建.Net技術體系的微服務架構,配套相關核心組件。因平臺基於微服務架構方式研發,每個領域服務遵循平臺統一標準,各自研發,獨立部署運行,服務運行日誌均通過記錄本地文件方式進行記錄。程式 ...
  • 先做一個對比: 對比點 Storm Spark Streaming 實時計算模型 純實時,來一條數據,處理一條數據 準實時,對一個時間段內的數據收集起來,作為一個RDD,再處理 實時計算延遲度 毫秒級 秒級 吞吐量 低 高 事務機制 支持完善 支持,但不夠完善 健壯性 / 容錯性 ZooKeeper ...
  • 最近與同仁講一個簡單的功能,我們過去的項目或系統可能開發過很多次了,當下需要反思軟體設計怎麼才能做得更好,這樣我們自己才能成長。如果軟體設計都做不好,更做不好軟體架構。 如果你重覆一次又一次在做與過去相同的東西,有沒有意義? 沒有成長,等於浪費時間。現在產品經理都需要關註用戶增長的設計了,思考你如何... ...
  • 一、虛擬機與Linux系統 利用linux鏡像新建虛擬機 建立虛擬機 安裝成功 1.ping主機可達 2.ifconfig查看網路狀態 3.創建一個用戶,並將其納入root組,然後將用戶刪除 創建用戶 納入root組 刪除用戶 4.創建文件夾,文件夾中創建一些文件,將文件夾打包,最後解包到另一個文件 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...