Tomcat源碼解讀系列（三）——Tomcat對HTTP請求處理的整體流程

聲明：源碼版本為Tomcat 6.0.35

前面的文章中介紹了Tomcat初始化的過程，本文將會介紹Tomcat對HTTP請求的處理的整體流程，更細節的。

在上一篇文章中，介紹到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);
                }
            }
        }
    }

到此，線程已經獲取了，接下來，最關鍵的是調用線程實現Worker的run方法：

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.Request和org.apache.coyote.Response了，但是要注意的是，此時這兩個類並不是我們常用的HttpServletRequest和HttpServletResponse的實現類，而是Tomcat內部的數據結構，存儲了和輸入、輸出相關的信息。值得注意的是，在CoyoteAdapter的service方法中，會調用名為postParseRequest的方法，在這個方法中，會解析請求，調用Mapper的Map方法來確定該請求該由哪個Engine、Host和Context來處理。

在以上的信息處理完畢后，在CoyoteAdapter的service方法中，會調用這樣一個方法：

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

這個方法會涉及到Tomcat組件中的Container實現類的重要組成結構，即每個容器類組件都有一個pipeline屬性，這個屬性控制請求的處理過程，在pipeline上可以添加Valve，進而可以控制請求的處理流程。可以用下面的圖來表示，請求是如何流動的：

可以將請求想象成水的流動，請求需要在各個組件之間流動，中間經過若干的水管和水閥，等所有的水閥走完，請求也就處理完了，而每個組件都會有一個默認的水閥（以Standard作為類的前綴）來進行請求的處理，如果業務需要的話，可以自定義Valve，將其安裝到容器中。

后面的處理過程就比較類似了，會按照解析出來的Engine、Host、Context的順序來進行處理。這里用了兩張算不上標准的時序圖來描述這一過程：

在以上的流程中，會一層層地調用各個容器組件的Valve的invoke方法，其中StandardWrapperValve這個標准閥門將會調用StandardWrapper的allocate方法來獲取真正要執行的Servlet（在Tomcat中所有的請求最終都會映射到一個Servlet，靜態資源和JSP也是如此），並按照請求的地址來構建過濾器鏈，按照順序執行各個過濾器並最終調用目標Servlet的service方法，來完成業務的真正處理。

以上的處理過程中，涉及到很多重要的代碼，后續的文章會擇期要者進行解析，如：

• Mapper中的internalMapWrapper方法（用來匹配對應的Servlet）
• ApplicationFilterFactory的createFilterChain方法（用來創建該請求的過濾器鏈）
• ApplicationFilterChain的internalDoFilter方法（用來執行過濾器方法以及最后的Servlet）
• Http11Processor中的process方法、prepareRequest方法以及prepareResponse方法（用來處理HTTP請求相關的協議、參數等信息）

至此，我們簡單了解一個請求的處理流程。