IoSession (Voovan-network 3.0.0 API)

java.lang.Object
- org.voovan.network.IoSession<T>

直接已知子类:

AioSession, NioSession, UdpSession
```
public abstract class IoSession<T extends SocketContext>
extends Object
```
会话抽象类

作者:

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

嵌套类概要

嵌套类
限定符和类型类和说明

class IoSession.State
会话状态管理

嵌套类
限定符和类型	类和说明
`class`	`IoSession.State` 会话状态管理

构造器概要

构造器
构造器和说明

IoSession(T socketContext)
构造函数

构造器
构造器和说明
`IoSession(T socketContext)` 构造函数

方法概要

所有方法实例方法抽象方法具体方法
限定符和类型	方法和说明
`void`	`cancelIdle()` 停止空闲事件触发
`void`	`checkIdle()` 启动空闲事件触发
`abstract boolean`	`close()` 关闭会话
`boolean`	`containAttribute(Object key)` 检查会话参数是否存在
`void`	`enabledMessageSpliter(boolean useSpliter)` 设置是否使用分割器读取
`Object`	`getAttribute(Object key)` 获取会话参数
`Map<Object,Object>`	`getAttributes()` 获取全部会话参数
`ByteBufferChannel`	`getByteBufferChannel()` 获取接收的输出流
`HeartBeat`	`getHeartBeat()` 获取心跳对象
`int`	`getIdleInterval()` 获取空闲事件时间
`MessageLoader`	`getMessageLoader()` 获取消息处理类
`protected abstract MessageSplitter`	`getMessagePartition()` 获取消息分割处理类
`SSLParser`	`getSSLParser()` 获取 SSLParser
`IoSession.State`	`getState()`
`abstract boolean`	`isConnected()` 会话是否连接
`abstract boolean`	`isOpen()` 会话是否打开
`abstract int`	`loaclPort()` 获取本地端口
`abstract String`	`localAddress()` 获取本地 IP 地址
`int`	`read(ByteBuffer byteBuffer)` 直接从缓冲区读取数据
`protected abstract int`	`read0(ByteBuffer buffer)` 读取消息到缓冲区
`abstract String`	`remoteAddress()` 获取对端 IP 地址
`abstract int`	`remotePort()` 获取对端端口
`void`	`removeAttribute(Object key)` 移除会话参数
`int`	`send(ByteBuffer buffer)` 直接向缓冲区发送消息注意直接调用不会触发 onSent 事件, 也不会经过任何过滤器
`protected abstract int`	`send0(ByteBuffer buffer)` 发送消息注意直接调用不会出发 onSent 事件
`void`	`setAttribute(Object key, Object value)` 设置会话参数
`protected void`	`setHeartBeat(HeartBeat heartBeat)`
`void`	`setIdleInterval(int idleInterval)` 设置空闲事件时间
`protected void`	`setSSLParser(SSLParser sslParser)` 获取 SSLParser
`T`	`socketContext()` 获取 socket 连接上下文
`Object`	`syncRead()` 同步读取消息消息会经过 filter 的 decoder 函数处理后再返回
`void`	`syncSend(Object obj)` 同步发送消息消息会经过 filter 的 encoder 函数处理后再发送
`abstract String`	`toString()`
`boolean`	`wait(int waitTime)` 等待所有处理都被处理完成 ByteBufferChannel.size() = 0时,或者超时后退出

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- 构造器详细资料
  - IoSession
```
public IoSession(T socketContext)
```
    构造函数
    
    参数:
    
    socketContext - socketContext对象
- 方法详细资料
  - getHeartBeat
```
public HeartBeat getHeartBeat()
```
    获取心跳对象
    
    返回:
    
    心跳对象
  - setHeartBeat
```
protected void setHeartBeat(HeartBeat heartBeat)
```
  - getState
```
public IoSession.State getState()
```
  - checkIdle
```
public void checkIdle()
```
    启动空闲事件触发
  - cancelIdle
```
public void cancelIdle()
```
    停止空闲事件触发
  - getIdleInterval
```
public int getIdleInterval()
```
    获取空闲事件时间
    
    返回:
    
    空闲事件时间
  - setIdleInterval
```
public void setIdleInterval(int idleInterval)
```
    设置空闲事件时间
    
    参数:
    
    idleInterval - 空闲事件时间
  - getByteBufferChannel
```
public ByteBufferChannel getByteBufferChannel()
```
    获取接收的输出流
    
    返回:
    
    接收的输出流
  - getSSLParser
```
public SSLParser getSSLParser()
```
    获取 SSLParser
    
    返回:
    
    SSLParser对象
  - setSSLParser
```
protected void setSSLParser(SSLParser sslParser)
```
    获取 SSLParser
    
    参数:
    
    sslParser - SSL解析对象
  - getAttributes
```
public Map<Object,Object> getAttributes()
```
    获取全部会话参数
    
    返回:
    
    会话参数Map
  - getAttribute
```
public Object getAttribute(Object key)
```
    获取会话参数
    
    参数:
    
    key - 参数名
    
    返回:
    
    参数对象
  - setAttribute
```
public void setAttribute(Object key,
                         Object value)
```
    设置会话参数
    
    参数:
    
    key - 参数名
    
    value - 参数对象
  - removeAttribute
```
public void removeAttribute(Object key)
```
    移除会话参数
    
    参数:
    
    key - 参数名
  - containAttribute
```
public boolean containAttribute(Object key)
```
    检查会话参数是否存在
    
    参数:
    
    key - 参数名
    
    返回:
    
    是否包含
  - localAddress
```
public abstract String localAddress()
```
    获取本地 IP 地址
    
    返回:
    
    本地 IP 地址
  - loaclPort
```
public abstract int loaclPort()
```
    获取本地端口
    
    返回:
    
    返回-1为没有取到本地端口
  - remoteAddress
```
public abstract String remoteAddress()
```
    获取对端 IP 地址
    
    返回:
    
    对端 ip 地址
  - remotePort
```
public abstract int remotePort()
```
    获取对端端口
    
    返回:
    
    返回-1为没有取到对端端口
  - socketContext
```
public T socketContext()
```
    获取 socket 连接上下文
    
    返回:
    
    socket 连接上下文, 连接断开时返回的是null
  - read0
```
protected abstract int read0(ByteBuffer buffer)
                      throws IOException
```
    读取消息到缓冲区
    
    参数:
    
    buffer - 接收数据的缓冲区
    
    返回:
    
    接收数据大小
    
    抛出:
    
    IOException - IO 异常
  - send0
```
protected abstract int send0(ByteBuffer buffer)
                      throws IOException
```
    发送消息注意直接调用不会出发 onSent 事件
    
    参数:
    
    buffer - 发送缓冲区
    
    返回:
    
    读取的字节数
    
    抛出:
    
    IOException - IO 异常
  - syncRead
```
public Object syncRead()
                throws ReadMessageException
```
    同步读取消息消息会经过 filter 的 decoder 函数处理后再返回
    
    返回:
    
    读取出的对象
    
    抛出:
    
    ReadMessageException - 读取消息异常
  - syncSend
```
public void syncSend(Object obj)
              throws SendMessageException
```
    同步发送消息消息会经过 filter 的 encoder 函数处理后再发送
    
    参数:
    
    obj - 要发送的对象
    
    抛出:
    
    SendMessageException - 消息发送异常
  - enabledMessageSpliter
```
public void enabledMessageSpliter(boolean useSpliter)
```
    设置是否使用分割器读取
    
    参数:
    
    useSpliter - true 使用分割器读取,false 不使用分割器读取,且不会出发 onRecive 事件
  - send
```
public int send(ByteBuffer buffer)
```
    直接向缓冲区发送消息注意直接调用不会触发 onSent 事件, 也不会经过任何过滤器
    
    参数:
    
    buffer - byte缓冲区
    
    返回:
    
    发送的数据大小
  - read
```
public int read(ByteBuffer byteBuffer)
         throws IOException
```
    直接从缓冲区读取数据
    
    参数:
    
    byteBuffer - 字节缓冲对象ByteBuffer,读取前需要使用 enabledMessageSpliter(false) 停止分割器的工作,除非有特殊的需求.
    
    返回:
    
    读取的字节数
    
    抛出:
    
    IOException - IO异常
  - getMessageLoader
```
public MessageLoader getMessageLoader()
```
    获取消息处理类
    
    返回:
    
    消息处理类
  - getMessagePartition
```
protected abstract MessageSplitter getMessagePartition()
```
    获取消息分割处理类
    
    返回:
    
    消息分割处理类
  - isConnected
```
public abstract boolean isConnected()
```
    会话是否连接
    
    返回:
    
    true: 连接,false: 关闭
  - isOpen
```
public abstract boolean isOpen()
```
    会话是否打开
    
    返回:
    
    true: 打开,false: 关闭
  - wait
```
public boolean wait(int waitTime)
```
    等待所有处理都被处理完成 ByteBufferChannel.size() = 0时,或者超时后退出
    
    参数:
    
    waitTime - 超时事件
    
    返回:
    
    true: 数据处理完退出, false:超时退出
  - close
```
public abstract boolean close()
```
    关闭会话
    
    返回:
    
    是否关闭
  - toString
```
public abstract String toString()
```
    覆盖:
    
    toString 在类中 Object

类 IoSession<T extends SocketContext>

嵌套类概要

构造器概要

方法概要

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

构造器详细资料

IoSession

方法详细资料

getHeartBeat

setHeartBeat

getState

checkIdle

cancelIdle

getIdleInterval

setIdleInterval

getByteBufferChannel

getSSLParser

setSSLParser

getAttributes

getAttribute

setAttribute

removeAttribute

containAttribute

localAddress

loaclPort

remoteAddress

remotePort

socketContext

read0

send0

syncRead

syncSend

enabledMessageSpliter

send

read

getMessageLoader

getMessagePartition

isConnected

isOpen

wait

close

toString