WebServer 初始化过程

在上一节中 Spring Boot 初始化了 WebServer 对应的工厂类。同时，我们也知道对应 Web容器的WebServer实现类有:TomcatWebServer、JettyWebServer和UndertowWebServer。

这节重点讲解这些 WebServer 是如何被初始化，又如何启动的。

WebServer 接口的源代码如下。

public interface WebServer {
void start() throws WebServerException;
void stop() throws WebServerException;int getPort();
}

接口定义了 3 个方法: start 方 法为启动容器，stop 方 法为停止容器,getPort 方法为获得容器端口。

现在以 Tomcat 的启动为例来说明整个内置容器的加载与启动。在上节中，工厂类已经被自动配置初始化。那么，在什么地方用到它们的呢?这要回到最初 Spring Boot 启动的过程中。

还记得 SpringApplication 的 run 方法中有一个调用初始化容器的方法 refreshContext 吗?

我们就从这个方法开始追踪。

public ConfigurableApplicationContext run(String... args) {
try {
//初始化容器
refreshContext(context);
} catch (Throwable ex) {
}

在 run 方法中调用了 refreshContext 方法，refreshContext 方法中又调用了refresh 方法。

private void refreshContext(ConfigurableApplicationContext context) {
//调用 refresh 方法
refresh(context);
refresh 方法的代码如下。
protected void refresh(ApplicationContext applicationContext) {
Assert. isInstanceOf(AbstractApplicat ionContext. class, applicationContext);
((AbstractApplicationContext) applicationContext).refresh();
}

通过 refresh 方法我们能看到什么呢?对的，就是
AbstractApplicationContext 这个抽象类，该类的实例化对象在调用 refreshContext 方法之前，已经通过 createApplicationContext 方法进行实例化了。createApplicationContext 方法的源代码如下。

protected ConfigurableApplicat ionContext createApplicationContext() {
//首先获取容器的类变量
Class<?> contextClass = this . applicat ionContextClass;
/如果为 null,则根据 web 应用类型按照默认类进行创建
if (contextClass == null) {
try
witch (this . webApplicat ionType) {
contextClass = Class . forName(DEFAULT_ _SERVLET _WEB_ _CONTEXT_ CLASS);
break;
case REACTIVE:contextClass = Class . forName (DEFAULT_ REACTIVE_ WEB_ CONTEXT_ CLASS);
break;
default:
contextClass = Class . forName (DEFAULT CONTEXT. CLASS);
}catch (ClassNotFoundException ex) {
如果存在对应的 Class 配置，则通过 Spring 提 供的 BeanUtils 来进行实例化 return
(ConfigurableApplicationContext) BeanUtils. instantiateClass(contextClass);
}
}
}

ServletWeb 项目默认会实例化 DEFAULT_ _SERVLET_ WEB_ _CONTEXT _CLASS 常量指定的
org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext 类。

在 refresh 方法中调用的
AbstractApplicationContext 的 refresh 方法就是这个常量配置的类的 refresh 方法但 AnnotationConfigServletWebServerApplicationContext 方法内并没有该refresh 方法，该方法定义在它的父类 ServletWebServerApplicationContext 中。

@Override
public final void refresh() throws BeansException, IllegalStateException
try {
super . refresh();
} catch (RuntimeException ex) {
stopAndReleaseWebServer();
throw ex;
}
}

ServletWebServerApplicationContext 的 refresh 方 法 仅 调 用 了 父 类AbstractApplication-Context 中的 refresh 方法。AbstractApplicationContext 中的 refresh方法的代码如下。

@Override
public void refresh() throws BeansException, IllegalStateException {
synchronized (this . startupShutdownMonitor)
try {
...
onRefresh();
}catch (BeansException ex) {
}

忽略掉 refresh 方法中的其他方法，我们重点了解下其调用的 onRefresh 方法。

protected void onRefresh() throws BeansException {
//为子类提供，默认不做任何操作
我们发现这个 onRefresh 方法默认是空的，待其子类来实现。也就是说，该方法真正的实现又回到了它的子类 ServletWebServerApplicationContext 中。
@Override
protected void onRefresh() {
super . onRefresh();
try {
createWebServer();
} catch (Throwable ex){
throw new ApplicationContextException("Unable to start web server", e
x);
}

经过一路的代码跟踪，终于回到重点方法: createWebServer 方法。

private void createWebServer() {
WebServer webServer = this . webServer;
ServletContext servletContext = getServletContext();
if (webServer == null && servletContext == null) {
ServletwebServerFactory factory = getWebServerFactory();
this . webServer = factory . getWebServer(getSelfInitializer());
} else if (servletContext != null) {
initPropertySources();
}
}

在
ServletWebServerApplicationContext 的 createWebServer 方 法 中 ， 初 始 化 时 默 认web-Server 和 servletContext 都为 null,因此直接进入第一个 if 判断中的业务逻辑。看一下get-WebServerFactory 都做 了些什么。

protected ServletWebServerFactory getWebServerFactory() {
//使用 Bean name 数组的好处是可以不用考虑层级关系
String[] beanNames = getBeanF actory() . getBeanNamesForType(ServletWebServe
r-
Factory.class);
if (beanNames.length == 0) {
throw new ApplicationContextException("Unable to start ServletWebServe-
rApplicationContext due to missin
g" +"ServletWebServerFactory bean.");
if (beanNames . length > 1) {
throw new ApplicationContextExc
eption("Unable to start ServletwebServer-
ApplicationContext due to multiple”+ "ServletWebServerFactory beans :”+StringUtils.arrayToCommaDelimitedString(beanNames));
}
return getBeanFactory(). getBean(beanNames[0], ServletWebServerFactory.class);
}

getWebServerFactory 方法中通过 BeanFactory 获得类型为 ServletWebServerFactory 类的 beanNames 数组，然后判断数组长度。当 beanNames 长度为 0 时，说明容器中没有对应的 Bean 存在，则抛出异常;当 beanNames 长度大于 1 时，说明存在多个对应的 Bean,也就是说有可能同时存在多个 Web 容器的工厂方法，同样抛出异常;只有 beanNames 长度等于 1 时，说明恰好存在一个对应的 Bean, 才会获取对应的 Bean 并返回。

如果一层层向上追溯
TomcatServletWebServerFactory 的类结构，我们就会发现，它先是继承了抽象类AbstractServletWebServerFactory,而抽象类AbstractServletWebServerFactory 又实现了口 ConfigurableServletWebServerFactory 接口ConfigurableServletWebServer-Factory又继承接口ServletWebServerFactory.这里获得的 ServletWebServerFactory 的具体实现类，正是我们在上一节中通过自动配置实例化的TomcatServletWebServerFactory 对象的 Bean 名称。

当获得 ServletWebServerFactory 之后，便调用了它的 getWebServer 方法，以 Tomcat 为例，其实也就是调用了
TomcatServletWebServerFactory 的 getWebServer 方法。

@Override
public WebServer getWebServer(ServletContextInitializer... initializers)
//内置 Tomcat 包中提供的类
Tomcat tomcat = new Tomcat();
//获取并没置 baseDir 路径，不存在则创建一个 ltomcat 为前缀的临时文件
File baseDir = (this. baseDirectory != null) ? this. baseDirectory
createTempDir("tomcat");
tomcat . setBaseDir(baseDir . getAbsolutePath());
/创建 Connector
Connector connector = new Connector(this . protocol);
tomcat . getService(). addConnector(connector);
// Connector 定制化
customi zeConnector(connector);
tomcat. setConnector( connector);
tomcat. . getHost(). setAutoDeploy(false);
configureEngine(tomcat. getEngine());
for (Connector additionalConnector : this . additionalTomcatConnectors) {
tomcat . getService() . addConnector ( additionalConnector);
prepareContext(tomcat . getHost(), initializers);//创建 omcatWebServer
return getTomcatwebServer(tomcat);
}
}

TomcatServletWebServerFactory 的 getWebServer 方法中实现了 Tomcat 的创建、BaseDir的设置 、Connector 的初始化和定制化等一系 列初始化操作。

至此，上面代码中依旧没有 体现 TomcatServer 的创建和初始化， 不要着急，它们就在getWebServer 方法的最后- -行代码调用的 getTomcatWebServer 方法中。

protected TomcatWebServer getTomcatWebServer (Tomcat tomcat) {
return new TomcatWebServer(tomcat, getPort() >=

getTomcatWebServer 方法的实现很简单，将 getWebServer 中创建的 Tomcat 对象和当前类中 port 值是否大于等于 0 的判断结果作为 TomcatWebServer 构造方法的参数传入，创建 TomcatWebServer 对象。

针 对 getTomcatWebServer 方 法 ， 子 类 可 以 重 写 该 方 法 ， 返 回 一 个 不 同 的Tomcat-WebServer 或者添加针对 Tomcat Server 的一些额外操作。

先看 TomcatWebServer 的构造方法源码。

public class TomcatWebServer implements WebServer {
private final Tomcat tomcat;
private final boolean autoStart;
public TomcatWebServer(Tomcat tomcat, boolean autoStart) {
Assert . notNull(tomcat, "Tomcat Server must not be null");
this. tomcat = tomcat;
this. autoStart = autoStart;
initialize();
}
}

构造方法接收 Tomcat tomcat 和 boolean autoStart 两个参数，并将其赋值给对应的成员变量。其中 Tomcat 参数不能为 null, autoStart 参 数则根据端口是否大于等于 0 来决定是否启动服务。在构造方法的最后，调用了 nitialize 方法来进行初始化操作。

omcatWebServern 的 initialize 方法源代码如下。

public class TomcatWebServer implements WebServer {
private final Tomcat tomcat;
private final boolean autoStart;
private
volatile boolean started;
logger. info("Tomcat initialized with port(s): ”+ getPortsDescription(f
synchronized (this .monitor) {
// 将 实 例 id 添 加 到 tomcat 引 擎 名 字 中 ， 格 式 为 “ 原 引 / 擎 名 字 实 例 id”Contextcontext=findContext():
//添加生命周期的监昕事件
context . addL ifecyclelistener((event) -> {
if (context . equals(event. getSource()) && Lifecycle . START EVENT.
equals(event . getType()))
//移除 connector, 磅保当服务器启动时不会进行协议绑定
})
//启动服务，触发初始化监听
this. tomcat . start();
/可以直接在主线程中重新抛出失败异常， TomcatStarter 不存在或状态错误均
会抛出异常
rethrowDeferredStartupExceptions();
try
/绑定一个命名的 context.到类加载器
(), getClass().getClassLoader());
sLoader(context, context. getNamingToken
catch (NamingException ex)
// 当命名不可用时(抛异常)， 直接跳过并继续
// 与 Jetty 不同， 所有 Tomcat 线程都是守护程序线程。创建一 一个阻止非守护程序
止立即关闭
startDaemonAwaitThread();
} catch (Exception ex) {
stopSilently();
destroySilently();
throw new WebServerException("Unable to start embedded Tomcat", e x）；
}
}}
}

通过以上源代码，可以看出在 TomcatWebServer 的 initialize 方法中做了以下操作:重命名tomcat 弓|擎名称、对 Context 添加生 命周期监听事件、启动服务触发初始化监听、检查TomcatStarter 对象是否存在及 Container 状态是否正确、绑定命名到类加载器、启动守护等待线程等。

至此，针对 Tomcat 的 TomcatWebServer 的初始化已经完成。关于其他 Web 容器的WebServer 初始化操作，读者可仿照本节的思路进行源代码分析，这里不再逐一讲解。

本文给大家讲解的内容是SpringBoot内置Servlet容器源码解析：WebServer初始化过程

1. 下篇文章给大家讲解的是DispatcherServlet的加载过程；
2. 觉得文章不错的朋友可以转发此文关注小编；
3. 感谢大家的支持！