| 程序包 | 说明 |
|---|---|
| org.voovan.network | |
| org.voovan.network.aio | |
| org.voovan.network.filter | |
| org.voovan.network.handler | |
| org.voovan.network.messagesplitter | |
| org.voovan.network.nio | |
| org.voovan.network.udp |
| 限定符和类型 | 方法和说明 |
|---|---|
IoSession |
Event.getSession() |
| 限定符和类型 | 方法和说明 |
|---|---|
static HeartBeat |
HeartBeat.attachSession(IoSession session,
ConnectModel connectModel)
将心跳绑定到 Session
默认使用 PING, PONG 作为心跳消息
|
static HeartBeat |
HeartBeat.attachSession(IoSession session,
ConnectModel connectModel,
String ping,
String pong)
将心跳绑定到 Session
|
static boolean |
HeartBeat.beat(IoSession session)
一次心跳动作
|
int |
MessageSplitter.canSplite(IoSession session,
ByteBuffer byteBuffer)
判断消息是否可分割
|
SSLParser |
SSLManager.createClientSSLParser(IoSession session)
获取SSLParser
|
SSLParser |
SSLManager.createServerSSLParser(IoSession session)
获取Server 模式 SSLParser
|
Object |
IoFilter.decode(IoSession session,
Object object)
过滤器解密函数,接收事件(onRecive)前调用
onRecive事件前调用
|
Object |
IoFilter.encode(IoSession session,
Object object)
过滤器加密函数,发送事件(onSend)前调用
send事件前调用
|
static Object |
EventProcess.filterDecoder(IoSession session,
ByteBuffer readedBuffer)
使用过滤器过滤解码结果
|
static ByteBuffer |
EventProcess.filterEncoder(IoSession session,
Object result)
使用过滤器编码结果
|
static void |
EventTrigger.fireAccept(IoSession session) |
static void |
EventTrigger.fireAcceptThread(IoSession session) |
static void |
EventTrigger.fireConnect(IoSession session) |
static void |
EventTrigger.fireConnectThread(IoSession session) |
static void |
EventTrigger.fireDisconnect(IoSession session) |
static void |
EventTrigger.fireDisconnectThread(IoSession session) |
static void |
EventTrigger.fireEvent(IoSession session,
Event.EventName name,
Object other)
事件触发
根据事件启动 EventThread 来处理事件
|
static void |
EventTrigger.fireEventThread(IoSession session,
Event.EventName name,
Object other)
事件触发
根据事件启动 EventThread 来处理事件
|
static void |
EventTrigger.fireException(IoSession session,
Exception exception) |
static void |
EventTrigger.fireExceptionThread(IoSession session,
Exception exception) |
static void |
EventTrigger.fireIdle(IoSession session) |
static void |
EventTrigger.fireIdleThread(IoSession session) |
static void |
EventTrigger.fireReceive(IoSession session) |
static void |
EventTrigger.fireReceiveThread(IoSession session) |
static void |
EventTrigger.fireSent(IoSession session,
Object obj) |
static void |
EventTrigger.fireSentThread(IoSession session,
Object obj) |
static Event |
Event.getInstance(IoSession session,
Event.EventName name,
Object other)
活的新的实例
|
protected void |
SocketContext.initSSL(IoSession session) |
static void |
HeartBeat.interceptHeartBeat(IoSession session,
ByteBufferChannel byteBufferChannel)
截断心跳消息
|
static boolean |
EventTrigger.isHandShakeDone(IoSession session) |
Object |
IoHandler.onConnect(IoSession session)
连接成功事件
|
void |
IoHandler.onDisconnect(IoSession session)
连接断开事件
|
void |
IoHandler.onException(IoSession session,
Exception e)
异常事件
|
void |
IoHandler.onIdle(IoSession session)
空闲事件
|
Object |
IoHandler.onReceive(IoSession session,
Object obj)
接收数据事件
|
void |
IoHandler.onSent(IoSession session,
Object obj)
发送数据事件
发送后调用
|
static void |
EventProcess.sendMessage(IoSession session,
Object obj)
在一个独立的线程中并行的发送消息
|
void |
Event.setSession(IoSession session) |
int |
SSLParser.unWarpByteBufferChannel(IoSession session,
ByteBufferChannel netByteBufferChannel,
ByteBufferChannel appByteBufferChannel)
读取SSL消息到缓冲区
|
protected void |
SocketContext.waitConnected(IoSession session)
等待连接完成
|
| 构造器和说明 |
|---|
Event(IoSession session,
Event.EventName name,
Object other)
构造函数
|
MessageLoader(IoSession session)
构造函数
|
SSLParser(SSLEngine engine,
IoSession session)
构造函数
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
AioSession
NIO 会话连接对象
|
| 限定符和类型 | 方法和说明 |
|---|---|
Object |
StringFilter.decode(IoSession session,
Object object) |
Object |
StringFilter.encode(IoSession session,
Object object) |
| 限定符和类型 | 方法和说明 |
|---|---|
Object |
SynchronousHandler.onConnect(IoSession session) |
void |
SynchronousHandler.onDisconnect(IoSession session) |
void |
SynchronousHandler.onException(IoSession session,
Exception e) |
void |
SynchronousHandler.onIdle(IoSession session) |
Object |
SynchronousHandler.onReceive(IoSession session,
Object obj) |
void |
SynchronousHandler.onSent(IoSession session,
Object obj) |
| 限定符和类型 | 方法和说明 |
|---|---|
int |
TransferSplitter.canSplite(IoSession session,
ByteBuffer byteBuffer) |
int |
TimeOutMesssageSplitter.canSplite(IoSession session,
ByteBuffer byteBuffer) |
int |
LineMessageSplitter.canSplite(IoSession session,
ByteBuffer byteBuffer) |
int |
HttpMessageSplitter.canSplite(IoSession session,
ByteBuffer byteBuffer) |
int |
BufferLengthSplitter.canSplite(IoSession session,
ByteBuffer byteBuffer) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
NioSession
NIO 会话连接对象
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
UdpSession
UDP NIO 会话连接对象
|
Copyright © 2017 Voovan. All rights reserved.