org.voovan.network

Class MessageLoader

java.lang.Object

org.voovan.network.MessageLoader

public class MessageLoader
extends Object

Socket消息处理类

Author:

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MessageLoader.StopType

Constructor Summary

Constructors

Constructor and Description
MessageLoader(IoSession session) 构造函数

Method Summary

Modifier and Type	Method and Description
void	close() 关闭 MessageLoader
MessageLoader.StopType	getStopType() 获取停止类型
static boolean	isStreamEnd(byte[] buffer, int length) 判断字节所属流是否结束
static boolean	isStreamEnd(int length) 判断字节所属流是否结束
int	read() 读取 socket 中的数据 逐字节读取数据,并用消息截断器判断消息包是否完整,消息粘包有两种截断方式: 1.消息截断器生效 2.消息读取时间超时,例如设置5m,则连续5秒内没有读取到有用的消息则返回报文.
void	setStopType(MessageLoader.StopType stopType) 设置停止类型

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageLoader

public MessageLoader(IoSession session)

构造函数

Parameters:

session - Session 对象

Method Detail

getStopType

public MessageLoader.StopType getStopType()

获取停止类型

Returns:

停止类型

setStopType

public void setStopType(MessageLoader.StopType stopType)

设置停止类型

Parameters:

stopType - 停止类型

isStreamEnd

public static boolean isStreamEnd(int length)

判断字节所属流是否结束

Parameters:

length - 长度

Returns:

是否意外断开

isStreamEnd

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

判断字节所属流是否结束

Parameters:

buffer - 缓冲区

length - 长度

Returns:

是否意外断开

close

public void close()

关闭 MessageLoader

read

public int read()

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

Returns:

读取的缓冲区数据