博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
tomcat源码分析-Container初始化与加载
阅读量:6693 次
发布时间:2019-06-25

本文共 12460 字,大约阅读时间需要 41 分钟。

hot3.png

    我们谈到tomcat时,第一印象是它是一种servlet容器,这个概念是相当抽象和本质的,我们仍然对tomcat的内幕很陌生。我们知道,tomcat由Connector和Container两大组件构成,Connector在前面的文章已经介绍过了,今天我们就来看看Container是怎么回事。

 

一、Container基本结构

    前文中有讲到,Connector和Container的初始化工作是由Digester解析conf/server.xml来完成的,而在server.xml中已经告诉了我们Container的基本结构。我们先来看看server.xml文件:

 

 通过xml文件,我们可以很清晰的看到,Server下包含了Service(可有多个),Service下包含了Connector和Engine,其实还可以包含Executor(线程池)。Engine正是与Connector处在同一水平的容器,Engine下面有Host,下面给出tomcat模块组成图。

 

前面在模拟tomcat连接器时,正是将servlet容器的实例作为参数传入到连接器的setContainer()方法中,这样连接器才能调用servlet容器的invoke()方法。 

 

    接下来给出一张大众化的Container组件结构图。

 通过代码可以知道,tomcat提供了一个Container接口来抽象容器,并且细分了4种类型的容器,分别是Engine、Host、Context和Wrapper,对应不同的概念层次。

 

· Engine:表示整个Catalina的servlet引擎

· Host:表示一个拥有数个上下文的虚拟主机

· Context:表示一个Web应用,一个context包含一个或多个wrapper

· Wrapper:表示一个独立的servlet 

Engine是顶层容器,java程序能够运行是因为有引擎即jvm,很自然的,Engine正是可以配置jvm(jvmRoute="jvm1")。Host是Engine的子容器,Context是Host的子容器,Wrapper是Context的子容器,这4个接口的标准实现分别是StandardEngine、StandardHost、StandardContext、StandardWrapper,她们都在org.apache.catalina.core包类,分析tomcat容器正式主要分析这4个类。下图展示了Container接口及其子接口和实现类的UML类图。

 

通过上面的两个图,我们知道了Container的结构,那么Container的初始化工作是怎么完成的呢?

 

二、Container初始化

    回到Catalina类中,在load方法中调用了createStartDigester方法。

 

/**     * Create and configure the Digester we will be using for startup.     */    protected Digester createStartDigester() {        Digester digester = new Digester();        // Initialize the digester        // Configure the actions we will be using        // 如果遇到”Server“元素起始符;则创建"org.apache.catalina.core.StandardServ        // er"的一个实例对象,并压入堆栈;如果"Server"元素的"className"属性存在,那么用        // 这个属性的值所指定的class来创建实例对象,并压入堆栈。        digester.addObjectCreate("Server",                                 "org.apache.catalina.core.StandardServer",                                 "className");        // 从server.xml读取"Server"元素的所有{属性:值}配对,用对应的Setter方法将属性值        // 设置到堆栈顶层元素(Server)。        digester.addSetProperties("Server");        digester.addSetNext("Server",                            "setServer",                            "org.apache.catalina.Server");        digester.addObjectCreate("Server/Service",                                 "org.apache.catalina.core.StandardService",                                 "className");        digester.addSetProperties("Server/Service");        digester.addSetNext("Server/Service",                            "addService",                            "org.apache.catalina.Service");        digester.addObjectCreate("Server/Service/Listener",                                 null, // MUST be specified in the element                                 "className");        digester.addSetProperties("Server/Service/Listener");        digester.addSetNext("Server/Service/Listener",                            "addLifecycleListener",                            "org.apache.catalina.LifecycleListener");        //Executor        //Connector        // Add RuleSets for nested elements        digester.addRuleSet(new NamingRuleSet("Server/GlobalNamingResources/"));        digester.addRuleSet(new EngineRuleSet("Server/Service/"));        digester.addRuleSet(new HostRuleSet("Server/Service/Engine/"));        digester.addRuleSet(new ContextRuleSet("Server/Service/Engine/Host/"));        addClusterRuleSet(digester, "Server/Service/Engine/Host/Cluster/");        digester.addRuleSet(new NamingRuleSet("Server/Service/Engine/Host/Context/"));        // When the 'engine' is found, set the parentClassLoader.        digester.addRule("Server/Service/Engine",                         new SetParentClassLoaderRule(parentClassLoader));        addClusterRuleSet(digester, "Server/Service/Engine/Cluster/");        return (digester);    }

    从简化的源码中可以看到,digester对server.xml设置的标签动作有5种调用:

 

  •     addObjectCreate:遇到起始标签的元素,初始化一个实例对象入栈
  •     addSetProperties:遇到某个属性名,使用setter来赋值
  •     addSetNext:遇到结束标签的元素,调用相应的方法
  •     addRule:调用rule的begin 、body、end、finish方法来解析xml,入栈和出栈给对象赋值
  •     addRuleSet:调用addRuleInstances来解析xml标签

    从这些规则和xml中可以看到,Calatina的Server对象是StandardServer。StandardService包含了多个Connector(xml中有2个connector)和一个StandardEngine Container。StandardEngine包含了一个Host Container。

 

三、Context容器加载web服务与热部署

    从confg/server.xml中我们可以看到Server的容器的初始化只有Engine和Host,那么Context是什么时候初始化的呢,是怎么加载我们的web application,怎么实现的热部署呢?

    先说结论,tomcat的Engine会启动一个线程,该线程每10s会发送一个事件,监听到该事件的部署配置类会自动去扫描webapp文件夹下的war包,将其加载成一个Context,即启动一个web服务。

    OK,回过头看conf/server.xml和createStartDigester,添加了HostRuleSet,进入HostRuleSet类中,可以看到这么一行代码:

 

digester.addRule(prefix + "Host", new LifecycleListenerRule              ("org.apache.catalina.startup.HostConfig", "hostConfigClass"));

    继续进入LifecycleListenerRule类可以发现,在监听事件中增加了HostConfig类的对象,也就是StandardHost中新增了一个HostConfig监听器。再回过头来进入StandardEngine的starInternal方法super.startInternal(父类ContainerBase)中有这行代码:

    threadStart();

进入后发现开启了一个线程,调用ContainerBackgroundProcessor这个的run方法,而这个run方法可以看到,

 

protected class ContainerBackgroundProcessor implements Runnable {    @Override    public void run() {        //        try {            while (!threadDone) {                try {                    Thread.sleep(backgroundProcessorDelay * 1000L);//在StandardEngine中构造方法设置默认backgroundProcessorDelay=10,即10s调用一次                } catch (InterruptedException e) {                    // Ignore                }                if (!threadDone) {                    //                    processChildren(parent, cl);                }            }        }         //    }}

也就是说该线程每10s会调用一次processChildren,继续跟踪该方法,会看到调用Engine、Host、Context、Wrapper各容器组件及与它们相关的其它组件的backgroundProcess方法。

 

@Overridepublic void backgroundProcess() {    if (loader != null) {        try {            loader.backgroundProcess();        } catch (Exception e) {            log.warn(sm.getString("containerBase.backgroundProcess.loader", loader), e);                        }    }    //    fireLifecycleEvent(Lifecycle.PERIODIC_EVENT, null);}

这个方法中比较重要的两个

loader.backgroundProcess():调用了载入器的WebappLoader的backgroundProcess方法,进入这个方法可以看到:

 

public void backgroundProcess() {    if (reloadable && modified()) {        try {            Thread.currentThread().setContextClassLoader                (WebappLoader.class.getClassLoader());            if (container instanceof StandardContext) {                ((StandardContext) container).reload();            }        } finally {            if (container.getLoader() != null) {                Thread.currentThread().setContextClassLoader                    (container.getLoader().getClassLoader());            }        }    } else {        closeJARs(false);    }}

看判断条件reloadable和modified(),reloadable即为是否开启热部署,而modified()则是当前文件是否有修改的判断,当开启了热部署且有修改就会调用Context的reload方法进行重加载,实现web服务的**热部署**。

 

fireLifecycleEvent:对容器的监听对象发送Lifecycle.PERIODIC_EVENT事件,调用LifecycleListener的lifecycleEvent。

 

public void fireLifecycleEvent(String type, Object data) {    LifecycleEvent event = new LifecycleEvent(lifecycle, type, data);    LifecycleListener interested[] = listeners;    for (int i = 0; i < interested.length; i++)        interested[i].lifecycleEvent(event);}

好的,前面说到StandardHost通server.xml配置了HostConfig监听器,那么进入HostConfig查看对该事件的响应方法lifecycleEvent

 

public void lifecycleEvent(LifecycleEvent event) {    // Identify the host we are associated with    try {        host = (Host) event.getLifecycle();        if (host instanceof StandardHost) {            setCopyXML(((StandardHost) host).isCopyXML());            setDeployXML(((StandardHost) host).isDeployXML());            setUnpackWARs(((StandardHost) host).isUnpackWARs());            setContextClass(((StandardHost) host).getContextClass());        }    } catch (ClassCastException e) {        log.error(sm.getString("hostConfig.cce", event.getLifecycle()), e);        return;    }    // 看事件与其对应的方法调用    if (event.getType().equals(Lifecycle.PERIODIC_EVENT)) {        check();    } else if (event.getType().equals(Lifecycle.START_EVENT)) {        start();    } else if (event.getType().equals(Lifecycle.STOP_EVENT)) {        stop();    }}

可以看到Lifecycle.PERIODIC_EVENT事件会调用其check方法。

 

protected void check() {    if (host.getAutoDeploy()) {//这个条件对应这server.xml的Host配置的autoDeploy="true"        DeployedApplication[] apps =            deployed.values().toArray(new DeployedApplication[0]);        for (int i = 0; i < apps.length; i++) {            if (!isServiced(apps[i].name))                //资源查找                checkResources(apps[i], false);        }        if (host.getUndeployOldVersions()) {            checkUndeploy();        }        //部署        deployApps();    }}

很显然,如果server.xml的Host配置了能够自动部署(StandardHost默认autoDeploy=true),那么会调用deployApps方法。也就是说tomcat每10s会调用一次deployApps,完**热部署**。当然,启动tomcat时则是START_EVENT,调用start()方法。

public void start() {        // ...        if (!appBase().isDirectory()) {            log.error(sm.getString(                    "hostConfig.appBase", host.getName(), appBase().getPath()));            host.setDeployOnStartup(false);            host.setAutoDeploy(false);        }        if (host.getDeployOnStartup())            deployApps();    }

 

protected void deployApps() {    File appBase = appBase();    File configBase = configBase();    String[] filteredAppPaths = filterAppPaths(appBase.list());    // Deploy XML descriptors from configBase    deployDescriptors(configBase, configBase.list());    // Deploy WARs    deployWARs(appBase, filteredAppPaths);    // Deploy expanded folders    deployDirectories(appBase, filteredAppPaths);}

可以看到可以通过xml,war包等直接部署!

 

protected void deployDescriptor(ContextName cn, File contextXml) {    //    Context context = null;    //    Class
clazz = Class.forName(host.getConfigClass());//默认值:ContextConfig LifecycleListener listener = (LifecycleListener) clazz.newInstance(); context.addLifecycleListener(listener); // host.addChild(context); //}

 

而部署的过程,其实就是创建了Context对象,并添加到Host中。

此外从HostConfig部署Contex的方法中可以看到,有3中方式部署war包:

  1 在server.xml的Host标签中声明Context标签

  2 将war包放入webapps中

  3 context.xml配置方式

至此,我们已经知道了Engine、Host、Context的加载了,同时也知道了tomcat是怎么加载我们的web服务,是怎么实现的热部署。那么接下来就剩下最后一个Wrapper的加载了。

很捉急,在server.xml中没有关于Wrapper的初始化加载,那么在哪里呢? 

同样回到,上面的deployApps()方法中,在其三种部署方式中都有一节代码

 

Class
clazz = Class.forName(host.getConfigClass());//默认值:ContextConfigLifecycleListener listener = (LifecycleListener) clazz.newInstance();context.addLifecycleListener(listener);

这段代码的作用是给Context容器添加了ContextConfig监听器。而在Context的startInternal方法中,发送了监听事件:

 

fireLifecycleEvent(Lifecycle.CONFIGURE_START_EVENT, null);

ContextConfig监听到该事件,调用configureStart方法,在该方法中调用webConfig(),webConfig完成web.xml解析,生成servlet、filter等信息,并配置加载Wrapper。通过对ContextConfig的分析可以知道,Wrapper 代表一个 Servlet,它负责管理一个 Servlet,包括的 Servlet 的装载、初始化、执行以及资源回收。

 

四、关于StandardContext

    StandardContext简单点说就是Servlet容器,是需要我们重点研究的对象,它包含了ApplicationContext (implements ServletContext),查看代码,我们可以发现容器对web.xml中相关元素的加载过程。

startInternal()// Set up the context init params            mergeParameters();// Call ServletContainerInitializersfor (Map.Entry
>> entry : initializers.entrySet()) { try { entry.getKey().onStartup(entry.getValue(), getServletContext()); } catch (ServletException e) { log.error(sm.getString("standardContext.sciFail"), e); ok = false; break; }}// Configure and call application event listeners if (ok) { if (!listenerStart()) { log.error( "Error listenerStart"); ok = false; } } try { // Start manager if ((manager != null) && (manager instanceof Lifecycle)) { ((Lifecycle) getManager()).start(); } } catch(Exception e) { log.error("Error manager.start()", e); ok = false; } // Configure and call application filters if (ok) { if (!filterStart()) { log.error("Error filterStart"); ok = false; } } // Load and initialize all "load on startup" servlets if (ok) { if (!loadOnStartup(findChildren())){ log.error("Error loadOnStartup"); ok = false; } }

我们常用的spring的ContextLoaderListener就是在此处加载的,注意,在Servlet3.0之前,listener不是按顺序调用的。关于Servlet,强烈建议读一下《Servlet规范》

    好了,从Engine---Host---Contex----Wrapper这个链路上的容器初始化和app加载已经完成。接下来的文章我们来看请求在容器里所走过的代码逻辑。

 

 

转载于:https://my.oschina.net/javahongxi/blog/1523766

你可能感兴趣的文章
设计模式--FACADE
查看>>
wsdl
查看>>
手机LED---点阵字体实现
查看>>
新项目要考虑的问题
查看>>
URL中“#” “?” &“”号的作用
查看>>
Linux: 字体安装
查看>>
ImportError: No module named MySQLdb
查看>>
MySQL主从复制与都系分离
查看>>
远程连接MySQL, 10038问题
查看>>
ACPI电源管理中的S0 S1 S2 S3 S4 S5
查看>>
Eclipse 全屏插件及颜色主题插件
查看>>
动态数据类型转换
查看>>
wordpress修改域名后的一些设置:
查看>>
VS2012 GetTickCount64
查看>>
jquery常用
查看>>
在 CentOS 7 中安装 Nextcloud
查看>>
iOS 发送邮件 ios7
查看>>
JavaMailSenderImpl
查看>>
【Android】EditText的特殊属性介绍
查看>>
go处理json格式文件
查看>>