在Spring Boot的入口类中,我们通常是通过调用SpringApplication
的run方法来启动Spring Boot项目。这节我们来深入学习下SpringApplication的一些细节。
自定义SpringApplication
默认的我们都是直接通过SpringApplication
的run方法来直接启动Spring Boot,其实我们可以通过一些API来调整某些行为。
通过SpringApplication API调整
我们新建一个SpringBoot项目,Spring Boot版本为2.1.0.RELEASE,artifactId
为SpringApplication,并引入spring-boot-starter-web
依赖。项目结构如下所示:
我们将入口类的代码改为:
SpringApplication application = new SpringApplication(DemoApplication.class);
application.setBannerMode(Banner.Mode.OFF);
application.setWebApplicationType(WebApplicationType.NONE);
application.setAdditionalProfiles("dev");
application.run(args);
通过调用SpringApplication
的方法,我们关闭了Banner的打印,设置应用环境为非WEB应用,profiles指定为dev。除此之外,SpringApplication
还包含了许多别的方法,具体可以查看源码或者官方文档:
通过SpringApplicationBuilder API调整
SpringApplicationBuilder
提供了Fluent API,可以实现链式调用,下面的代码和上面的效果一致,但在编写上较为方便:
new SpringApplicationBuilder(DemoApplication.class)
.bannerMode(Banner.Mode.OFF)
.web(WebApplicationType.NONE)
.profiles("dev")
.run(args);
SpringApplication准备阶段
SpringApplication
的生命周期阶段大致可以分为准备阶段和运行阶段。
我们通过源码来查看SpringApplication
的有参构造器:
通过有参构造器里的代码我们可以将SpringApplication
的准备阶段分为以下几个步骤:
配置源
构造器中this.primarySources = new LinkedHashSet<>(Arrays.asList(primarySources));
这行代码用于加载我们配置的Spring Boot Bean源。通常我们使用SpringApplication
或者SpringApplicationBuilder
的构造器来直接指定源。
所谓的Spring Boot Bean源指的是某个被**@SpringBootApplication**
注解标注的类,比如入口类:
我们也可以将上面的代码改为下面这种方式:
public class DemoApplication {
public static void main(String[] args) {
SpringApplication application = new SpringApplication(ApplicationResource.class);
application.run(args);
}
@SpringBootApplication
public static class ApplicationResource {
}
}
这样也是可行的。查看SpringApplication
的单个参数构造器:
说明我们除了配置单个源外,还可以配置多个源。
推断应用类型
构造器中这行this.webApplicationType = WebApplicationType.deduceFromClasspath();
代码用于推断当前Spring Boot应用类型。
Spring Boot 2.0后,应用可以分为下面三种类型:
WebApplicationType.NONE
:非WEB类型;WebApplicationType.REACTIVE
:Web Reactive类型;(响应式Web项目(WebFlux),非阻塞)WebApplicationType.SERVLET
:Web Servlet类型。(传统 MVC Web项目,阻塞)
WebApplicationType.deduceFromClasspath()
方法根据当前应用ClassPath中是否存在相关的实现类来判断应用类型到底是哪个,deduceFromClasspath
方法的源码如下所示:
我们也可以直接通过SpringApplication
的setWebApplicationType
方法或者SpringApplicationBuilder
的web
方法来指定当前应用的类型。
加载应用上下文初始器
接着下一行代码setInitializers((Collection) getSpringFactoriesInstances(ApplicationContextInitializer.class));
用于加载应用上下文初始器ApplicationContextInitializer
。
getSpringFactoriesInstances
方法的源码如下所示:
上面代码利用Spring工厂加载机制,实例化ApplicationContextInitializer
实现类,并进行排序。
所以我们可以通过实现**ApplicationContextInitializer**
接口用于在Spring Boot应用初始化之前执行一些自定义操作。
举个例子,在com.example.demo
下新建initializer
包,然后创建一个HelloApplicationContextInitializer
类,实现ApplicationContextInitializer
接口:
@Order(Ordered.HIGHEST_PRECEDENCE)
public class HelloApplicationContextInitializer implements ApplicationContextInitializer {
@Override
public void initialize(ConfigurableApplicationContext applicationContext) {
System.out.println("ConfigurableApplicationContext.id - " + applicationContext.getId());
}
}
上面代码中实现了initialize方法,并且使用@Order
注解指定优先级。其中Ordered.HIGHEST_PRECEDENCE
等于Integer.MIN_VALUE
,Ordered.LOWEST_PRECEDENCE
等于Integer.MAX_VALUE
。所以数值越小,优先级越高。
除了使用@Order
注解来指定优先级外,我们也可以通过实现org.springframework.core.Ordered
接口的getOrder
方法来指定优先级。
接着我们来创建一个优先级比HelloApplicationContextInitializer
低的Initializer —— AfterHelloApplicationContextInitializer
:
public class AfterHelloApplicationContextInitializer implements ApplicationContextInitializer, Ordered {
@Override
public void initialize(ConfigurableApplicationContext applicationContext) {
System.out.println("AfterHelloApplicationContextInitializer: " + applicationContext.getId());
}
@Override
public int getOrder() {
return Ordered.LOWEST_PRECEDENCE;
}
}
上面通过getOrder
方法来指定了优先级为最低优先级。
创建好后,我们还需在工厂配置文件里配置这两个实现类。在resources目录下新建META-INF目录,并创建spring.factories文件:
# Initializers
org.springframework.context.ApplicationContextInitializer=\
com.example.demo.initializer.HelloApplicationContextInitializer,\
com.example.demo.initializer.AfterHelloApplicationContextInitializer
这时候,启动Spring Boot项目,会发现控制台在打印Banner后就执行了这两个初始化器,并且HelloApplicationContextInitializer
的initialize
方法执行时机先于AfterHelloApplicationContextInitializer
的initialize
方法:
加载应用事件监听器
在加载完应用上下文初始器后,下一行的setListeners((Collection) getSpringFactoriesInstances(ApplicationListener.class));
代码加载了应用事件监听器。与加载事件上下文初始器类似,Spring Boot也是通过Spring的工厂方法来实例化ApplicationListener
的实现类,并进行排序。
既然是事件监听,那么其可以监听什么事件呢?其监听的是**ApplicationEvent**
接口的实现类,我们查看一下都有哪些事件实现了这个接口:
这里我们以ContextClosedEvent
为例子来编写自定义的应用事件监听器,监听Spring上下文关闭事件。
在com.example.demo
下新建listener
包,然后创建一个ContextClosedEventListener
类,实现ApplicationListener
接口:
@Order(Ordered.HIGHEST_PRECEDENCE)
public class ContextClosedEventListener implements ApplicationListener<ContextClosedEvent> {
@Override
public void onApplicationEvent(ContextClosedEvent event) {
System.out.println("ContextClosedEvent: " + event.getApplicationContext().getId());
}
}
上面代码实现了对ContextClosedEvent
事件的监听,并且分配了最高优先级。
接着创建一个优先级比ContextClosedEventListener
低的监听器AfterContextClosedEventListener
:
public class AfterContextClosedEventListener implements ApplicationListener<ContextClosedEvent>, Ordered {
@Override
public void onApplicationEvent(ContextClosedEvent event) {
System.out.println("AfterContextClosedEventr: " + event.getApplicationContext().getId());
}
@Override
public int getOrder() {
return Ordered.HIGHEST_PRECEDENCE + 1;
}
}
最后,别忘了在Spring工厂配置文件里进行配置:
# Application Listeners
org.springframework.context.ApplicationListener=\
com.example.demo.listener.ContextClosedEventListener,\
com.example.demo.listener.AfterContextClosedEventListener
在Spring Boot入口类中将环境指定为非WEB环境(这样在启动后应用会马上关闭):
new SpringApplicationBuilder(DemoApplication.class)
.web(WebApplicationType.NONE)
.run(args);
运行Spring Boot入口类,控制台输出如下:
推断入口类
接着构造器里的代码下一行this.mainApplicationClass = deduceMainApplicationClass();
用于推断运行Spring Boot应用的入口类。查看deduceMainApplicationClass
方法源码:
代码主要逻辑是根据Main线程执行堆栈判断实际的入口类。
准备阶段介绍完毕后,接下来开始介绍运行阶段。
SpringApplication运行阶段
SpringApplication的运行阶段对应SpringApplication
的run
方法,我们查看其源码:
public ConfigurableApplicationContext run(String... args) {
StopWatch stopWatch = new StopWatch();
stopWatch.start();
ConfigurableApplicationContext context = null;
Collection<SpringBootExceptionReporter> exceptionReporters = new ArrayList<>();
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;
}
运行阶段大致可以分为下面这几个过程:
开启时间监听
run
方法开头的这两行代码用于开启时间监听:
StopWatch stopWatch = new StopWatch();
stopWatch.start();
上面代码用于开启Spring Boot应用启动时间监听,配合下面的stopWatch.stop();
便可以计算出完整的启动时间。
开启运行监听器
run
方法的这几行代码用于加载Spring应用运行监听器(SpringApplicationRunListener):
SpringApplicationRunListeners listeners = getRunListeners(args);
listeners.started();
getRunListeners
方法源码:
private SpringApplicationRunListeners getRunListeners(String[] args) {
Class<?>[] types = new Class<?>[] { SpringApplication.class, String[].class };
return new SpringApplicationRunListeners(logger, getSpringFactoriesInstances(
SpringApplicationRunListener.class, types, this, args));
}
上面代码通过SpringFactoriesLoader
检索META-INF/spring.factories找到声明的所有SpringApplicationRunListener
的实现类并将其实例化,然后装配到List<SpringApplicationRunListener>
运行监听器集合中。
listeners.started();
用于遍历运行监听器集合中的所有SpringApplicationRunListener
的实现类,并逐一调用它们的starting
方法,广播Spring Boot应用要开始启动了。
在Spring Boot中**SpringApplicationRunListener**
接口用于监听整个Spring Boot应用生命周期,其代码如下所示:
public interface SpringApplicationRunListener {
void starting();
void environmentPrepared(ConfigurableEnvironment environment);
void contextPrepared(ConfigurableApplicationContext context);
void contextLoaded(ConfigurableApplicationContext context);
void started(ConfigurableApplicationContext context);
void running(ConfigurableApplicationContext context);
void failed(ConfigurableApplicationContext context, Throwable exception);
}
这些方法对应着Spring Boot应用生命周期的各个阶段:
方法名称 | 对应生命周期 | Spring Boot起始版本 |
---|---|---|
starting() | Spring 应用刚启动 | 1.0 |
environmentPrepared(ConfigurableEnvironment) | ConfigurableEnvironment 准备完毕,允许将其调整 | 1.0 |
contextPrepared(ConfigurableApplicationContext) | ConfigurableApplicationContext 准备完毕,允许将其调整 | 1.0 |
contextLoaded(ConfigurableApplicationContext) | ConfigurableApplicationContext 已装载,但仍未启动 | 1.0 |
started(ConfigurableApplicationContext) | ConfigurableApplicationContext 已启动,此时 Spring Bean 已初始化完成 | 2.0 |
running(ConfigurableApplicationContext) | Spring 应用正在运行 | 2.0 |
failed(ConfigurableApplicationContext,Throwable) | Spring 应用运行失败 | 2.0 |
我们在com.example.demo.linstener
下自定义一个SpringApplicationRunListener
接口实现类HelloSpringApplicationRunListener
:
public class HelloApplicationRunListener implements SpringApplicationRunListener {
public HelloApplicationRunListener(SpringApplication application, String[] args) {
}
@Override
public void starting() {
System.out.println("HelloApplicationRunListener starting......");
}
@Override
public void environmentPrepared(ConfigurableEnvironment environment) {
}
@Override
public void contextPrepared(ConfigurableApplicationContext context) {
}
@Override
public void contextLoaded(ConfigurableApplicationContext context) {
}
@Override
public void started(ConfigurableApplicationContext context) {
}
@Override
public void running(ConfigurableApplicationContext context) {
}
@Override
public void failed(ConfigurableApplicationContext context, Throwable exception) {
}
}
通过这个实现类,我们可以在Spring Boot应用刚启动的时候在控制台输出HelloApplicationRunListener starting......
。
因为其基于Spring的工厂方法来实现,所以我们需要在spring.factories文件里配置这个实现类:
# Run Listeners
org.springframework.boot.SpringApplicationRunListener=\
com.example.demo.run.HelloApplicationRunListener
启动Spring Boot应用便可以在控制台看到如下输出了:
创建 Environment
run
方法中的这行代码用于创建并配置当前SpringBoot应用将要使用的Environment(包括配置要使用的PropertySource以及Profile):
ConfigurableEnvironment environment = prepareEnvironment(listeners, applicationArguments);
我们已经在准备阶段里推断出了应用类型,这里只要根据相应的应用类型来创建相应的应用环境即可,类型和环境对应关系如下:
- Web Reactive: StandardReactiveWebEnvironment
- Web Servlet: StandardServletEnvironment
- 非 Web: StandardEnvironment
在prepareEnvironment
方法中会执行listeners.environmentPrepared(environment);
,用于遍历调用所有SpringApplicationRunListener
实现类的environmentPrepared()
方法,广播Environment准备完毕。
是否打印Banner
run
方法中的这行代码会根据我们的配置来决定是否打印Banner:
Banner printedBanner = printBanner(environment);
创建Context
run
方法中的这行代码用于创建ApplicationContext
:
context = createApplicationContext();
不同的环境对应不同的ApplicationContext
:
- Web Reactive: AnnotationConfigReactiveWebServerApplicationContext
- Web Servlet: AnnotationConfigServletWebServerApplicationContext
- 非 Web: AnnotationConfigApplicationContext
装配Context
run
方法中的这行代码用于装配Context:
prepareContext(context, environment, listeners, applicationArguments, printedBanner);
方法prepareContext
的源码如下所示:
private void prepareContext(ConfigurableApplicationContext context,
ConfigurableEnvironment environment, SpringApplicationRunListeners listeners,
ApplicationArguments applicationArguments, Banner printedBanner) {
context.setEnvironment(environment);
postProcessApplicationContext(context);
applyInitializers(context);
listeners.contextPrepared(context);
if (this.logStartupInfo) {
logStartupInfo(context.getParent() == null);
logStartupProfileInfo(context);
}
// Add boot specific singleton beans
ConfigurableListableBeanFactory beanFactory = context.getBeanFactory();
beanFactory.registerSingleton("springApplicationArguments", applicationArguments);
if (printedBanner != null) {
beanFactory.registerSingleton("springBootBanner", printedBanner);
}
if (beanFactory instanceof DefaultListableBeanFactory) {
((DefaultListableBeanFactory) beanFactory)
.setAllowBeanDefinitionOverriding(this.allowBeanDefinitionOverriding);
}
// Load the sources
Set<Object> sources = getAllSources();
Assert.notEmpty(sources, "Sources must not be empty");
load(context, sources.toArray(new Object[0]));
listeners.contextLoaded(context);
}
prepareContext
方法开头为ApplicationContext
加载了environment,之后通过applyInitializers
方法逐个执行ApplicationContextInitializer
的initialize
方法来进一步封装ApplicationContext
,并调用所有的SpringApplicationRunListener
实现类的contextPrepared
方法,广播ApplicationContext已经准备完毕了。
之后初始化IOC容器,并调用SpringApplicationRunListener
实现类的contextLoaded
方法,广播ApplicationContext
加载完成,这里就包括通过@EnableAutoConfiguration
导入的各种自动配置类。
Refresh Context
run
方法中的这行代码用于初始化所有自动配置类,并调用ApplicationContext
的refresh
方法:
refreshContext(context);
广播应用已启动
run
方法中的这行代码用于广播Spring Boot应用已启动:
listeners.started(context);
started
方法会调用所有的SpringApplicationRunListener
的finished
方法,广播SpringBoot应用已经成功启动。
执行Runner
run
方法中的这行代码callRunners(context, applicationArguments);
遍历所有ApplicationRunner
和CommandLineRunner
的实现类,并执行其run
方法。我们可以实现自己的**ApplicationRunner**
或者**CommandLineRunner**
,来对Spring Boot的启动过程进行扩展。
我们在com.example.demo
下新建runner
包,然后创建一个ApplicationRunner
的实现类HelloApplicationRunner
:
@Component
public class HelloApplicationRunner implements ApplicationRunner {
@Override
public void run(ApplicationArguments args) {
System.out.println("HelloApplicationRunner: hello spring boot");
}
}
这里我们需要将HelloApplicationRunner
使用@Component
注解标注,让其注册到IOC容器中。
然后再创建一个CommandLineRunner
的实现类HelloCommandLineRunner
:
@Component
public class HelloCommandLineRunner implements CommandLineRunner {
@Override
public void run(String... args) {
System.out.println("HelloCommandLineRunner: hello spring boot");
}
}
启动Spring Boot应用,便可以在应用刚启动好后看到如下输出:
广播应用运行中
run
方法中的这行代码listeners.running(context);
用于调用SpringApplicationRunListener
的running
方法,广播Spring Boot应用正在运行中。
当run
方法运行出现异常时,便会调用handleRunFailure
方法来处理异常,该方法里会通过listeners.failed(context, exception);
来调用SpringApplicationRunListener
的failed
方法,广播应用启动失败,并将异常扩散出去。
上面所有的广播事件都是使用Spring的应用事件广播器接口
ApplicationEventMulticaster
的实现类SimpleApplicationEventMulticaster
来进行广播的。