91精品国产综合久久久久久 ,国产五月天在线,99国产精品久久久久久久

接上一篇，說到 XmlConfiguration , XmlConfiguration 利用自己實現的 IOC 組裝 Server 的全過程如下圖所示：

這里可以看到 3 個關鍵的配置文件， jetty.xml 、 jetty-deploy.xml 、以及 contexts/xxx.xml

l Jetty.xml 文件中定義了入口類 Server, 以及其所需要的線程池、 Connector 、 Handler 。

l Jetty-deploy.xml 中則定義了部署 web 應用用到部署工具，在其中指定了部署 web 應用的兩種方式，類似于 tomcat, 如果采用 webappProvider ，則表示將 web 應用放在 webapp 下即可生效，如果采用 ContextProvider ，則需要定義 Contexts 目錄所在位置，只要在該目錄下放置任何應用的 context 配置文件就可以生效。

l Xxx.xml 這是一個用戶自定義文件，表示采用 ContextProvider 時，在其中定義一個 WebAppContext 的 handler, 它指定了我們應用所在的位置，便于加載。

XmlConfiguration 解析裝配完畢之后，就開始啟動服務， Jetty 的啟動是從 Server 開始的，我們來看一下服務器真正的啟動過程。

從上圖中我們能大概看出服務器啟動過程，先是由用戶設置好需要的核心組件，然后調用 Server.start() 開始啟動服務，其中會首先啟動 handler 處理器，之后啟動用戶自定義組件，這個自定義組件需要實現 LifeCyle 接口，最后才啟動 Connector 接受請求。可以想到，關閉過程恰好是反過來，首先關閉接受請求的 connector ，然后再關閉用戶自定義組件，最后關閉 handler.

我們再來詳細看一下 Server 源代碼的核心實現過程，當調用 start 方法時，其實是調用其祖先類 AbstractLifeCycle 中方法，該方法在這里有一個模板實現，如下：

public final void start() throws Exception { synchronized (_lock) { try { if (_state == __STARTED || _state == __STARTING) return; setStarting(); doStart(); setStarted(); } catch (Exception e) { setFailed(e); throw e; } catch (Error e) { setFailed(e); throw e; } } }

Connector 啟動過程

看下 Connector 的詳細啟動過程： ( 以 NIO 為例 )

NIOConnector 啟動過程中，先創建了多個 SelectSet 對象，每個 SelectSet 負責一個 NIO 的 Selector ，專門用于監聽 read 事件 ( 這里利用的多線程 Reactor 模式， http://gee.cs.oswego.edu/dl/cpjslides/nio.pdf ) ，當然這里僅僅是創建了對象，并沒有啟動，后面會提到。

SelectorManager ：

然后再調用 open 創建了一個 blocking 的阻塞 channel ，專門用于接受用戶的新連接，我們看下：

public void open() throws IOException { synchronized(this) { if (_acceptChannel == null) { // Create a new server socket _acceptChannel = ServerSocketChannel.open(); // Set to blocking mode _acceptChannel.configureBlocking(true); // Bind the server socket to the local host and port _acceptChannel.socket().setReuseAddress(getReuseAddress()); InetSocketAddress addr = getHost()==null?new InetSocketAddress(getPort()):new InetSocketAddress(getHost(),getPort()); _acceptChannel.socket().bind(addr,getAcceptQueueSize()); _localPort=_acceptChannel.socket().getLocalPort(); if (_localPort<=0) throw new IOException("Server channel not bound"); } } }

隨后從線程池中分配了 N 個 ( 可以在配置文件中配置 ) 線程用于啟動 SelectSet 監聽 read 事件。

synchronized (this) { _acceptorThread = new Thread[getAcceptors()]; for (int i = 0; i < _acceptorThread.length; i++) _threadPool.dispatch(new Acceptor(i)); if (_threadPool.isLowOnThreads()) Log.warn("insufficient threads configured for {}",this); }

最后再分配 1 個線程用于 accept 用戶的新連接，新連接來之后，會將其設置為 nonblocking 模式，之后就將其 Register 給某個 SelectSet 去監聽 read 事件，然后又返回來繼續監聽新連接：

_manager.dispatch(new Runnable() { public void run() { final ServerSocketChannel server=_acceptChannel; while (isRunning() && _acceptChannel==server && server.isOpen()) { try { SocketChannel channel = server.accept(); channel.configureBlocking(false); Socket socket = channel.socket(); configure(socket); _manager.register(channel); } catch(IOException e) { Log.ignore(e); } } } });

Handler 啟動過程

Jetty 將所有的真正處理請求的動作都抽象成了 Handler ，因此做事情的組件都是實現了這個接口的，包括上圖所示的 WebAppContext 等等，需要做什么樣的工作，那么就添加什么樣的 Handler ，這里 SessionHandler 不是必須的，但是默認是創建好的。 ServletHandler 主要負責處理 web 應用的 Servlet 、 Filter 等工作，最后將請求直接交給 Servlet 、 Filter 都是在這里完成。

這里展示的 Handler 的啟動過程其實是在準備 web 應用環境，例如解析 web 應用的 web.xml 等等工作，做好一切準備工作。

Jetty 服務器架構分析(中)

更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索：z360901061

微信掃一掃加我為好友

QQ號聯系： 360901061

您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。

【本文對您有幫助就好】元

2元

5元

10元

20元

自定義