概述
Jetty作為HTTP服務(wù)器，服務(wù)器和客戶(hù)端以HTTP協(xié)議格式通信，Jetty使用Parser（HttpParser）來(lái)抽象HTTP請(qǐng)求消息和響應(yīng)消息的解析類(lèi)引擎。在HttpParser實(shí)現(xiàn)中，它采用有限狀態(tài)機(jī)算法：定義了21中狀態(tài)，每解析一個(gè)字符，就根據(jù)當(dāng)前的狀態(tài)做相應(yīng)的處理，并決定是否要遷移到下一個(gè)狀態(tài)，直到HTTP請(qǐng)求消息或響應(yīng)消息解析完成。HttpParser采用事件驅(qū)動(dòng)機(jī)制，它定義了EventHandler類(lèi)，用戶(hù)可以通過(guò)注冊(cè)的EventHandler實(shí)例獲取相應(yīng)的消息：請(qǐng)求行解析完成(startRequest)、響應(yīng)行解析完成(startResponse)、每個(gè)消息頭解析完成(parsedHeader)、所有消息頭解析完成(headerComplete)、消息內(nèi)容解析完成(content)、整個(gè)消息(請(qǐng)求消息或響應(yīng)消息)解析完成(messageComplete)。
Parser接口定義
public interface Parser {
// 重置Parser的內(nèi)部狀態(tài)，以重用Parser實(shí)例，如果returnBuffers為true，則將內(nèi)部Buffer回收。
void reset(boolean returnBuffers);
// 當(dāng)前Parser是否已經(jīng)解析完成。
boolean isComplete();
// 當(dāng)前Parser是否處于Idle狀態(tài)，它還處于初始狀態(tài)，解析還沒(méi)有開(kāi)始。
boolean isIdle();
// 內(nèi)部Buffer是否還有內(nèi)容沒(méi)有解析。
boolean isMoreInBuffer() throws IOException;
// 開(kāi)始解析已接收到的消息，返回-1表示解析到流的末位，0表示沒(méi)有該次調(diào)用沒(méi)有解析任何消息，>0表示這次調(diào)用總共解析過(guò)的字節(jié)數(shù)。
int parseAvailable() throws IOException;
}
EventHandler定義
public static abstract class EventHandler {
// 消息內(nèi)容解析完成
public abstract void content(Buffer ref) throws IOException;
// 所有消息頭解析完成
public void headerComplete() throws IOException {
}
// 整個(gè)消息(請(qǐng)求消息或響應(yīng)消息)解析完成
public void messageComplete(long contentLength) throws IOException {
}
// 每個(gè)消息頭解析完成
public void parsedHeader(Buffer name, Buffer value) throws IOException {
}
// 請(qǐng)求行解析完成
public abstract void startRequest(Buffer method, Buffer url, Buffer version)
throws IOException;
// 響應(yīng)行解析完成
public abstract void startResponse(Buffer version, int status, Buffer reason)
throws IOException;
}
EventHandler的實(shí)現(xiàn)類(lèi)
在HttpConnection的內(nèi)部類(lèi)RequestHandler類(lèi)實(shí)現(xiàn)了HttpParser.EventHandler類(lèi)，以作為HttpParser使用時(shí)的回調(diào)。
startRequest：重置當(dāng)前HttpConnection狀態(tài)，HttpRequest的時(shí)間戳，設(shè)置新解析出來(lái)的RequestMethod、URI、version信息。parsedHeader：將每個(gè)HTTP頭(name, value)對(duì)添加到_requestFields字段中，并檢查某些頭的存在性以及其值的合法性。
1. 如果“host”頭存在，則設(shè)置_host為true。
2. 對(duì)“Expect”頭，如果其值是“100-continue”，設(shè)置_expect100Continue為true，若值是“102-processing”，設(shè)置_expect102Processing值為true，當(dāng)信息不足時(shí)，設(shè)置_expect為true。
3. 對(duì)“Accept-Encoding”和“User-Agent”頭，只能是預(yù)定義的值。
4. 對(duì)“Content-Type”頭只能是預(yù)定義的值，并且根據(jù)該值設(shè)置_charset字段。
5. 對(duì)“Connectin”頭，如果是“close”值，則設(shè)置HttpGenerator的persistent屬性為false，并且設(shè)置_responseFields的“Connection”值為“close”，否則為“keep-alive”。
headerComplete：在HTTP消息頭解析結(jié)束后，對(duì)AsyncEndpoint，調(diào)用其scheduleIdle()方法，設(shè)置HttpGenerator中的HTTP version字段，以及當(dāng)前請(qǐng)求是否為HEAD請(qǐng)求，如果當(dāng)前Server配置了sendDateHeader，則設(shè)置HttpGenerator的Date字段為HttpRequest的時(shí)間戳(在startRequest方法調(diào)用是設(shè)置)。對(duì)HTTP/1.1，如果沒(méi)有設(shè)置Host頭，直接返回400響應(yīng)(調(diào)用_generator的completeHeader和complete方法)；如果expect為true，表示Expect頭設(shè)置有問(wèn)題，直接返回417響應(yīng)(調(diào)用_generator的completeHeader和complete方法)。設(shè)置_charset字段，對(duì)CHUNK請(qǐng)求立即開(kāi)始處理請(qǐng)求(handleRequest)，否則延遲到消息讀取完成。
content：對(duì)AsyncEndPoint，調(diào)用其scheduleIdle()方法，如果請(qǐng)求還未開(kāi)始處理，則立即開(kāi)始處理請(qǐng)求。
messageComplete：如果請(qǐng)求還未開(kāi)始處理，則立即開(kāi)始處理請(qǐng)求。
注：這里并沒(méi)有在content方法中保存消息體的內(nèi)容，在Jetty中使用HttpInput類(lèi)從HttpParser中直接讀取消息體的內(nèi)容(通過(guò)HttpInput的read方法調(diào)用HttpParser.blockForContent()方法)。
HttpPaser有限狀態(tài)機(jī)實(shí)現(xiàn)
在HttpParser中定義了21中狀態(tài)，其中STATE_END以前的狀態(tài)用于解析HTTP頭消息，而STATE_END以后的狀態(tài)用于解析HTTP消息體。它們各自的狀態(tài)遷移圖如下。
HttpParser在解析HTTP消息頭時(shí)的狀態(tài)遷移圖
HttpParser在解析HTTP消息體時(shí)的狀態(tài)遷移圖
HttpParser在HttpConnection類(lèi)中的使用
HttpParser在HttpConnection中的handle方法被調(diào)用時(shí)用于解析客戶(hù)端過(guò)來(lái)的HTTP請(qǐng)求消息。
if (!_parser.isComplete()) {
int parsed=_parser.parseAvailable();
if (parsed>0)
progress=true;
}
posted on 2014-04-19 18:31
DLevin 閱讀(2511)
評(píng)論(3) 編輯 收藏 所屬分類(lèi):
Jetty