org.voovan.network.handler

Class SynchronousHandler

java.lang.Object

org.voovan.network.handler.SynchronousHandler

All Implemented Interfaces:

IoHandler

public class SynchronousHandler
extends Object
implements IoHandler

Socket 同步通信 handler

Author:

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

Constructor Summary

Constructors

Constructor and Description
SynchronousHandler()

Method Summary

Modifier and Type	Method and Description
void	addResponse(Object obj) 增加响应对象
void	clearResponse()
void	dataNotify()
Object	getResponse(int timeout) 获取下一个响应对象
boolean	hasNextResponse() 是否存在下一个响应对象
Object	onConnect(IoSession session) 连接成功事件
void	onDisconnect(IoSession session) 连接断开事件
void	onException(IoSession session, Exception e) 异常事件
void	onFlush(IoSession session) Socket 缓冲区发送事件
void	onIdle(IoSession session) 空闲事件
Object	onReceive(IoSession session, Object obj) 接收数据事件
void	onSent(IoSession session, Object obj) 发送数据事件 发送后调用
int	responseCount() 获取响应对象数量
void	waitData(int timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronousHandler

public SynchronousHandler()

Method Detail

onConnect

public Object onConnect(IoSession session)

Description copied from interface: IoHandler

连接成功事件

Specified by:

onConnect in interface IoHandler

Parameters:

session - Session 对象

Returns:

返回的对象将发送

onDisconnect

public void onDisconnect(IoSession session)

Description copied from interface: IoHandler

连接断开事件

Specified by:

onDisconnect in interface IoHandler

Parameters:

session - Session 对象

onReceive

public Object onReceive(IoSession session,
                        Object obj)

Description copied from interface: IoHandler

接收数据事件

Specified by:

onReceive in interface IoHandler

Parameters:

session - Session 对象

obj - 接收的对象

Returns:

返回的对象将发送

onSent

public void onSent(IoSession session,
                   Object obj)

Description copied from interface: IoHandler

发送数据事件 发送后调用

Specified by:

onSent in interface IoHandler

Parameters:

session - Session 对象

obj - 发送的对象

onFlush

public void onFlush(IoSession session)

Description copied from interface: IoHandler

Socket 缓冲区发送事件

Specified by:

onFlush in interface IoHandler

Parameters:

session - session Session 对象

onException

public void onException(IoSession session,
                        Exception e)

Description copied from interface: IoHandler

异常事件

Specified by:

onException in interface IoHandler

Parameters:

session - Session 对象

e - 异常信息

onIdle

public void onIdle(IoSession session)

Description copied from interface: IoHandler

空闲事件

Specified by:

onIdle in interface IoHandler

Parameters:

session - Session 对象

addResponse

public void addResponse(Object obj)

增加响应对象

Parameters:

obj - 响应对象

getResponse

public Object getResponse(int timeout)
                   throws Exception

获取下一个响应对象

Parameters:

timeout - 超时时间

Returns:

响应对象

Throws:

TimeoutException - 超时异常

Exception

responseCount

public int responseCount()

获取响应对象数量

Returns:

获取响应对象数量

clearResponse

public void clearResponse()

hasNextResponse

public boolean hasNextResponse()

是否存在下一个响应对象

Returns:

true: 存在, false: 不存在

waitData

public void waitData(int timeout)
              throws TimeoutException

Throws:

TimeoutException

dataNotify

public void dataNotify()