tomcat分配请求之——请求如何流程Connection

 

首先摘自我的好友。傻博语录：人生就是悲剧

 

上次说到每一个请求会分配给一个Worker处理，而Worker与我们平时写代码都是围绕Servlet写的，到底又有些什么差别呢？

worker后面是委托给Handler处理的。

handler处理的时候分配给Http11Processor(Http11Processor被维护在一个先进先出队列当中)。

而所有的HttpProcessor共享Http11Protocal 的Adapter成员变量，Adapter会调用到Servlet，即所有Handler都用同一个Adapter。

首先请看图：

 讲述下每个部分的作用：

 

JioEndPointer:启动一个线程监听socket，并把到来的请求分配给相应的worker

Http11ConnectionHandler: Http协议的基于普通IO的处理方式.

Adapter:Http协议的请求 委托或 适配给 servlet容器处理的适配器

attributes:Http协议的相关属性设置

其中的对应关系也非常重要：

A,1个worker 必须对应一个 Http11ConnectionHandler 中的Http11ConnectionProcessor（是handler里面真正处理的Http协议的类）

 

B,所有的worker都持有同一个Adapter

 

 

 

详细类图下图所示：

 

 

 

我在HttpServlet的service方法里设置了一个断点，然后调试了下，可以看一下调用栈。 

 调用栈很清晰得说明了调用到哪些类和顺序:也可以看官方化得时序图： 

http://tomcat.apache.org/tomcat-6.0-doc/architecture/requestProcess/requestProcess.pdf

 

 

 

JIoEndpoint.java

/** * Create (or allocate) and return an available processor for use in * processing a specific HTTP request, if possible. If the maximum * allowed processors have already been created and are in use, return * <code>null</code> instead. */ protected Worker createWorkerThread() { synchronized (workers) { if (workers.size() > 0) { curThreadsBusy++; return workers.pop(); } if ((maxThreads > 0) && (curThreads < maxThreads)) {              // 默认maxThreads 为200 curThreadsBusy++; if (curThreadsBusy == maxThreads) { log.info(sm.getString("endpoint.info.maxThreads", Integer.toString(maxThreads), address, Integer.toString(port))); } return (newWorkerThread()); } else { if (maxThreads < 0) { curThreadsBusy++; return (newWorkerThread()); } else { return (null); } } } } /** * Create and return a new processor suitable for processing HTTP * requests and returning the corresponding responses. */ protected Worker newWorkerThread() { Worker workerThread = new Worker(); workerThread.start(); return (workerThread); }

 

 

从代码来看，如果没有到达请求最大值，首先会从栈中取得空闲的Worker，或者创建新的Worker。

 

所以来一个请求，会分配给一个Worker，而Worker做了一些接收Socket，设置一些socket和需要的环境类，然后就交给了Servlet实例,而servlet实例启动的时候就是对于一个context 中配置的一个servlet只启动一个实例。

 

 StandardWrapper.java

/** * Load and initialize an instance of this servlet, if there is not already * at least one initialized instance. This can be used, for example, to * load servlets that are marked in the deployment descriptor to be loaded * at server startup time. */ public synchronized Servlet loadServlet() throws ServletException { // Nothing to do if we already have an instance or an instance pool // 初始化servlet的时候，如果发现已经初始化完毕，则不再初始化 if (!singleThreadModel && (instance != null)) return instance;

 

 

所以首先servlet不是线程安全的。

其次 HttpSession不是线程安全的。

还有 Context不是现成安全的。

 

Request是线程安全的。