读懂tomact源码三:Service

2024-08-24 05:32
文章标签 源码 service 读懂 tomact

本文主要是介绍读懂tomact源码三:Service，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！ 

service是一个接口，在源码上有一段这样的话：

A Service is a group of one or more Connectors that share a single Container to process their incoming requests.  This arrangement allows, for example,a non-SSL and SSL connector to share the same population of web apps.A given JVM can contain any number of Service instances; however, they are completely independent of each other and share only the basic JVM facilities and classes on the system class path.
 Service是一组连接器共享单个容器，来解析他们收到的请求。这些请求可以是ssl或者不是ssl的。一个给定的jvm包含任何数量的service实例；但是，它们彼此相互独立，共享一份jvm虚拟机和系统变量的类。

Service的源码

public interface Service extends Lifecycle {// ----------------- Propertiespublic Container getContainer();public void setContainer(Container container);public String getInfo();public String getName();public void setName(String name);public Server getServer();public void setServer(Server server);public ClassLoader getParentClassLoader();public void setParentClassLoader(ClassLoader parent);// ----------------- Public Methodspublic void addConnector(Connector connector);public void removeConnector(Connector connector);public void addExecutor(Executor ex);public Executor[] findExecutors();public Executor getExecutor(String name);public void removeExecutor(Executor ex);
}

StandardService实现了Service这个接口

Property

  1. private final Object connectorsLock = new Object();
    connectors的锁，主要是add、remove、restart操作
  2. protected PropertyChangeSupport support = new PropertyChangeSupport(this);
    PropertyChangeSupport，我也不懂是什么鬼，看着是支持一些属性的更改
  3. protected Connector connectors[] = new Connector[0];
    这个servce所关联的Connector
  4. protected Container container = null;
    The Container associated with this Service
  5. private Server server = null;
    这个service的所有者吧

method

  1. setContainer : 设置service的Container
public void setContainer(Container container) {Container oldContainer = this.container;if ((oldContainer != null) && (oldContainer instanceof Engine))((Engine) oldContainer).setService(null);this.container = container;if ((this.container != null) && (this.container instanceof Engine))((Engine) this.container).setService(this);if (getState().isAvailable() && (this.container != null)) {try {this.container.start();} catch (LifecycleException e) {// Ignore}}if (getState().isAvailable() && (oldContainer != null)) {try {oldContainer.stop();} catch (LifecycleException e) {// Ignore}}// Report this property change to interested listenerssupport.firePropertyChange("container", oldContainer, this.container);}
  1. addConnector,添加Connector
  public void addConnector(Connector connector) {synchronized (connectorsLock) {connector.setService(this);Connector results[] = new Connector[connectors.length + 1];System.arraycopy(connectors, 0, results, 0, connectors.length);results[connectors.length] = connector;connectors = results;if (getState().isAvailable()) {try {connector.start();} catch (LifecycleException e) {log.error(sm.getString("standardService.connector.startFailed",connector), e);}}// Report this property change to interested listenerssupport.firePropertyChange("connector", null, connector);}}
  1. removeConnector：删去一个Connector
public void removeConnector(Connector connector) {synchronized (connectorsLock) {int j = -1;for (int i = 0; i < connectors.length; i++) {if (connector == connectors[i]) {j = i;break;}}if (j < 0)return;if (connectors[j].getState().isAvailable()) {try {connectors[j].stop();} catch (LifecycleException e) {log.error(sm.getString("standardService.connector.stopFailed",connectors[j]), e);}}connector.setService(null);int k = 0;Connector results[] = new Connector[connectors.length - 1];for (int i = 0; i < connectors.length; i++) {if (i != j)results[k++] = connectors[i];}connectors = results;// Report this property change to interested listenerssupport.firePropertyChange("connector", connector, null);}}
  1. startInternal
protected void startInternal() throws LifecycleException {if (log.isInfoEnabled())log.info(sm.getString("standardService.start.name", this.name));setState(LifecycleState.STARTING);// Start our defined Container firstif (container != null) {synchronized (container) {container.start();}}synchronized (executors) {for (Executor executor : executors) {executor.start();}}// Start our defined Connectors secondsynchronized (connectorsLock) {for (Connector connector : connectors) {try {// If it has already failed, don't try and start itif (connector.getState() != LifecycleState.FAILED) {connector.start();}} catch (Exception e) {log.error(sm.getString("standardService.connector.startFailed",connector), e);}}}}

Start nested components ： Executors, Connectors and Containers and implement the requirements of org.apache.catalina.util.LifecycleBase#startInternal().

5:initInternal:主要是初始化，Executor、Connector、container
protected void initInternal() throws LifecycleException {

    super.initInternal();if (container != null) {container.init();}// Initialize any Executorsfor (Executor executor : findExecutors()) {if (executor instanceof LifecycleMBeanBase) {((LifecycleMBeanBase) executor).setDomain(getDomain());}executor.init();}// Initialize our defined Connectorssynchronized (connectorsLock) {for (Connector connector : connectors) {try {connector.init();} catch (Exception e) {String message = sm.getString("standardService.connector.initFailed", connector);log.error(message, e);if (Boolean.getBoolean("org.apache.catalina.startup.EXIT_ON_INIT_FAILURE"))throw new LifecycleException(message);}}}
}

6：startInternal：Executor、Connector、container开始执行

protected void startInternal() throws LifecycleException {if (log.isInfoEnabled())log.info(sm.getString("standardService.start.name", this.name));setState(LifecycleState.STARTING);// Start our defined Container firstif (container != null) {synchronized (container) {container.start();}}synchronized (executors) {for (Executor executor : executors) {executor.start();}}// Start our defined Connectors secondsynchronized (connectorsLock) {for (Connector connector : connectors) {try {// If it has already failed, don't try and start itif (connector.getState() != LifecycleState.FAILED) {connector.start();}} catch (Exception e) {log.error(sm.getString("standardService.connector.startFailed",connector), e);}}}}

7、stopInternal

protected void stopInternal() throws LifecycleException {

    // Pause connectors firstsynchronized (connectorsLock) {for (Connector connector : connectors) {try {connector.pause();} catch (Exception e) {log.error(sm.getString("standardService.connector.pauseFailed",connector), e);}}}if (log.isInfoEnabled())log.info(sm.getString("standardService.stop.name", this.name));setState(LifecycleState.STOPPING);// Stop our defined Container secondif (container != null) {synchronized (container) {container.stop();}}// Now stop the connectorssynchronized (connectorsLock) {for (Connector connector : connectors) {if (!LifecycleState.STARTED.equals(connector.getState())) {// Connectors only need stopping if they are currently// started. They may have failed to start or may have been// stopped (e.g. via a JMX call)continue;}try {connector.stop();} catch (Exception e) {log.error(sm.getString("standardService.connector.stopFailed",connector), e);}}}synchronized (executors) {for (Executor executor : executors) {executor.stop();}}
}

**

note：注意Internal中Executor、Connector、container的次序

**

8.getParentClassLoader 

  public ClassLoader getParentClassLoader() {if (parentClassLoader != null)return (parentClassLoader);if (server != null) {return (server.getParentClassLoader());}return (ClassLoader.getSystemClassLoader());}

如果没有parentClassLoader和server，返回SystemClassLoader

这篇关于读懂tomact源码三:Service的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1101583。

相关文章

Android实现一键录屏功能(附源码)

Android实现一键录屏功能(附源码)

《Android实现一键录屏功能(附源码)》在Android5.0及以上版本,系统提供了MediaProjectionAPI,允许应用在用户授权下录制屏幕内容并输出到视频文件,所以本文将基于此实现一个... 目录一、项目介绍二、相关技术与原理三、系统权限与用户授权四、项目架构与流程五、环境配置与依赖六、完整
阅读更多...
Android实现定时任务的几种方式汇总(附源码)

Android实现定时任务的几种方式汇总(附源码)

《Android实现定时任务的几种方式汇总(附源码)》在Android应用中,定时任务（ScheduledTask）的需求几乎无处不在：从定时刷新数据、定时备份、定时推送通知,到夜间静默下载、循环执行... 目录一、项目介绍1. 背景与意义二、相关基础知识与系统约束三、方案一：Handler.postDel
阅读更多...
Java 正则表达式URL 匹配与源码全解析

Java 正则表达式URL 匹配与源码全解析

《Java正则表达式URL匹配与源码全解析》在Web应用开发中,我们经常需要对URL进行格式验证,今天我们结合Java的Pattern和Matcher类,深入理解正则表达式在实际应用中... 目录1.正则表达式分解：2. 添加域名匹配 (2)3. 添加路径和查询参数匹配 (3) 4. 最终优化版本5.设计思
阅读更多...
电脑死机无反应怎么强制重启? 一文读懂方法及注意事项

电脑死机无反应怎么强制重启? 一文读懂方法及注意事项

《电脑死机无反应怎么强制重启?一文读懂方法及注意事项》在日常使用电脑的过程中，我们难免会遇到电脑无法正常启动的情况，本文将详细介绍几种常见的电脑强制开机方法，并探讨在强制开机后应注意的事项，以及如何... 在日常生活和工作中，我们经常会遇到电脑突然无反应的情况，这时候强制重启就成了解决问题的“救命稻草”。那
阅读更多...
Java调用C++动态库超详细步骤讲解(附源码)

Java调用C++动态库超详细步骤讲解(附源码)

《Java调用C++动态库超详细步骤讲解(附源码)》C语言因其高效和接近硬件的特性,时常会被用在性能要求较高或者需要直接操作硬件的场合,：本文主要介绍Java调用C++动态库的相关资料,文中通过代... 目录一、直接调用C++库第一步：动态库生成（vs2017+qt5.12.10）第二步：Java调用C++
阅读更多...
Python实现无痛修改第三方库源码的方法详解

Python实现无痛修改第三方库源码的方法详解

《Python实现无痛修改第三方库源码的方法详解》很多时候,我们下载的第三方库是不会有需求不满足的情况,但也有极少的情况,第三方库没有兼顾到需求,本文将介绍几个修改源码的操作,大家可以根据需求进行选择... 目录需求不符合模拟示例 1. 修改源文件2. 继承修改3. 猴子补丁4. 追踪局部变量需求不符合很
阅读更多...
Spring 中 BeanFactoryPostProcessor 的作用和示例源码分析

Spring 中 BeanFactoryPostProcessor 的作用和示例源码分析

《Spring中BeanFactoryPostProcessor的作用和示例源码分析》Spring的BeanFactoryPostProcessor是容器初始化的扩展接口,允许在Bean实例化前... 目录一、概览1. 核心定位2. 核心功能详解3. 关键特性二、Spring 内置的 BeanFactory
阅读更多...
MyBatis-Plus中Service接口的lambdaUpdate用法及实例分析

MyBatis-Plus中Service接口的lambdaUpdate用法及实例分析

《MyBatis-Plus中Service接口的lambdaUpdate用法及实例分析》本文将详细讲解MyBatis-Plus中的lambdaUpdate用法,并提供丰富的案例来帮助读者更好地理解和应... 目录深入探索MyBATis-Plus中Service接口的lambdaUpdate用法及示例案例背景
阅读更多...
Android里面的Service种类以及启动方式

Android里面的Service种类以及启动方式

《Android里面的Service种类以及启动方式》Android中的Service分为前台服务和后台服务,前台服务需要亮身份牌并显示通知,后台服务则有启动方式选择,包括startService和b... 目录一句话总结：一、Service 的两种类型：1. 前台服务（必须亮身份牌）2. 后台服务（偷偷干
阅读更多...
电脑密码怎么设置? 一文读懂电脑密码的详细指南

电脑密码怎么设置? 一文读懂电脑密码的详细指南

《电脑密码怎么设置?一文读懂电脑密码的详细指南》为了保护个人隐私和数据安全，设置电脑密码显得尤为重要，那么，如何在电脑上设置密码呢？详细请看下文介绍... 设置电脑密码是保护个人隐私、数据安全以及系统安全的重要措施，下面以Windows 11系统为例，跟大家分享一下设置电脑密码的具体办php法。Windo
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2