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 条评论
登录 后参与评论

相关文章

来自专栏Ryan Miao

Mybatis XML 映射配置文件 -- 熟悉配置

来源:http://www.mybatis.org/mybatis-3/zh/configuration.html properties mybatis读取属性...

2646
来自专栏软件测试经验与教训

Python 异常处理

3134
来自专栏程序员互动联盟

【答疑解惑】getchar()与EOF

先看下面的代码: while((c = getchar()) != EOF){ putchar(c); } 这一段代码是The C Programming ...

3539
来自专栏码洞

会玩Go!会玩Python!嘭!Go-Python!

Golang是静态语言,性能很好,当它不那么灵活,不好在运行时动态运行代码。Python是动态语言,非常灵活,但是性能很差。古人云:“鱼和熊掌不能兼得”。但是如...

451
来自专栏有趣的django

CRM客户关系管理系统(九) 第九章、filter_horizontal优化和kingadmin删除功能

1060
来自专栏数据之美

bash/shell 解析命令行参数工具:getopts/getopt

bash 脚本中,简单点的参数选项,我们可以直接用位置参数 $1 $2 这样来获取处理了,例如下面这段代码片段: optionParam=$1 baseHd...

2098
来自专栏散尽浮华

Python介绍

Python概述 Python创始人是吉多.范罗苏姆。在1989年万圣节期间为打发时间而开发的。 目前Python在TIOBE排行榜第五位置 ? Python可...

18410
来自专栏Golang语言社区

【Golang语言社区】 Go语言中使用 Protobuf

安装 goprotobuf 1.从 https://github.com/google/protobuf/releases 获取 Protobuf 编译器 pr...

2523
来自专栏Jed的技术阶梯

Kafka 中使用 Avro 序列化框架(一):使用传统的 avro API 自定义序列化类和反序列化类

关于 avro 的 maven 工程的搭建以及 avro 的入门知识,可以参考: Apache Avro 入门

723
来自专栏技术总结

iOS 复制知识点总结

18611

扫描关注云+社区