深入剖析Tomcat(六) Tomcat各组件的生命周期控制

Catalina中有很多组件,像上一章提到的四种容器,载入器,映射器等都是一种组件。每个组件在对外提供服务之前都需要有个启动过程;组件在销毁之前,也需要有个关闭过程;例如servlet容器关闭时,需要调用servlet的destroy方法,session管理器关闭时必须将seesion对象保存到辅助存储器中等。

Catalina为了更好的控制各组件的启动与销毁流程,做了几个生命周期的接口与工具类出来,对所有需要生命周期控制的组件做了个规范,并将启动与销毁的触发点收束到一个顶层组件中,实现统一启动或关闭所有组件。

这个统一控制的实现方式就是,由最顶层组件发号施令,一层一层往下传播,每个组件只控制其子组件的启动与关闭,直到最底层的组件。

相关的接口与类有以下几个,下面一一介绍

org.apache.catalina.Lifecycle

org.apache.catalina.LifecycleEvent

org.apache.catalina.LifecycleListener

org.apache.catalina.util.LifecycleSupport

Lifecycle接口

Catalina中的组件如果想被纳入统一生命周期管理的话,就必须实现Lifecycle接口。

该接口定义了五个方法与六个字符串属性。

最重要的方法是start()与stop()方法,这两个方法必须被实现。

start()方法中需要执行本组件的启动逻辑并调用子组件的start()方法。stop()方法需要执行本组件的关闭逻辑并调用子组件的stop()方法。Catalina的这种设计使得所有子组件都置于其父组件的“监护”之下,这样,Catalina的启动类只需要启动一个组件就可以将全部应用的组件都启动起来。

六个属性则是定义了start与stop过程中的六个阶段的事件

  • BEFORE_START_EVENT:组件启动前
  • START_EVENT:                 组件启动中
  • AFTER_START_EVENT:   组件启动后
  • BEFORE_STOP_EVENT:  组件关闭前
  • STOP_EVENT:                   组件关闭中
  • AFTER_STOP_EVENT:     组件关闭后

六种事件发生后,需要有专门的事件监听器来处理。Lifecycle接口中其他三个方法则是与事件监听器相关的方法:添加、移除、查询 事件监听器。

public interface Lifecycle {public static final String START_EVENT = "start";public static final String BEFORE_START_EVENT = "before_start";public static final String AFTER_START_EVENT = "after_start";public static final String STOP_EVENT = "stop";public static final String BEFORE_STOP_EVENT = "before_stop";public static final String AFTER_STOP_EVENT = "after_stop";public void addLifecycleListener(LifecycleListener listener);public LifecycleListener[] findLifecycleListeners();public void removeLifecycleListener(LifecycleListener listener);public void start() throws LifecycleException;public void stop() throws LifecycleException;}

LifecycleEvent类

这个类是对Lifecycle中六种事件的封装,组件触发生命周期的事件后,将事件封装成LifecycleEvent对象,然后作为监听器的方法参数去触发监听。其中type字段放的就是Lifecycle中定义的六个事件之一。

public final class LifecycleEvent extends EventObject {public LifecycleEvent(Lifecycle lifecycle, String type) {this(lifecycle, type, null);}public LifecycleEvent(Lifecycle lifecycle, String type, Object data) {super(lifecycle);this.lifecycle = lifecycle;this.type = type;this.data = data;}// 事件关联的数据private Object data = null;// 触发事件的组件private Lifecycle lifecycle = null;// 事件类型private String type = null;public Object getData() {return this.data;}public Lifecycle getLifecycle() {return this.lifecycle;}public String getType() {return (this.type);}}

LifecycleListener接口

这是事件监听器的接口。实现了Lifecycle接口的组件,在触发了一个事件后,将事件封装成LifecycleEvent对象,调用监听器的lifecycleEvent,根据不同事件做相应处理。

package org.apache.catalina;public interface LifecycleListener {/*** 让监听器知晓有事件发生了*/public void lifecycleEvent(LifecycleEvent event);}

LifecycleSupport类

此类是一个工具类,负责辅助 实现了Lifecycle的组件 将LifecycleEvent事件通知到所有监听器。

LifecycleSupport类有两个属性:

  • lifecycle:关联的 实现了Lifecycle接口的组件
  • listeners:lifecycle关联的监听器

addLifecycleListenerremoveLifecycleListener两个方法,通过复制监听器数组的方式来新增或移除监听器。

fireLifecycleEvent方法负责将事件封装成LifecycleEvent对象并作为参数,for循环调用所有监听器的lifecycleEvent方法,执行监听处理。

public final class LifecycleSupport {public LifecycleSupport(Lifecycle lifecycle) {super();this.lifecycle = lifecycle;}private Lifecycle lifecycle = null;private LifecycleListener[] listeners = new LifecycleListener[0];/*** 为lifecycle组件添加一个事件监听器*/public void addLifecycleListener(LifecycleListener listener) {synchronized (listeners) {LifecycleListener results[] = new LifecycleListener[listeners.length + 1];for (int i = 0; i < listeners.length; i++) {results[i] = listeners[i];}results[listeners.length] = listener;listeners = results;}}public LifecycleListener[] findLifecycleListeners() {return listeners;}/*** 通知所有事件监听器,此容器发生了特定事件,默认使用调用线程以同步的方式执行此方法。*/public void fireLifecycleEvent(String type, Object data) {LifecycleEvent event = new LifecycleEvent(lifecycle, type, data);LifecycleListener[] interested;// 这里克隆一下listeners数组,我理解克隆的意义 是为了防止在执行listeners的for循环过程中,又被调用了addLifecycleListener来添加一个listenersynchronized (listeners) {interested = listeners.clone();}for (int i = 0; i < interested.length; i++) {interested[i].lifecycleEvent(event);}}/*** 移除一个事件监听器*/public void removeLifecycleListener(LifecycleListener listener) {synchronized (listeners) {int n = -1;for (int i = 0; i < listeners.length; i++) {if (listeners[i] == listener) {n = i;break;}}if (n < 0) return;LifecycleListener results[] = new LifecycleListener[listeners.length - 1];int j = 0;for (int i = 0; i < listeners.length; i++) {if (i != n) results[j++] = listeners[i];}listeners = results;}}}

其他类

本章其他的类基本沿用了第五章的类。不同点是,本章将各个组件类都实现了Lifecycle接口。

SimpleContext最为最顶层的组件,负责“一键启停”所有组件。SimpleContext拥有一个LifecycleSupport属性,用来处理对生命周期事件的监听。本章做了一个SimpleContextLifecycleListener类来作为SimpleContext的事件监听器。在start()启动方法中,会将一个SimpleContextLifecycleListener实例与SimpleContext绑定起来。

下面是SimpleContext的部分代码

public class SimpleContext implements Context, Pipeline, Lifecycle {public SimpleContext() {pipeline.setBasic(new SimpleContextValve());}// 子容器protected HashMap children = new HashMap();// 载入器private Loader loader = null;// 生命周期支持组件protected LifecycleSupport lifecycle = new LifecycleSupport(this);// 管道private SimplePipeline pipeline = new SimplePipeline(this);// servlet的uri映射private HashMap servletMappings = new HashMap();// 默认映射器protected Mapper mapper = null;// 映射器集合protected HashMap mappers = new HashMap();// 父组件private Container parent = null;// 此组件是否已启动protected boolean started = false;// 添加映射器public void addLifecycleListener(LifecycleListener listener) {lifecycle.addLifecycleListener(listener);}// 移除映射器public void removeLifecycleListener(LifecycleListener listener) {lifecycle.removeLifecycleListener(listener);}public synchronized void start() throws LifecycleException {if (started) {throw new LifecycleException("SimpleContext has already started");}// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(BEFORE_START_EVENT, null);started = true;try {// 启动所有从属组件if ((loader != null) && (loader instanceof Lifecycle)) {((Lifecycle) loader).start();}// 启动所有子容器Container children[] = findChildren();for (int i = 0; i < children.length; i++) {if (children[i] instanceof Lifecycle) {((Lifecycle) children[i]).start();}}// 启动管道中的所有阀if (pipeline instanceof Lifecycle) {((Lifecycle) pipeline).start();}// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(START_EVENT, null);} catch (Exception e) {e.printStackTrace();}// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(AFTER_START_EVENT, null);}public void stop() throws LifecycleException {if (!started) {throw new LifecycleException("SimpleContext has not been started");}// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(BEFORE_STOP_EVENT, null);lifecycle.fireLifecycleEvent(STOP_EVENT, null);started = false;try {// 关闭管道中的所有阀if (pipeline instanceof Lifecycle) {((Lifecycle) pipeline).stop();}// 关闭所有子容器Container children[] = findChildren();for (int i = 0; i < children.length; i++) {if (children[i] instanceof Lifecycle) {((Lifecycle) children[i]).stop();}}if ((loader != null) && (loader instanceof Lifecycle)) {((Lifecycle) loader).stop();}} catch (Exception e) {e.printStackTrace();}// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(AFTER_STOP_EVENT, null);}}

SimpleContextLifecycleListener监听器

public class SimpleContextLifecycleListener implements LifecycleListener {public void lifecycleEvent(LifecycleEvent event) {Lifecycle lifecycle = event.getLifecycle();System.out.println("SimpleContextLifecycleListener's event " + event.getType());if (Lifecycle.START_EVENT.equals(event.getType())) {System.out.println("Starting context.");} else if (Lifecycle.STOP_EVENT.equals(event.getType())) {System.out.println("Stopping context.");}}}

SimpleLoader(载入器)实现了Lifecycle接口,但是方法都留空了,start与stop方法打印了一下启动信息。虽然这里start方法没有干事,但是它的启动流程已经能交给上层组件来控制了,后面再丰富启动流程也ok。

public synchronized void start() throws LifecycleException {System.out.println("Starting SimpleLoader");
}public void stop() throws LifecycleException {System.out.println("Stopping SimpleLoader");
}

SimplePipeline实现了Lifecycle接口,但是相关方法也留空了。start与stop方法仅仅打印一条信息。

public synchronized void start() throws LifecycleException {System.out.println("Starting SimplePipeline");
}public void stop() throws LifecycleException {System.out.println("Stopping SimplePipeline");
}

SimpleWrapper实现了Lifecycle接口,它是个容器类,包含了多种组件,所以它的start(),stop()方法做了实现。由于SimpleWrapper的每个实例都对应了一个servlet实例,所以在stop方法中,会去调用servlet的destroy方法。

public class SimpleWrapper implements Wrapper, Pipeline, Lifecycle {public SimpleWrapper() {pipeline.setBasic(new SimpleWrapperValve());}// the servlet instanceprivate Servlet instance = null;private String servletClass;private Loader loader;private String name;private SimplePipeline pipeline = new SimplePipeline(this);protected Container parent = null;protected LifecycleSupport lifecycle = new LifecycleSupport(this);protected boolean started = false;// 本章中的SimpleWrapper没有监听器,监听器相关的三个方法留空public void addLifecycleListener(LifecycleListener listener) {}public LifecycleListener[] findLifecycleListeners() {return null;}public void removeLifecycleListener(LifecycleListener listener) {}public synchronized void start() throws LifecycleException {System.out.println("Starting Wrapper " + name);if (started) {throw new LifecycleException("Wrapper already started");}// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(BEFORE_START_EVENT, null);started = true;// 启动所有从属组件if ((loader != null) && (loader instanceof Lifecycle)) {((Lifecycle) loader).start();}// 启动管道中的所有阀if (pipeline instanceof Lifecycle) {((Lifecycle) pipeline).start();}// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(START_EVENT, null);// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(AFTER_START_EVENT, null);}public void stop() throws LifecycleException {System.out.println("Stopping wrapper " + name);// 销毁servlet实例 (如果它已经被初始化的话)try {instance.destroy();} catch (Throwable t) {}instance = null;if (!started) {throw new LifecycleException("Wrapper " + name + " not started");}// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(BEFORE_STOP_EVENT, null);// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(STOP_EVENT, null);started = false;// 关闭管道中的所有阀if (pipeline instanceof Lifecycle) {((Lifecycle) pipeline).stop();}// 关闭所有从属组件if ((loader != null) && (loader instanceof Lifecycle)) {((Lifecycle) loader).stop();}// 触发了特定事件,通知事件监听器lifecycle.fireLifecycleEvent(AFTER_STOP_EVENT, null);}
}

启动类与第五章相比,还是原来的配方,还是原来的味道。

public final class Bootstrap {public static void main(String[] args) {Connector connector = new HttpConnector();Wrapper wrapper1 = new SimpleWrapper();wrapper1.setName("Primitive");wrapper1.setServletClass("PrimitiveServlet");Wrapper wrapper2 = new SimpleWrapper();wrapper2.setName("Modern");wrapper2.setServletClass("ModernServlet");Context context = new SimpleContext();context.addChild(wrapper1);context.addChild(wrapper2);Mapper mapper = new SimpleContextMapper();mapper.setProtocol("http");LifecycleListener listener = new SimpleContextLifecycleListener();((Lifecycle) context).addLifecycleListener(listener);context.addMapper(mapper);Loader loader = new SimpleLoader();context.setLoader(loader);// context.addServletMapping(pattern, name);context.addServletMapping("/Primitive", "Primitive");context.addServletMapping("/Modern", "Modern");connector.setContainer(context);try {connector.initialize();((Lifecycle) connector).start();((Lifecycle) context).start();// make the application wait until we press a key.System.in.read();((Lifecycle) context).stop();} catch (Exception e) {e.printStackTrace();}}
}

启动应用,看后端日志

HttpConnector Opening server socket on all host IP addresses
HttpConnector[8080] Starting background thread
SimpleContextLifecycleListener's event before_start
Starting SimpleLoader
Starting Wrapper Primitive
Starting SimplePipeline
Starting Wrapper Modern
Starting SimplePipeline
Starting SimplePipeline
SimpleContextLifecycleListener's event start
Starting context.
SimpleContextLifecycleListener's event after_start
关闭应用
SimpleContextLifecycleListener's event before_stop
SimpleContextLifecycleListener's event stop
Stopping context.
Stopping SimplePipeline
Stopping wrapper Primitive
Stopping SimplePipeline
Stopping wrapper Modern
Stopping SimplePipeline
Stopping SimpleLoader
SimpleContextLifecycleListener's event after_stopProcess finished with exit code 0

可以看到,随着SimpleContext#start()方法的调用,其下属的各组件和子容器都被启动了起来。而当我往控制台中输入了内容(“关闭应用”)之后,触发关闭流程,随着SimpleContext#stop()方法的调用,其下属各组件与子容器也都被关闭了。由于SimpleContext与SimpleWraper容器实例中都包含SimplePipeline所以你能看到多条SimplePipeline的启动信息。

好,本章内容到此结束。Tomcat通过Lifecycle这么一组接口,将各个组件的生命周期串联了起来,实现了“一键启动”、“一键关闭”。这个思想值得借鉴,体悟这种编程思想,也为我们以后的编程场景多一种参考储备。下一章,我们一起来看看Tomcat中的日志记录器,看看它是怎么记日志的,敬请期待吧!

源码分享

https://gitee.com/huo-ming-lu/HowTomcatWorks

原书中的代码没有明显bug,所以我仅仅格式化了一下代码,并加了些注释

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/832256.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Linux的shell外壳

Shell外壳 在计算机领域&#xff0c;“shell”&#xff08;外壳&#xff09;是指一种用户界面&#xff0c;提供了访问操作系统服务的方式。Shell 是用户与操作系统之间的桥梁&#xff0c;它解释并执行用户输入的命令。 Shell 的主要功能包括&#xff1a; 命令解释&#xff1a…

drain3学习笔记

介绍 由于众所周知的原因&#xff0c;Github访问不稳定。官网虽然介绍&#xff0c;但是案例连接无效&#xff0c;因此保存于此&#xff0c;方便参考学习。 配置 官网样例&#xff08;GitHub&#xff09; drain3.ini [SNAPSHOT] snapshot_interval_minutes 10 compress_st…

设计模式(软件设计师第5版)

创建型&#xff08;5种&#xff09; 1.他们都将关于该系统使用哪些具体的类的信息封转起来。 2.他们隐藏这些类的实例是如何被创建和放在一起的。整个系统关于这些对象所知道的是由抽象类所定义的接口。 创建型模式在什么被创建&#xff0c;谁创建它&#xff0c;它是怎样被创…

从同一文件中导出和导入多个组件

从同一文件中导出和导入多个组件 如果你只想展示一个 Profile 组&#xff0c;而不展示整个图集。你也可以导出 Profile 组件。但 Gallery.js 中已包含 默认 导出&#xff0c;此时&#xff0c;你不能定义 两个 默认导出。但你可以将其在新文件中进行默认导出&#xff0c;或者将…

字符串循环左移

#include <iostream> #include <string> using namespace std;int main() {string s1, s2;getline(cin, s1);int n;cin >> n;if(n>s1.size()){nn-s1.size();s2 s1.substr(0, n);s1.erase(0, n);cout << s1s2;}else{// 提取s1的前n个字符到s2中s2 …

MyBatis 多表映射及动态语句

三、MyBatis多表映射 3.1 多表映射概念 多表查询结果映射思路 前面说明中&#xff0c;我全面梳理了单表的mybatis操作&#xff01;但是开发中更多的是多表查询需求&#xff0c;这种情况我们如何让进行处理&#xff1f;MyBatis 思想是&#xff1a;数据库不可能永远是你所想或…

金融行业专题|信托超融合架构转型与场景探索合集

文章包含 15 信托用户基于超融合实现私有云建设、平台云下迁、信创云转型、容器云探索等场景实践分享。下载《【核心业务篇】金融核心生产业务场景探索文章合集》、《【信创转型与架构升级篇】金融核心生产业务场景探索文章合集》、《【数据库与数据仓库篇】金融核心生产业务场…

编程入门(六)【Linux系统基础操作一】

读者大大们好呀&#xff01;&#xff01;!☀️☀️☀️ &#x1f525; 欢迎来到我的博客 &#x1f440;期待大大的关注哦❗️❗️❗️ &#x1f680;欢迎收看我的主页文章➡️寻至善的主页 文章目录 &#x1f525;前言&#x1f680;Linux操作系统介绍与环境准备Linux操作系统介…

【PyTorch】5-进阶训练技巧(损失函数、学习率、模型微调、半精度训练、数据增强、超参数设置)

PyTorch&#xff1a;5-进阶训练技巧 注&#xff1a;所有资料来源且归属于thorough-pytorch(https://datawhalechina.github.io/thorough-pytorch/)&#xff0c;下文仅为学习记录 5.1&#xff1a;自定义损失函数 PyTorch在torch.nn模块提供了许多常用的损失函数&#xff0c;比…

Windows远程桌面实现之十四:实现AirPlay接收端,让苹果设备(iOS,iPad等)屏幕镜像到PC端

by fanxiushu 2024-05-04 转载或引用请注明原始作者。 这个课题已经持续了好几年&#xff0c;已经可以说是很长时间了。 实现的程序是 xdisp_virt&#xff0c; 可以去github下载使用:GitHub - fanxiushu/xdisp_virt: xfsredir file system 一开始是基于测试镜像驱动的目的随便开…

Vue前端环境准备

vue-cli Vue-cli是Vue官方提供的脚手架&#xff0c;用于快速生成一个Vue项目模板 提供功能&#xff1a; 统一的目录结构 本地调试 热部署 单元测试 集成打包上线 依赖环境&#xff1a;NodeJs 安装NodeJs与Vue-Cli 1、安装nodejs&#xff08;已经安装就不用了&#xff09; node-…

探索系统限流的艺术:滑动与滚动时间窗口的奥秘

在互联网的汪洋大海中&#xff0c;系统如同航行的巨轮&#xff0c;面对着波涛汹涌的流量浪涌。为了保障这艘巨轮稳定前行&#xff0c;"限流"便成了必备的导航仪器&#xff0c;而滑动时间窗口与滚动时间窗口则是其中最为精湛的两大技术。本文将为你揭示它们的奥秘&…

linux文本三剑客之grep

目录 1、三剑客特点和应用场景 2、三件客之grep 1) -v 参数使用示例&#xff1a; 1、三剑客特点和应用场景 命令特点场景grep过滤grep命令过滤速度最快sed替换&#xff0c;修改文件内容&#xff0c;取行 如果要进替换/修改文件内容 取出某个范围的内容&#xff08;从中午12.到…

【stomp 实战】spring websocket用户消息发送源码分析

这一节&#xff0c;我们学习用户消息是如何发送的。 消息的分类 spring websocket将消息分为两种&#xff0c;一种是给指定的用户发送&#xff08;用户消息&#xff09;&#xff0c;一种是广播消息&#xff0c;即给所有用户发送消息。那怎么区分这两种消息呢?那就是用前缀了…

我们说的数据分析,到底要分析些什么?

作者 Gam 本文为CDA志愿者投稿作品 “我们说数据分析&#xff0c;到底要分析些什么&#xff1f;” 数据分析这个话题自从进入人们的视线以来&#xff0c;这个话题就成为人们茶余饭后的谈资&#xff0c;但是一千个人眼中就有一千个哈姆雷特&#xff0c;就意味着每个人对数据分…

使用Photoshop压缩图片大小的4种方法

使用Photoshop压缩图片大小&#xff0c;一般可采用下面4种方法&#xff1a; 1.调整图片分辨率&#xff1a; 打开需要压缩的图片文件。 依次点击菜单栏中的“图像”>“图像大小”。 在弹出的对话框中&#xff0c;通过调整分辨率参数来减小文件大小。 2.降低图片品质&#…

什么是水经微图注册码?

水经微图&#xff08;以下简称“微图”&#xff09;注册码&#xff0c;是微图的一种授权方式。 什么是微图注册码&#xff1f; 注册码仅可授权一台电脑&#xff0c;绑定CPU和网卡&#xff0c;激活后不可更换电脑使用。 如果CPU或网卡被更换&#xff0c;以及电脑损坏无法开机…

数据库中索引的底层原理和SQL优化

文章目录 关于索引B 树的特点MySQL 为什么使用 B 树&#xff1f; 索引分类聚簇索引 和 非聚簇索引覆盖索引索引的最左匹配原则索引与NULL索引的代价大表结构修改 SQL优化EXPLAIN命令选择索引列其它细节 关于索引 索引是一种用来加快查找效率的数据结构&#xff0c;可以简单粗暴…