Springboot ApplicationRunner使用

ApplicationRunner介紹

ApplicationRunner是在應(yīng)用容器啟動(dòng)之后會(huì)回調(diào)到，在ApplicationStartedListener調(diào)用之后被調(diào)用。

如果說ApplicationListener中有阻塞，那么ApplicationRunner也都不會(huì)被調(diào)用。

@Component
public class ApplicationRunnerTest implements ApplicationRunner {
    @Override
    public void run(ApplicationArguments args) throws Exception {
        System.out.println(args);
    }
}

我們可以在applicationRunner中做一些異步啟動(dòng)的操作，比如實(shí)例化Kafka客戶端，異步加載緩存等等在服務(wù)啟動(dòng)之后不立馬提供服務(wù)的操作。

通過分析源碼可以知道runner實(shí)在容器加載完成以及ApplicationStartedListener調(diào)用之后進(jìn)行回調(diào)的。

ApplicationRunner為什么不被調(diào)用

問題描述

在項(xiàng)目中寫了一個(gè)ApplicationRunner 來啟動(dòng)消費(fèi)隊(duì)列線程，結(jié)果啟動(dòng)的時(shí)候applicationRunner的run方法死活不被調(diào)用。

問題分析

通過debug發(fā)現(xiàn)，在springboot初始化完環(huán)境refresh context之后就會(huì)調(diào)用started listener然后調(diào)用application runner，如果started listner 存在阻塞的話就會(huì)導(dǎo)致后續(xù)的application runner 不被運(yùn)行。

而我在另一個(gè)組件中使用ApplicationListener<ApplicationStartedEvent> 去啟動(dòng)了netty server，啟動(dòng)netty server會(huì)導(dǎo)致當(dāng)前線程阻塞以至于application runner 不被調(diào)用。

問題解決

在listener和Runner當(dāng)中盡量啟用線程來跑阻塞而不是直接去跑阻塞任務(wù)。

ApplicationRunner的作用是什么？

有時(shí)針對(duì)一些特殊的業(yè)務(wù)場景，需要在系統(tǒng)啟動(dòng)時(shí)執(zhí)行某些任務(wù)，如：配置文件的加載、數(shù)據(jù)庫的初始化等等操作。

SpringBoot 提供了兩種解決方案：

• 一種是使用CommandLineRunner
• 另一種是使用 ApplicationRunner

基本原理

項(xiàng)目在啟動(dòng)時(shí)會(huì)遍歷所有的 ApplicationRunner 的實(shí)現(xiàn)類并調(diào)用其中的 run 方法，如果在系統(tǒng)中有多個(gè) ApplicationRunner的實(shí)現(xiàn)類，可以使用 @Order 注解對(duì)這些實(shí)現(xiàn)類的調(diào)用順序進(jìn)行排序(數(shù)字越小越先執(zhí)行)；run方法的參數(shù)是系統(tǒng)啟動(dòng)時(shí)傳入的參數(shù)，即入口類中main方法的參數(shù)(在調(diào)用SpringApplication.run方法時(shí)傳入到 SpringBoot項(xiàng)目的上下文環(huán)境中)。

如何使用

@Component
@Slf4j
@Order(1)
public class MyApplicationRunner implements ApplicationRunner {
?? ?// ApplicationArguments, 需要區(qū)分選項(xiàng)參數(shù)和非選項(xiàng)參數(shù);
?? ?// 選項(xiàng)參數(shù), 通過ApplicationArguments的getOptionNames()方法獲取所有選項(xiàng)名稱即參數(shù)的KEY, 然后通過 getOptionValues()方法根據(jù)參數(shù)KEY, 獲取實(shí)際值(它會(huì)返回一個(gè)列表字符串), 一般為： --user-name=ROCKY --age=30
?? ?// 非選項(xiàng)參數(shù), 通過ApplicationArguments的getNonOptionArgs()方法獲取一個(gè)參數(shù)值數(shù)組;
? ? @Override
? ? public void run(ApplicationArguments args) throws Exception {
? ? ?? ?// TO DO SOMETHING...
? ? }
}

ApplicationRunner和CommandLineRunner的區(qū)別

@Component
@Slf4j
@Order(1)
public class MyCommandLineRunner implements CommandLineRunner {
? ? @Override
? ? public void run(String... args) throws Exception {
? ? ?? ?// TO DO SOMETHING...
? ? }
}?

ApplicationRunner與CommandLineRunner的主要區(qū)別體現(xiàn)在run方法的參數(shù)上，CommandLineRunner中的run方法的參數(shù)是參數(shù)數(shù)組；ApplicationRunner中的run方法的參數(shù)是ApplicationArguments對(duì)象。

執(zhí)行順序

系統(tǒng)支持創(chuàng)建多個(gè)CommandLineRunner或ApplicationRunner的實(shí)現(xiàn)類，可以使用@Order注解或?qū)崿F(xiàn)Ordered接口，來設(shè)定各個(gè)實(shí)現(xiàn)類的執(zhí)行順序。

選項(xiàng)參數(shù)與非選項(xiàng)參數(shù)

• 選項(xiàng)參數(shù)：可以理解為Spring Boot 提供的參數(shù)格式，以–開頭，使用=分割鍵值對(duì)，如：java -jar XXX.jar --name=ROCKY --age=30 --spring.profiles.active=dev；
• 非選項(xiàng)參數(shù)：不是以–開頭，也沒有設(shè)置值的單一參數(shù)KEY只有值，如：java -jar XXX.jar --name=ROCKY --age=30 --spring.profiles.active=dev 陜西 西安 雁塔區(qū)，其中"陜西 西安 雁塔區(qū)" 就是非選項(xiàng)參數(shù)；
• 系統(tǒng)參數(shù)：-Dxxxx是設(shè)置JAVA運(yùn)行上下文的參數(shù)語法，用于配置一些環(huán)境變量，如：java -jar XXX.jar -Dserver.port=8081 --name=ROCKY --age=30 --spring.profiles.active=dev 陜西 西安 雁塔區(qū)，其中"-Dserver.port"就是系統(tǒng)參數(shù)。

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

最新評(píng)論