org.voovan.network

类 EventProcess

java.lang.Object

org.voovan.network.EventProcess

public class EventProcess
extends Object

事件的实际逻辑处理

作者:

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

方法概要

限定符和类型	方法和说明
static Object	filterDecoder(IoSession session, ByteBuffer readedBuffer) 使用过滤器过滤解码结果
static ByteBuffer	filterEncoder(IoSession session, Object result) 使用过滤器编码结果
static void	onAccepted(Event event) Accept事件
static void	onConnect(Event event) 连接成功事件 建立连接完成后出发
static void	onDisconnect(Event event) 连接断开事件 断开后出发
static void	onException(Event event, Exception e) 异常产生事件 异常产生侯触发
static void	onIdle(Event event) 空闲事件触发
static void	onRead(Event event) 读取事件 在消息接受完成后触发
static void	onSent(Event event, Object sendObj) 发送完成事件 发送后出发
static void	process(Event event) 处理异常
static void	sendMessage(IoSession session, Object obj) 在一个独立的线程中并行的发送消息

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

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

方法详细资料

onAccepted

public static void onAccepted(Event event)
                       throws IOException

Accept事件

参数:

event - 事件对象

抛出:

IOException - IO 异常

onConnect

public static void onConnect(Event event)

连接成功事件 建立连接完成后出发

参数:

event - 事件对象

onDisconnect

public static void onDisconnect(Event event)

连接断开事件 断开后出发

参数:

event - 事件对象

onRead

public static void onRead(Event event)
                   throws IOException,
                          SendMessageException,
                          IoFilterException

读取事件 在消息接受完成后触发

参数:

event - 事件对象

抛出:

SendMessageException - 消息发送异常

IOException - IO 异常

IoFilterException - IoFilter 异常

filterDecoder

public static Object filterDecoder(IoSession session,
                                   ByteBuffer readedBuffer)
                            throws IoFilterException

使用过滤器过滤解码结果

参数:

session - Session 对象

readedBuffer - 需解码的对象

返回:

解码后的对象

抛出:

IoFilterException - 过滤器异常

filterEncoder

public static ByteBuffer filterEncoder(IoSession session,
                                       Object result)
                                throws IoFilterException

使用过滤器编码结果

参数:

session - Session 对象

result - 需编码的对象

返回:

编码后的对象

抛出:

IoFilterException - 过滤器异常

sendMessage

public static void sendMessage(IoSession session,
                               Object obj)

在一个独立的线程中并行的发送消息

参数:

session - Session 对象

obj - 待发送的对象

onSent

public static void onSent(Event event,
                          Object sendObj)
                   throws IOException

发送完成事件 发送后出发

参数:

event - 事件对象

sendObj - 发送的对象

抛出:

IOException - IO 异常

onIdle

public static void onIdle(Event event)

空闲事件触发

参数:

event - 事件对象

onException

public static void onException(Event event,
                               Exception e)

异常产生事件 异常产生侯触发

参数:

event - 事件对象

e - 异常对象

process

public static void process(Event event)

处理异常

参数:

event - 事件对象