org.voovan.network

类 MessageLoader

java.lang.Object

org.voovan.network.MessageLoader

public class MessageLoader
extends Object

Socket消息处理类

作者:

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

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	MessageLoader.StopType

构造器概要

构造器

构造器和说明
MessageLoader(IoSession session) 构造函数

方法概要

限定符和类型	方法和说明
void	close() 关闭 MessageLoader
MessageLoader.StopType	getStopType() 获取停止类型
static boolean	isStreamEnd(byte[] buffer, Integer length) 判断字节所属流是否结束
static boolean	isStreamEnd(ByteBuffer buffer, Integer length) 判断字节所属流是否结束
boolean	isUseSpliter() 获取是否使用分割器读取
void	pause() 暂停
ByteBuffer	read() 读取 socket 中的数据 逐字节读取数据,并用消息截断器判断消息包是否完整,消息粘包有两种截断方式: 1.消息截断器生效 2.消息读取时间超时,例如设置5m,则连续5秒内没有读取到有用的消息则返回报文.
void	reset() 重置计数 读取超时时间回0
void	setStopType(MessageLoader.StopType stopType) 设置停止类型
void	setUseSpliter(boolean useSpliter) 设置是否是否使用分割器读取
void	unpause() 恢复

从类继承的方法 java.lang.Object

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

构造器详细资料

MessageLoader

public MessageLoader(IoSession session)

构造函数

参数:

session - Session 对象

方法详细资料

isUseSpliter

public boolean isUseSpliter()

获取是否使用分割器读取

返回:

true 使用分割器读取,false 不使用分割器读取,且不会出发 onRecive 事件

setUseSpliter

public void setUseSpliter(boolean useSpliter)

设置是否是否使用分割器读取

参数:

useSpliter - true 使用分割器读取,false 不使用分割器读取,且不会出发 onRecive 事件

getStopType

public MessageLoader.StopType getStopType()

获取停止类型

返回:

停止类型

setStopType

public void setStopType(MessageLoader.StopType stopType)

设置停止类型

参数:

stopType - 停止类型

pause

public void pause()

暂停

unpause

public void unpause()

恢复

isStreamEnd

public static boolean isStreamEnd(ByteBuffer buffer,
                                  Integer length)

判断字节所属流是否结束

参数:

buffer - 缓冲区

length - 长度

返回:

是否意外断开

isStreamEnd

public static boolean isStreamEnd(byte[] buffer,
                                  Integer length)

判断字节所属流是否结束

参数:

buffer - 缓冲区

length - 长度

返回:

是否意外断开

reset

public void reset()

重置计数 读取超时时间回0

close

public void close()

关闭 MessageLoader

read

public ByteBuffer read()
                throws IOException

读取 socket 中的数据 逐字节读取数据,并用消息截断器判断消息包是否完整,消息粘包有两种截断方式: 1.消息截断器生效 2.消息读取时间超时,例如设置5m,则连续5秒内没有读取到有用的消息则返回报文.

返回:

读取的缓冲区数据

抛出:

IOException - IO 异常