Tomcat請(qǐng)求處理(二)--請(qǐng)求處理框架

1、T omcat 請(qǐng)求處理 (二 - 請(qǐng)求處理框架當(dāng) Tomcat 的 Acceptor 監(jiān)聽到有請(qǐng)求到來時(shí), 就會(huì)結(jié)束阻塞, 繼續(xù)進(jìn)行程序下面的動(dòng)作。 如 下面的代碼所示: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 (running catch (Throwable t 結(jié)束阻塞后,首先是 Socket 的初始化,由于 ServerSocketFactory 的實(shí)現(xiàn)類 DefaultServerSocketFactory 并沒有擴(kuò)展 initSocket(方法,所以這一步其實(shí)是什么都沒 做的。protected boolean processSocket(Socket socket tr

3、y if (executor = null / 得到一個(gè) Work 并為它分配這個(gè) SocketgetWorkerThread(.assign(socket; else executor.execute(new SocketProcessor(socket; catch (Throwable t return false;return true;hxzon :這里提供了 jdk5 executor+SocketProcessor和 tomcat 自己的 worker 實(shí)現(xiàn)。使用 jdk5 executor簡潔許多。executor 是一個(gè)外部的基于線程池的執(zhí)行器, 先不去考慮它, 重點(diǎn)看一下

4、getWorkerThread(和 Worker#assign(getWorkerThread(的源代碼如下:protected Worker getWorkerThread( / 獲取一個(gè) WorkerWorker workerThread = createWorkerThread(;while (workerThread = null / 如果獲取的 Worker 為 Nulltry synchronized (workers / 等待 workers 里邊 Worker 的回收, recycleWorkerThread(中會(huì)調(diào)用 notify 通知這個(gè)線程結(jié)束等待的workers.wai

5、t(; catch (InterruptedException e / 等待結(jié)束,再次獲取一個(gè) WorkerworkerThread = createWorkerThread(;return workerThread;這里這個(gè) createWorkerThread(也就是獲取 Worker 的方法值得研究一下。protected Worker createWorkerThread( synchronized (workers if (workers.size( > 0 / 如果堆棧中有剩余的 Worker/ 當(dāng)前在使用的 Worker 線程計(jì)數(shù)curThreadsBusy+;/ 將一個(gè)

6、Worker 推出堆棧return workers.pop(;/ 如果堆棧中沒有多余的 Worker 了,那么創(chuàng)建一個(gè)。if (maxThreads > 0 && (curThreads < maxThreads / 如果 maxThreads 有定義,并且當(dāng)前的 Worker 數(shù)量小于這個(gè)值。/ 在 recycleWorkerThread(中會(huì)將新創(chuàng)建的 Worker 放入堆棧的curThreadsBusy+;return (newWorkerThread(; else if (maxThreads < 0 / maxThreads沒有定義,可以有無限個(gè) W

7、orker 的情況。curThreadsBusy+;return (newWorkerThread(; else return (null;而 newWorkerThread(方法還是很好理解的:protected Worker newWorkerThread( Worker workerThread = new Worker(;workerThread.start(;return (workerThread;創(chuàng)建一個(gè) Worker 線程,并且開啟線程。經(jīng)過上述的過程,就獲得了一個(gè) Worker(并且已經(jīng)開始運(yùn)行了 ,那么程序的下一步是調(diào)用 Worker 的 assign(方法:synchro

8、nized void assign(Socket socket / 等待獲取完上一個(gè) Socketwhile (available try wait(; catch (InterruptedException e / 保存新的 Socketthis.socket = socket;available = true;notifyAll(;這樣新的 Worker 已經(jīng)有一個(gè) Socket 對(duì)象去處理了,下面來看一下 Worker 的線程中做了哪 些工作。public void run( / 知道收到停止信號(hào),否則一直循環(huán)while (running / 等待為這個(gè)線程設(shè)置一個(gè) Socket 對(duì)象S

9、ocket socket = await(;if (socket = nullcontinue;/ 處理請(qǐng)求if (!setSocketOptions(socket | !cess(socket / 關(guān)閉 Sockettry socket.close(; catch (IOException e / 回收 Workersocket = null;recycleWorkerThread(this;其中 await(用于等待有 Socket 對(duì)象賦給當(dāng)前的 Worker 已進(jìn)行請(qǐng)求處理,代碼如下: private synchronized Socket await( / 等待

10、獲取 Socketwhile (!available try wait(; catch (InterruptedException e / Socket已經(jīng)收到Socket socket = this.socket;available = false;/ 這個(gè) notifyAll(是通知 assign(中的等待 Socket 的處理已經(jīng)開始了, / 可以為這個(gè) Worker 賦新的值了。notifyAll(;return (socket;而 setSocketOptions(用于設(shè)定一些 Socket 的參數(shù),如下所示:protected boolean setSocketOptions(So

11、cket socket int step = 1;try if (soLinger >= 0 socket.setSoLinger(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 return false;return true;cess(socket封裝了處理請(qǐng)求的全過程,下次再詳細(xì)了解而最后的 recycleWorkerThread(用于回收 Worker 到堆棧中以備下次使用: protected void recycl