org.voovan.http.message

Class HttpParser

java.lang.Object

org.voovan.http.message.HttpParser

public class HttpParser
extends Object

Http 报文解析类

Author:

helyho Voovan Framework. WebSite: https://github.com/helyho/Voovan Licence: Apache v2 License

Field Summary

Fields

Modifier and Type	Field and Description
static int	PARSER_TYPE_REQUEST
static int	PARSER_TYPE_RESPONSE

Method Summary

Modifier and Type	Method and Description
static Map<String,String>	getEqualMap(String str) 解析字符串中的所有等号表达式成 Map
static void	parseCookie(List<Cookie> cookies, int cookieType, String cookieValue) 处理消息的Cookie
static TreeMap<String,Object>	parseHeader(ByteBuffer byteBuffer, Runnable contiuneRead, int timeout) 解析 HTTP 请求 Header 中的一行
static boolean	parseHeaderLine(Map<String,Object> headerMap, ByteBuffer byteBuffer, Runnable contiuneRead, int timeout) 解析 HTTP 请求 Header 中的一行
static int	parseProtocol(Object[] packetMap, int type, ByteBuffer byteBuffer, Runnable contiuneRead, int timeout) 解析 HTTP 请求写一行
static Object[]	parser(IoSession session, Object[] packetMap, int type, ByteBufferChannel byteBufferChannel, int timeout, long requestMaxSize) 解析 HTTP 报文 解析称 Map 形式,其中: 1.protocol 解析成 key/value 形式 2.header 解析成 key/value 形式 3.cookie 解析成 List[Map[String,String]] 形式 3.part 解析成 List[Map[Stirng,Object]](因为是递归,参考 HTTP 解析形式) 形式 5.body 解析成 key=BODY_VALUE 的Map 元素
static Request	parseRequest(IoSession session, ByteBufferChannel byteBufferChannel, int timeOut, long requestMaxSize) 解析报文成 HttpRequest 对象
static Request	parseRequest(Request request, IoSession session, ByteBufferChannel byteBufferChannel, int timeOut, long requestMaxSize) 解析报文成 HttpRequest 对象
static Response	parseResponse(IoSession session, ByteBufferChannel byteBufferChannel, int timeOut) 解析报文成 HttpResponse 对象
static Response	parseResponse(Response response, IoSession session, ByteBufferChannel byteBufferChannel, int timeOut) 解析报文成 HttpResponse 对象
static void	resetThreadLocal()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PARSER_TYPE_REQUEST

public static final int PARSER_TYPE_REQUEST

See Also:

Constant Field Values

PARSER_TYPE_RESPONSE

public static final int PARSER_TYPE_RESPONSE

See Also:

Constant Field Values

Method Detail

getEqualMap

public static Map<String,String> getEqualMap(String str)

解析字符串中的所有等号表达式成 Map

Parameters:

str - 等式表达式

Returns:

等号表达式 Map

parseCookie

public static void parseCookie(List<Cookie> cookies,
                               int cookieType,
                               String cookieValue)

处理消息的Cookie

Parameters:

cookies - Cookie 保存集合

cookieType - Cookie 类型 0: request, 1: response

cookieValue - Cookie 数据

parseProtocol

public static int parseProtocol(Object[] packetMap,
                                int type,
                                ByteBuffer byteBuffer,
                                Runnable contiuneRead,
                                int timeout)

解析 HTTP 请求写一行

Parameters:

packetMap - 解析后数据的容器

type - 解析的报文类型

byteBuffer - ByteBuffer对象

contiuneRead - 当数据不足时的读取器

timeout - 读取超时时间参数

Returns:

协议行的 hash

parseHeaderLine

public static boolean parseHeaderLine(Map<String,Object> headerMap,
                                      ByteBuffer byteBuffer,
                                      Runnable contiuneRead,
                                      int timeout)

解析 HTTP 请求 Header 中的一行

Parameters:

headerMap - 解析后数据的容器

byteBuffer - ByteBuffer对象

contiuneRead - 当数据不足时的读取器

timeout - 读取超时时间参数

Returns:

true: Header解析未完成, false: Header解析完成

parseHeader

public static TreeMap<String,Object> parseHeader(ByteBuffer byteBuffer,
                                                 Runnable contiuneRead,
                                                 int timeout)

解析 HTTP 请求 Header 中的一行

Parameters:

byteBuffer - ByteBuffer对象

contiuneRead - 当数据不足时的读取器

timeout - 读取超时时间参数

Returns:

true: Header解析未完成, false: Header解析完成

parser

public static Object[] parser(IoSession session,
                              Object[] packetMap,
                              int type,
                              ByteBufferChannel byteBufferChannel,
                              int timeout,
                              long requestMaxSize)
                       throws IOException

解析 HTTP 报文 解析称 Map 形式,其中: 1.protocol 解析成 key/value 形式 2.header 解析成 key/value 形式 3.cookie 解析成 List[Map[String,String]] 形式 3.part 解析成 List[Map[Stirng,Object]](因为是递归,参考 HTTP 解析形式) 形式 5.body 解析成 key=BODY_VALUE 的Map 元素

Parameters:

session - socket 会话对象

packetMap - 用于填充的解析 map

type - 解析的报文类型, 0: Request, 1: Response

byteBufferChannel - 输入流

timeout - 读取超时时间参数

requestMaxSize - 上传文件的最大尺寸, 单位: kb

Returns:

解析后的 Map

Throws:

IOException - IO 异常

parseRequest

public static Request parseRequest(IoSession session,
                                   ByteBufferChannel byteBufferChannel,
                                   int timeOut,
                                   long requestMaxSize)
                            throws IOException

解析报文成 HttpRequest 对象

Parameters:

session - socket 会话对象

byteBufferChannel - 输入字节流

timeOut - 读取超时时间参数

requestMaxSize - 上传文件的最大尺寸, 单位: kb

Returns:

返回请求报文

Throws:

IOException - IO 异常

parseRequest

public static Request parseRequest(Request request,
                                   IoSession session,
                                   ByteBufferChannel byteBufferChannel,
                                   int timeOut,
                                   long requestMaxSize)
                            throws IOException

解析报文成 HttpRequest 对象

Parameters:

request - 请求对象

session - socket 会话对象

byteBufferChannel - 输入字节流

timeOut - 读取超时时间参数

requestMaxSize - 上传文件的最大尺寸, 单位: kb

Returns:

返回请求报文

Throws:

IOException - IO 异常

parseResponse

public static Response parseResponse(IoSession session,
                                     ByteBufferChannel byteBufferChannel,
                                     int timeOut)
                              throws IOException

解析报文成 HttpResponse 对象

Parameters:

session - socket 会话对象

byteBufferChannel - 输入字节流

timeOut - 读取超时时间参数

Returns:

返回响应报文

Throws:

IOException - IO 异常

parseResponse

public static Response parseResponse(Response response,
                                     IoSession session,
                                     ByteBufferChannel byteBufferChannel,
                                     int timeOut)
                              throws IOException

解析报文成 HttpResponse 对象

Parameters:

response - Resposne 响应对象

session - socket 会话对象

byteBufferChannel - 输入字节流

timeOut - 读取超时时间参数

Returns:

返回响应报文

Throws:

IOException - IO 异常

resetThreadLocal

public static void resetThreadLocal()