Tomcat請求處理(二) -- 請求處理框架

1、T omcat 請求處理 (二 - 請求處理框架當 Tomcat 的 Acceptor 監(jiān)聽到有請求到來時, 就會結束阻塞, 繼續(xù)進行程序下面的動作。 如 下面的代碼所示:public void run( while (running while (paused try Thread.sleep(1000; catch (InterruptedException e try / 開始監(jiān)聽端口Socket socket = serverSocketFactory.acceptSocket(serverSocket; / 初始化 SocketserverSocketFactory.initSock

2、et(socket;/ 處理 Socketif (!processSocket(socket try socket.close(; catch (IOException e catch (IOException x if (runninglog.error(sm.getString("endpoint.accept.fail", x; catch (Throwable t log.error(sm.getString("endpoint.accept.fail", t;結束阻塞后,首先是 Socket 的初始化,由于 ServerSocketFactor

3、y 的實現類 DefaultServerSocketFactory 并沒有擴展 initSocket(方法,所以這一步其實是什么都沒 做的。接下來程序執(zhí)行到了 .JIoEcessSocket(socket;這一步了,這個方法的源代碼如下所示:protected boolean processSocket(Socket socket try if (executor = null / 得到一個 Work 并為它分配這個 SocketgetWorkerThread(.assign(socket; else executor.execute(new SocketProcesso

4、r(socket; catch (Throwable t log.error(sm.getString("cess.fail", t;return false;return true;hxzon :這里提供了 jdk5 executor+SocketProcessor和 tomcat 自己的 worker 實現。使用 jdk5 executor簡潔許多。executor 是一個外部的基于線程池的執(zhí)行器, 先不去考慮它, 重點看一下 getWorkerThread(和 Worker#assign(getWorkerThread(的源代碼如下:prote

5、cted Worker getWorkerThread( / 獲取一個 WorkerWorker workerThread = createWorkerThread(;while (workerThread = null / 如果獲取的 Worker 為 Nulltry synchronized (workers / 等待 workers 里邊 Worker 的回收, recycleWorkerThread(中會調用 notify 通知這個線程結束等待的workers.wait(; catch (InterruptedException e / 等待結束,再次獲取一個 Workerworker

6、Thread = createWorkerThread(;return workerThread;這里這個 createWorkerThread(也就是獲取 Worker 的方法值得研究一下。protected Worker createWorkerThread( synchronized (workers if (workers.size( > 0 / 如果堆棧中有剩余的 Worker/ 當前在使用的 Worker 線程計數curThreadsBusy+;/ 將一個 Worker 推出堆棧return workers.pop(;/ 如果堆棧中沒有多余的 Worker 了,那么創(chuàng)建一個。

7、if (maxThreads > 0 && (curThreads < maxThreads / 如果 maxThreads 有定義,并且當前的 Worker 數量小于這個值。/ 在 recycleWorkerThread(中會將新創(chuàng)建的 Worker 放入堆棧的curThreadsBusy+;return (newWorkerThread(; else if (maxThreads < 0 / maxThreads沒有定義,可以有無限個 Worker 的情況。curThreadsBusy+;return (newWorkerThread(; else ret

8、urn (null;而 newWorkerThread(方法還是很好理解的:protected Worker newWorkerThread( Worker workerThread = new Worker(;workerThread.start(;return (workerThread;創(chuàng)建一個 Worker 線程,并且開啟線程。經過上述的過程,就獲得了一個 Worker(并且已經開始運行了 ,那么程序的下一步是調用 Worker 的 assign(方法:synchronized void assign(Socket socket / 等待獲取完上一個 Socketwhile (avai

9、lable try wait(; catch (InterruptedException e / 保存新的 Socketthis.socket = socket;available = true;notifyAll(;這樣新的 Worker 已經有一個 Socket 對象去處理了,下面來看一下 Worker 的線程中做了哪 些工作。public void run( / 知道收到停止信號,否則一直循環(huán)while (running / 等待為這個線程設置一個 Socket 對象Socket socket = await(;if (socket = nullcontinue;/ 處理請求if (!s

10、etSocketOptions(socket | !cess(socket / 關閉 Sockettry socket.close(; catch (IOException e / 回收 Workersocket = null;recycleWorkerThread(this;其中 await(用于等待有 Socket 對象賦給當前的 Worker 已進行請求處理,代碼如下: private synchronized Socket await( / 等待獲取 Socketwhile (!available try wait(; catch (InterruptedExce

11、ption e / Socket已經收到Socket socket = this.socket;available = false;/ 這個 notifyAll(是通知 assign(中的等待 Socket 的處理已經開始了, / 可以為這個 Worker 賦新的值了。notifyAll(;return (socket;而 setSocketOptions(用于設定一些 Socket 的參數,如下所示:protected boolean setSocketOptions(Socket socket int step = 1;try if (soLinger >= 0 socket.set

12、SoLinger(true, soLinger;if (tcpNoDelay socket.setTcpNoDelay(tcpNoDelay;if (soTimeout > 0 socket.setSoTimeout(soTimeout;step = 2;serverSocketFactory.handshake(socket; catch (Throwable t if (log.isDebugEnabled( if (step = 2 log.debug(sm.getString("endpoint.err.handshake", t; else log.debug(sm.getString("endpoint.err.unexpected", t; return false;return true;cess(socket封裝了處理請求的全過程,下次再詳細了解而最后的 recycleWorkerThread(用于回收 Worker 到堆棧中以備下次使用: prot