public class HttpMessageSplitter extends Object implements MessageSplitter
Constructor and Description |
---|
HttpMessageSplitter() |
Modifier and Type | Method and Description |
---|---|
int |
canSplite(IoSession session,
ByteBuffer byteBuffer)
判断消息是否可分割
分割处理: 这个时候返回长度需要大于 0, 这个时候 session.getByteBuffer 中的数据会被分割, 然后传递给 IoFilter
流式处理: 用户 http/1.1 等协议解析, 这个时候返回长度需要等于0, 则数据不会被分割, 所有数据都在 session.getByteBuffer 中, 这个时候数据可以在 IoFilter 中进行处理,
这个时候 IoFilter 接收到的是一个容量为 0 的 bytebuffer
|
static int |
isWebSocketFrame(ByteBuffer buffer)
判断缓冲区中的数据是否是一个 WebSocket 帧
|
public int canSplite(IoSession session, ByteBuffer byteBuffer)
MessageSplitter
canSplite
in interface MessageSplitter
session
- session 对象byteBuffer
- 缓冲数据public static int isWebSocketFrame(ByteBuffer buffer)
buffer
- 缓冲区对象Copyright © 2020 Voovan. All rights reserved.