`
lengyun3566
  • 浏览: 456237 次
  • 性别: Icon_minigender_1
  • 来自: 大连
博客专栏
D59180b9-02f1-3380-840c-ea34da46143c
《Spring Secur...
浏览量:386063
社区版块
存档分类
最新评论

Tomcat源码解读系列(三)——Tomcat对HTTP请求处理的整体流程

 
阅读更多

 

声明:源码版本为Tomcat 6.0.35

前面的文章中介绍了Tomcat初始化的过程,本文将会介绍TomcatHTTP请求的处理的整体流程,更细节的。

在上一篇文章中,介绍到JIoEndpoint 中的内部类Acceptor用来接受Socket请求,并调用processSocket方法来进行请求的处理,所以会从本文这个方法开始进行讲解。

 

protected boolean processSocket(Socket socket) {
        try {
            if (executor == null) {
                getWorkerThread().assign(socket);
            } else {
                executor.execute(new SocketProcessor(socket));
            }
        } catch (Throwable t) {
            //……此处略去若干代码
        }
        return true;
    }

 在以上的代码中,首先会判断是否在server.xml配置了进程池,如果配置了的话,将会使用该线程池进行请求的处理,如果没有配置的话将会使用JIoEndpoint中自己实现的线程池WorkerStack来进行请求的处理,我们将会介绍WorkerStack的请求处理方式。

 

protected Worker getWorkerThread() {
        // Allocate a new worker thread
        synchronized (workers) {
            Worker workerThread;
            while ((workerThread = createWorkerThread()) == null) {
                try {
                    workers.wait();
                } catch (InterruptedException e) {
                    // Ignore
                }
            }
            return workerThread;
        }
    }

 在以上的代码中,最终返回了一个Worker的实例,有其来进行请求的处理,在这里,我们再看一下createWorkerThread方法,该方法会生成或者在线程池中取到一个线程。

 

protected Worker createWorkerThread() {
        synchronized (workers) {
            if (workers.size() > 0) {
            //如果线程池中有空闲的线程,取一个
                curThreadsBusy++;
                return workers.pop();
            }
            if ((maxThreads > 0) && (curThreads < maxThreads)) {
                //如果还没有超过最大线程数,会新建一个线程
                curThreadsBusy++;
                return (newWorkerThread());
            } else {
                if (maxThreads < 0) {
                    curThreadsBusy++;
                    return (newWorkerThread());
                } else {
                    return (null);
                }
            }
        }
    }

 到此,线程已经获取了,接下来,最关键的是调用线程实现Workerrun方法:

 

public void run() {
            // Process requests until we receive a shutdown signal
            while (running) {
                // Wait for the next socket to be assigned
                Socket socket = await();
                if (socket == null)
                    continue;
                   if (!setSocketOptions(socket) || !handler.process(socket)) {
                    try {
                        socket.close();
                    } catch (IOException e) {
                    }
                }
                socket = null;
                recycleWorkerThread(this);
            }
        }

 这里跟请求处理密切相关的是handler.process(socket)这一句代码,此处handle对应的类是Http11Protocol中的内部类Http11ConnectionHandler,在此后的处理中,会有一些请求的预处理,我们用一个时序图来表示一下:



 在这个过程中,会对原始的socket进行一些处理,到CoyoteAdapter时,接受的参数已经是org.apache.coyote.Requestorg.apache.coyote.Response了,但是要注意的是,此时这两个类并不是我们常用的HttpServletRequestHttpServletResponse的实现类,而是Tomcat内部的数据结构,存储了和输入、输出相关的信息。值得注意的是,在CoyoteAdapterservice方法中,会调用名为postParseRequest的方法,在这个方法中,会解析请求,调用MapperMap方法来确定该请求该由哪个EngineHostContext来处理。

在以上的信息处理完毕后,在CoyoteAdapterservice方法中,会调用这样一个方法:

 

connector.getContainer().getPipeline().getFirst().invoke(request, response);

 这个方法会涉及到Tomcat组件中的Container实现类的重要组成结构,即每个容器类组件都有一个pipeline属性,这个属性控制请求的处理过程,在pipeline上可以添加Valve,进而可以控制请求的处理流程。可以用下面的图来表示,请求是如何流动的:



 可以将请求想象成水的流动,请求需要在各个组件之间流动,中间经过若干的水管和水阀,等所有的水阀走完,请求也就处理完了,而每个组件都会有一个默认的水阀(以Standard作为类的前缀)来进行请求的处理,如果业务需要的话,可以自定义Valve,将其安装到容器中。

后面的处理过程就比较类似了,会按照解析出来的EngineHostContext的顺序来进行处理。这里用了两张算不上标准的时序图来描述这一过程:




 在以上的流程中,会一层层地调用各个容器组件的Valveinvoke方法,其中StandardWrapperValve这个标准阀门将会调用StandardWrapperallocate方法来获取真正要执行的Servlet(在Tomcat中所有的请求最终都会映射到一个Servlet,静态资源和JSP也是如此),并按照请求的地址来构建过滤器链,按照顺序执行各个过滤器并最终调用目标Servletservice方法,来完成业务的真正处理。

 

 

 

 

 

以上的处理过程中,涉及到很多重要的代码,后续的文章会择期要者进行解析,如:

      Mapper中的internalMapWrapper方法(用来匹配对应的Servlet

       ApplicationFilterFactorycreateFilterChain方法(用来创建该请求的过滤器链)

       ApplicationFilterChaininternalDoFilter方法(用来执行过滤器方法以及最后的Servlet

       Http11Processor中的process方法、prepareRequest方法以及prepareResponse方法(用来处理HTTP请求相关的协议、参数等信息)

至此,我们简单了解一个请求的处理流程。

  • 大小: 96.9 KB
  • 大小: 165.9 KB
  • 大小: 140.3 KB
  • 大小: 159.5 KB
6
0
分享到:
评论
5 楼 lengyun3566 2012-09-13  
1927105 写道
w156445045 写道
请问下博主是用的啥工具画图的啊?图不错,很赞。


同问

呵呵 edraw 叫做亿图图示专家
4 楼 lengyun3566 2012-09-13  
w156445045 写道
请问下博主是用的啥工具画图的啊?图不错,很赞。

呵呵 edraw 叫做亿图图示专家
3 楼 1927105 2012-09-12  
w156445045 写道
请问下博主是用的啥工具画图的啊?图不错,很赞。


同问
2 楼 w156445045 2012-09-10  
请问下博主是用的啥工具画图的啊?图不错,很赞。
1 楼 liuningbo 2012-09-10  
不错!顶起

相关推荐

    tomcat源码解析

    ### tomcat源码解析 #### 简介与概览 Tomcat作为一款开源的Servlet容器,被广泛应用于Java Web应用的开发与部署环境中。它不仅支持Servlet API,还支持JSP规范,使得开发者能够轻松地构建动态网页。本文旨在深入...

    Java毕业设计——学校管理系统设计与实现(源码+数据库).zip

    《Java毕业设计——学校管理系统设计与实现》是一...以上内容仅是对该毕业设计项目的一般性解读,具体实现细节还需参考源码和数据库设计。通过这个项目,学生可以深入理解Java Web开发的全流程,提升实际问题解决能力。

    【计算机网页程序设计项目源码】springboot486基于springboot的太原学院商铺管理系统--论文pf.zip

    通过研究本项目源码,初学者能够逐步掌握如何构建RESTful API、如何处理HTTP请求、如何实现数据持久化等Web开发中的关键技能。 对于进阶学习者或者那些已经有一定基础的开发者来说,本项目则可以作为一个很好的实践...

    精选_基于SSM实现旅游网站项目_源码打包

    "精选_基于SSM实现旅游网站项目_源码打包" 这个标题揭示了我们讨论的核心——一个精选的旅游网站项目,它采用的是SSM框架进行开发,并且提供了完整的源码供学习和参考。SSM是Spring、Spring MVC和MyBatis的缩写,这...

    jshopv2releasesource

    《Java商城源码解析——以jshopv2releasesource为例》 在电子商务领域,Java作为后端开发的主流语言,被广泛应用于构建各种类型的网上商城系统。"jshopv2releasesource"是一个基于Java的开源商城项目,它为我们提供...

    spring例子: jpetstore

    2. **Spring MVC**:Spring的Web应用开发模型,负责处理HTTP请求,协调模型、视图和控制器之间的交互。 3. **AOP**:面向切面编程,Spring用它来实现日志记录、性能监控、事务管理等功能,将关注点分离,提高代码...

Global site tag (gtag.js) - Google Analytics