tomcat请求处理分析(二) 启动mapperListener

1.1.1启动mapperListener 

   这个方法的核心就是注册Host的

public void startInternal() throws LifecycleException{     setState(LifecycleState.STARTING); //获取当前service的container,其实也就是engine @SuppressWarnings("deprecation")     Engine engine = (Engine) service.getContainer();     if (engine == null) { return; }     findDefaultHost();//获取当前engine默认的host addListeners(engine);//给当前Mapper添加监听时间     //找到当前engine下所有host主机 Container[] conHosts =engine.findChildren();     for (Container conHost :conHosts) {         Host host = (Host) conHost;         if (!LifecycleState.NEW.equals(host.getState())){ // 登记host会注册context和 wrappers registerHost(host); }     }

}

1.1.1.1  注册Host

 注册Host主要进行了两步操作,第一步是添加Host 第二步是registerContext

private void registerHost(Host host) {     String[] aliases = host.findAliases(); mapper.addHost(host.getName(), aliases, host);     for (Container container :host.findChildren()) { if (container.getState().isAvailable()){             registerContext((Context)container); }     } if(log.isDebugEnabled()){ log.debug(sm.getString("mapperListener.registerHost", host.getName(), domain, service)); } }

1.1.1.1.1     添加Host

public synchronizedvoid addHost(String name, String[]aliases, Host host) { //StandardEngine[Catalina].StandardHost[localhost]     //创建MappedHost对象的数组,这里长度需要加1 MappedHost[]newHosts = new MappedHost[hosts.length + 1]; //创建一个MappedHost对象,用于保存host的map信息 MappedHostnewHost = new MappedHost(name, host); //insertMap将hosts这个数组迁移到newHosts并将newHost按name添加到指定位置 if (insertMap(hosts, newHosts, newHost)) { hosts= newHosts;   //指向新的数组 if (log.isDebugEnabled()) { log.debug(sm.getString("mapper.addHost.success", name)); }     } else{ //不能插入这说明有相同名字的,有两种情况,第一种是在先前通过addContextVersion加入让那个newHost指向,另一种名字相同则直接返回 MappedHostduplicate = hosts[find(hosts, name)];         if (duplicate.object == host) { if(log.isDebugEnabled()) { log.debug(sm.getString("mapper.addHost.sameHost", name)); }             newHost = duplicate; }else { log.error(sm.getString("mapper.duplicateHost", name, duplicate.getRealHostName())); return; }     }     List<MappedHost> newAliases = new ArrayList<>(aliases.length);     for (Stringalias : aliases) {         MappedHost newAlias = new MappedHost(alias, newHost);         if (addHostAliasImpl(newAlias)) {             newAliases.add(newAlias); }     }     newHost.addAliases(newAliases); }

    这个方法的作用将新的host插入到已有的集合,如果存在,直接返回,不存在则按字母排序有序插入,其中实现有序插入主要是调用了find这个二分查找,找到跟当前name最近的一个,然后进行插入,数组迁移

private static final <T> boolean insertMap (MapElement<T>[]oldMap, MapElement<T>[] newMap, MapElement<T>newElement) { int pos = find(oldMap, newElement.name);//在old里面,最近接新的元素的name的位置,这里返回的pos要么name相当,要么最左侧 if ((pos != -1) &&(newElement.name.equals(oldMap[pos].name))) { //这里表示有名字相同的,那么失败 return false; } //分段拷贝,这样拷贝完了之后也是排好序的 System.arraycopy(oldMap, 0, newMap, 0, pos + 1); //对数组拷贝,这里相当于先拷贝小的 newMap[pos + 1] =newElement; System.arraycopy (oldMap, pos + 1, newMap, pos + 2, oldMap.length - pos - 1);     return true; }

二分查找方法如下:

private static final <T> int find(MapElement<T>[] map, String name){ int a = 0;     int b = map.length - 1; // Special cases: -1 and 0 if (b == -1) { return -1; } if (name.compareTo(map[0].name) < 0) { return -1; } if (b == 0) { return 0; } int i = 0;     while (true) {         i = (b + a) / 2;         int result =name.compareTo(map[i].name);         if (result > 0) {             a = i; } else if (result == 0) { return i; } else {             b = i; } if ((b - a) == 1) { int result2 =name.compareTo(map[b].name);             if (result2 < 0) { return a; } else { return b; }         }     }

}

1.1.1.1.2     注册web应用

  在这里注册路由,经过http请求能够找到对应的web 应用,一个context对应一个web应用

private void registerContext(Context context) {     String contextPath =context.getPath(); //获取context的路径 if ("/".equals(contextPath)){         contextPath = ""; }     Host host = (Host)context.getParent(); //获取的其host WebResourceRootresources = context.getResources(); //获取root String[] welcomeFiles =context.findWelcomeFiles(); //获取欢迎页     // 准备context 下的所有 wrapper 信息 List<WrapperMappingInfo>wrappers = new ArrayList<>();     for (Container container :context.findChildren()) {         prepareWrapperMappingInfo(context, (Wrapper)container, wrappers);         if(log.isDebugEnabled()){ log.debug(sm.getString("mapperListener.registerWrapper", container.getName(), contextPath, service)); }     } // 添加 contextVersion,在这里面会将该context下的所有wrapper映射信息也构建 mapper.addContextVersion(host.getName(), host, contextPath, context.getWebappVersion(), context, welcomeFiles, resources, wrappers);     if(log.isDebugEnabled()){ log.debug(sm.getString("mapperListener.registerContext", contextPath, service)); }

}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏JAVA同学会

Zookeeper应用之——选举(Election)

请注意,此篇文章并不是介绍Zookeeper集群内部Leader的选举机制,而是应用程序使用Zookeeper作为选举。

502
来自专栏Pulsar-V

OpenCV在ubuntu下的编译

opencv的编译 下面我们写一个shell命名为build.sh放在opencv的根目录下面,代码如下: mkdir $1 cd $1 cmake -DWIT...

2835
来自专栏菩提树下的杨过

java调用.net asmx / wcf

一、先用asmx与wcf写二个.net web service: 1.1 asmx web服务:asmx-service.asmx.cs 1 using Sy...

2055
来自专栏chafezhou

程序员探案之被吃掉的串口数据

1194
来自专栏python学习路

五、常用模块

模块介绍 time &datetime模块 random os sys shutil json & picle shelve xml处理 yaml处理 conf...

2998
来自专栏后端云

支持windows虚拟机和linux虚拟机分区调度

用该image生成的vm,没有被nova-scheduler调度到windows主机组。

853
来自专栏WindCoder

Logstash6中grok插件的常用正则表达式

Logstash 内置了120种默认表达式,可以查看patterns,里面对表达式做了分组,每个文件为一组,文件内部有对应的表达式模式。下面只是部分常用的。

792
来自专栏个人分享

MapReduce格式与类型

  MapReduce是一个简单的数据处理模型,map与reduce的输入和输出类型都为key-value形式的键值对。

751
来自专栏逆向技术

PE格式第三讲扩展,VA,RVA,FA(RAW),模块地址的概念

          PE格式第三讲扩展,VA,RVA,FA的概念 一丶VA概念 VA (virtual Address) 虚拟地址的意思 ,比如随便打开一个PE...

2615
来自专栏逆向与安全

360 so动态脱壳

目前so加壳有很多家,我己知的有 爱加密,梆梆,360, 娜迦等 各有所长。今天把学习360的脱壳笔记记录下来与小菜共同学习,没有其它目的,大神请绕道!

890

扫码关注云+社区