Tomcat中的容器是如何处理请求的
上一篇《 Tomcat中的连接器是如何设计的 》介绍了Tomcat中连接器的设计，我们知道连接器是负责监听网络端口，获取连接请求，然后转换符合Servlet标准的请求，交给容器去处理，那么我们这篇文章将顺着上一篇文章的思路，看看一个请求到了容器，容器是如何请求的。
说明：本文tomcat版本是9.0.21，不建议零基础读者阅读。
从Adapter中说起
我们继续跟着上篇文章 Adapter 的源码，继续分析，上篇文章结尾的源码如下：
//源码1.类： CoyoteAdapter implements Adapter
public void service(org.apache.coyote.Request req, org.apache.coyote.Response res)
throws Exception {
Request request = (Request) req.getNote(ADAPTER_NOTES);
Response response = (Response) res.getNote(ADAPTER_NOTES);
postParseSuccess = postParseRequest(req, request, res, response);
if (postParseSuccess) {
//check valves if we support async
request.setAsyncSupported(
connector.getService().getContainer().getPipeline().isAsyncSupported());
// Calling the container
connector.getService().getContainer().getPipeline().getFirst().invoke(
request, response);
}
}
复制代码
上面的源码的主要作用就是获取到容器，然后调用 getPipeline() 获取 Pipeline ，最后去 invoke 调用，我们来看看这个 Pipeline 是做什么的。
//源码2.Pipeline接口
public interface Pipeline extends Contained {
public Valve getBasic();
public void setBasic(Valve valve);
public void addValve(Valve valve);
public Valve[] getValves();
public void removeValve(Valve valve);
public Valve getFirst();
public boolean isAsyncSupported();
public void findNonAsyncValves(Set<String> result);
}
//源码3. Valve接口
public interface Valve {
public Valve getNext();
public void setNext(Valve valve);
public void backgroundProcess();
public void invoke(Request request, Response response)
throws IOException, ServletException;
public boolean isAsyncSupported();
复制代码
我们从字面上可以理解 Pipeline 就是管道，而 Valve 就是阀门，实际上在Tomcat中的作用也是和字面意思差不多。每个容器都有一个管道，而管道中又有多个阀门。我们通过后面的分析来证明这一点。
管道-阀门（Pipeline-Valve）
我们看到上面的源码是 Pipeline 和 Valve 的接口， Pipeline 主要是设置 Valve ,而 Valve 是一个链表，然后可以进行 invoke 方法的调用。我们回顾下这段源码：
//源码4
connector.getService().getContainer().getPipeline().getFirst().invoke(
request, response);
复制代码
这里是直接获取容器的管道，然后获取第一个 Valve 进行调用。我们在之前提到过 Valve 是一个链表，这里只调用第一个，也就是可以通过Next去调用到最后一个。我们再回顾下我们第一篇文章《 Tomcat在SpringBoot中是如何启动的 》中提到过，容器是分为4个子容器,分别为 Engine 、 Host 、 Context 、 Wrapper ,他们同时也是父级和子级的关系， Engine > Host > Context > Wrapper 。
我之前提到过，每个容器都一个 Pipeline ,那么这个是怎么体现出来的呢？我们看容器的接口源码就可以发现, Pipeline 是容器接口定义的一个基本属性：
//源码5.
public interface Container extends Lifecycle {
//省略其他代码
/**
* Return the Pipeline object that manages the Valves associated with
* this Container.
*
* @return The Pipeline
*/
public Pipeline getPipeline();
}
复制代码
我们知道了每个容器都有一个管道( Pipeline )，管道中有许多阀门( Valve ), Valve 可以进行链式调用，那么问题来了，父容器管道中的 Valve 怎么调用到子容器中的 Valve 呢？在 Pipeline 的实现类 StandardPipeline 中，我们发现了如下源码：
/**
// 源码6.
* The basic Valve (if any) associated with this Pipeline.
*/
protected Valve basic = null;
/**
* The first valve associated with this Pipeline.
*/
protected Valve first = null;
public void addValve(Valve valve) {
//省略部分代码
// Add this Valve to the set associated with this Pipeline
if (first == null) {
first = valve;
valve.setNext(basic);
} else {
Valve current = first;
while (current != null) {
//这里循环设置Valve，保证最后一个是basic
if (current.getNext() == basic) {
current.setNext(valve);
valve.setNext(basic);
break;
}
current = current.getNext();
}
}
container.fireContainerEvent(Container.ADD_VALVE_EVENT, valve);
}
复制代码
根据如上代码，我们知道了 basic 是一个管道( Pipeline )中的最后一个阀门，按道理只要最后一个阀门是下一个容器的第一个阀门就可以完成全部的链式调用了。我们用一个请求debug下看看是不是和我们的猜测一样，我们在 CoyoteAdapter 中的 service 方法中打个断点，效果如下：
这里我们可以知道，在适配器调用容器的时候，也就是调用 Engine 的管道，只有一个阀门，也就是basic，值为 StandardEngineValve 。我们发现这个阀门的invoke方法如下：
//源码7.
public final void invoke(Request request, Response response)
throws IOException, ServletException {
// Select the Host to be used for this Request
Host host = request.getHost();
if (host == null) {
// HTTP 0.9 or HTTP 1.0 request without a host when no default host
// is defined. This is handled by the CoyoteAdapter.
return;
}
if (request.isAsyncSupported()) {
request.setAsyncSupported(host.getPipeline().isAsyncSupported());
}
// Ask this Host to process this request
host.getPipeline().getFirst().invoke(request, response);
}
复制代码
我们继续debug查看结果如下：
所以这里的 basic 实际上将会调用到 Host 容器的管道( Pipeline )和阀门( Valve ),也就是说，每个容器管道中的 basic 是负责调用下一个子容器的阀门。我用一张图来表示：
这张图清晰的描述了，Tomcat内部的容器是如何流转请求的，从连接器（ Connector ）过来的请求会进入 Engine 容器， Engine 通过管道( Pieline )中的阀门( Valve )来进行链式调用，最后的 basic 阀门是负责调用下一个容器的第一个阀门的，一直调用到 Wrapper ,然后 Wrapper 再执行 Servlet 。
我们看看 Wrapper 源码，是否真的如我们所说：
//源码8.
public final void invoke(Request request, Response response)
throws IOException, ServletException {
//省略部分源码
Servlet servlet = null;
if (!unavailable) {
servlet = wrapper.allocate();
}
// Create the filter chain for this request
ApplicationFilterChain filterChain =
ApplicationFilterFactory.createFilterChain(request, wrapper, servlet);
filterChain.doFilter(request.getRequest(),
response.getResponse());
}
复制代码
看到这里，你可能会说这里明明只是创建了过滤器( Filter )并且去调用而已，并没有去调用 Servlet ，没错，这里确实没有去调用 Servlet ，但是我们知道，过滤器( Filter )是在 Servlet 之前执行的，也就是说， filterChain.doFilter 执行完之后变会执行 Servlet 。我们看看 ApplicationFilterChain 的源码是否如我们所说：
//源码9.
public void doFilter(ServletRequest request, ServletResponse response)
throws IOException, ServletException {
//省略部分代码
internalDoFilter(request,response);
}
//源码10.
private void internalDoFilter(ServletRequest request,
ServletResponse response)
throws IOException, ServletException {
//省略部分代码
// Call the next filter if there is one
if (pos < n) {
//省略部分代码
ApplicationFilterConfig filterConfig = filters[pos++];
Filter filter = filterConfig.getFilter();
filter.doFilter(request, response, this);
return;
}
//调用servlet
// We fell off the end of the chain -- call the servlet instance
servlet.service(request, response);
复制代码
通过源码我们发现，在调用完所有的过滤器( Filter )之后， servlet 就开始调用 service 。我们看看 servlet 的实现类
这里我们熟悉的 HttpServlet 和 GenericServlet 是 Tomcat 包的类，实际上只有 HttpServlet ，因为 GenericServlet 是 HttpServlet 的父类。后面就是移交给了框架去处理了,Tomcat内部的请求已经到此是完成了。
Tomcat的多应用隔离实现
我们知道，Tomcat是支持部署多个应用的，那么Tomcat是如何支持多应用的部署呢？是怎么保证多个应用之间不会混淆的呢？要想弄懂这个问题，我们还是要回到适配器去说起，回到 service 方法
//源码11.类：CoyoteAdapter
public void service(org.apache.coyote.Request req, org.apache.coyote.Response res)
throws Exception {
//省略部分代码
// Parse and set Catalina and configuration specific
// request parameters
//处理URL映射
postParseSuccess = postParseRequest(req, request, res, response);
if (postParseSuccess) {
//check valves if we support async
request.setAsyncSupported(
connector.getService().getContainer().getPipeline().isAsyncSupported());
// Calling the container
connector.getService().getContainer().getPipeline().getFirst().invoke(
request, response);
}
}
复制代码
我们在之前的源码中只谈到了 connector.getService().getContainer().getPipeline().getFirst().invoke( request, response) 这段代码，这部分代码是调用容器，但是在调用容器之前有个 postParseRequest 方法是用来处理映射请求的，我们跟进看看源码：
//源码12.类：CoyoteAdapter
protected boolean postParseRequest(org.apache.coyote.Request req, Request request,
org.apache.coyote.Response res, Response response) throws IOException, ServletException {
省略部分代码
boolean mapRequired = true;
while (mapRequired) {
// This will map the the latest version by default
connector.getService().getMapper().map(serverName, decodedURI,
version, request.getMappingData());
//没有找到上下文就报404错误
if (request.getContext() == null) {
// Don't overwrite an existing error
if (!response.isError()) {
response.sendError(404, "Not found");
}
// Allow processing to continue.
// If present, the error reporting valve will provide a response
// body.
return true;
}
}
复制代码
这里就是循环去处理Url映射，如果 Context 没有找到，就返回404错误，我们继续看源码：
//源码13.类：Mapper
public void map(MessageBytes host, MessageBytes uri, String version,
MappingData mappingData) throws IOException {
if (host.isNull()) {
String defaultHostName = this.defaultHostName;
if (defaultHostName == null) {
return;
}
host.getCharChunk().append(defaultHostName);
}
host.toChars();
uri.toChars();
internalMap(host.getCharChunk(), uri.getCharChunk(), version, mappingData);
}
//源码14.类：Mapper
private final void internalMap(CharChunk host, CharChunk uri,
String version, MappingData mappingData) throws IOException {
//省略部分代码
// Virtual host mapping 处理Host映射
MappedHost[] hosts = this.hosts;
MappedHost mappedHost = exactFindIgnoreCase(hosts, host);
//省略部分代码
if (mappedHost == null) {
mappedHost = defaultHost;
if (mappedHost == null) {
return;
}
}
mappingData.host = mappedHost.object;
// Context mapping 处理上下文映射
ContextList contextList = mappedHost.contextList;
MappedContext[] contexts = contextList.contexts;
//省略部分代码
if (context == null) {
return;
}
mappingData.context = contextVersion.object;
mappingData.contextSlashCount = contextVersion.slashCount;
// Wrapper mapping 处理Servlet映射
if (!contextVersion.isPaused()) {
internalMapWrapper(contextVersion, uri, mappingData);
}
}
复制代码
由于上面的源码比较多，我省略了很多代码，保留了能理解主要逻辑的代码，总的来说就是处理Url包括三部分，映射 Host ，映射 Context 和映射 Servlet (为了节省篇幅，具体细节源码请感兴趣的同学自行研究)。
这里我们可以发现一个细节，就是三个处理逻辑都是紧密关联的，只有 Host 不为空才会处理 Context ,对于 Servlet 也是同理。所以这里我们只要 Host 配置不同，那么后面所有的子容器都是不同的，也就完成了应用隔离的效果。但是对于SpringBoot内嵌Tomcat方式(使用jar包启动)来说，并不具备实现多应用的模式，本身一个应用就是一个Tomcat。
为了便于理解，我也画了一张多应用隔离的图，这里我们假设有两个域名 admin.luozhou.com 和 web.luozhou.com 然后我每个域名下部署2个应用，分别是 User , log , blog , shop 。那么当我去想去添加用户的时候，我就会请求 admin.luozhou.com 域名下的 User 的 Context 下面的 add 的Servlet( 说明：这里例子设计不符合实际开发原则，add这种粒度应该是框架中的controller完成，而不是Servlet )。
总结
这篇文章我们研究了Tomcat中容器是如何处理请求的，我们来回顾下内容：
- 连接器把请求丢给适配器适配后调用容器(
Engine) - 容器内部是通过管道(
Pieline)-阀门(Valve)模式完成容器的调用的,父容器调用子容器主要通过一个basic的阀门来完成的。 - 最后一个子容器
wrapper完成调用后就会构建过滤器来进行过滤器调用，调用完成后就到了Tomcat内部的最后一步，调用servlet。也可以理解我们常用的HttpServlet，所有基于Servlet规范的框架在这里就进入了框架流程（包括SpringBoot）。 - 最后我们还分析了Tomcat是如何实现多应用隔离的，通过多应用的隔离分析，我们也明白了为什么Tomcat要设计如此多的子容器，多子容器可以根据需要完成不同粒度的隔离级别来实现不同的场景需求。
版权声明：原创文章，转载请注明出处。
正文到此结束
热门推荐
相关文章
近期评论
-
文章和留言都翻到11页了 没有OOM
-
-
朋友，翻页到11页，及以后，会出现OOM，无法访问
-
-
搞个gitee的项目
-
-
版本号是多少，你可以下载哪个代码仓库，jdk选1.8 直接跑就行
-
-
-
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
