org.voovan.network

Class EventProcess

java.lang.Object

org.voovan.network.EventProcess

public class EventProcess
extends Object

事件的实际逻辑处理

Author:

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

Field Summary

Fields

Modifier and Type	Field and Description
static ThreadLocal<ByteBuffer>	THREAD_BYTE_BYTE

Method Summary

Modifier and Type	Method and Description
static Object	doRecive(IoSession session, int splitLength) 接收的消息处理函数
static Object	filterDecoder(IoSession session, ByteBuffer readedBuffer) 使用过滤器过滤解码结果
static ByteBuffer	filterEncoder(IoSession session, Object result) 使用过滤器编码结果
static ByteBuffer	loadSplitData(IoSession session, int splitLength)
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	onFlush(Event event, List<Object> flushedObjects) 发送到 Socket 缓冲区事件
static void	onIdle(Event event) 空闲事件触发
static void	onRead(Event event, int recursionDepth) 读取事件 在消息接受完成后触发
static void	onSent(Event event, Object sendObj) 发送完成事件 发送后出发
static void	process(Event event) 处理异常
static void	sendMessage(IoSession session, Object obj) 在一个独立的线程中并行的发送消息

Methods inherited from class java.lang.Object

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

Field Detail

THREAD_BYTE_BYTE

public static ThreadLocal<ByteBuffer> THREAD_BYTE_BYTE

Method Detail

onAccepted

public static void onAccepted(Event event)
                       throws IOException

Accept事件

Parameters:

event - 事件对象

Throws:

IOException - IO 异常

onConnect

public static void onConnect(Event event)
                      throws IOException

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

Parameters:

event - 事件对象

Throws:

IOException - IO 异常

onDisconnect

public static void onDisconnect(Event event)

连接断开事件 断开后出发

Parameters:

event - 事件对象

onRead

public static void onRead(Event event,
                          int recursionDepth)
                   throws IOException

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

Parameters:

event - 事件对象

recursionDepth - 递归深度控制

Throws:

SendMessageException - 消息发送异常

IOException - IO 异常

IoFilterException - IoFilter 异常

loadSplitData

public static ByteBuffer loadSplitData(IoSession session,
                                       int splitLength)

doRecive

public static Object doRecive(IoSession session,
                              int splitLength)
                       throws IOException

接收的消息处理函数

Parameters:

session - 会话对象

splitLength - 分割有效自己数

Returns:

产生的响应

Throws:

IoFilterException - 过滤器异常

IOException

filterDecoder

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

使用过滤器过滤解码结果

Parameters:

session - Session 对象

readedBuffer - 需解码的对象

Returns:

解码后的对象

Throws:

IoFilterException - 过滤器异常

filterEncoder

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

使用过滤器编码结果

Parameters:

session - Session 对象

result - 需编码的对象

Returns:

编码后的对象

Throws:

IoFilterException - 过滤器异常

sendMessage

public static void sendMessage(IoSession session,
                               Object obj)

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

Parameters:

session - Session 对象

obj - 待发送的对象

onSent

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

发送完成事件 发送后出发

Parameters:

event - 事件对象

sendObj - 发送的对象

Throws:

IOException - IO 异常

onFlush

public static void onFlush(Event event,
                           List<Object> flushedObjects)
                    throws IOException

发送到 Socket 缓冲区事件

Parameters:

event - 事件对象

flushedObjects - flushed 发送的对象

Throws:

IOException - IO 异常

onIdle

public static void onIdle(Event event)

空闲事件触发

Parameters:

event - 事件对象

onException

public static void onException(Event event,
                               Exception e)

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

Parameters:

event - 事件对象

e - 异常对象

process

public static void process(Event event)

处理异常

Parameters:

event - 事件对象