org.voovan.network.aio

类 AioSession

java.lang.Object

org.voovan.network.IoSession<AioSocket>

org.voovan.network.aio.AioSession

public class AioSession
extends IoSession<AioSocket>

NIO 会话连接对象

作者:

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

嵌套类概要

从类继承的嵌套类/接口 org.voovan.network.IoSession

IoSession.State

构造器概要

构造器

构造器和说明
AioSession(AioSocket socket) 构造函数

方法概要

限定符和类型	方法和说明
boolean	close() 关闭会话
protected MessageSplitter	getMessagePartition() 获取消息分割处理类
boolean	isConnected() 会话是否连接
boolean	isOpen() 会话是否打开
int	loaclPort() 获取本地端口
String	localAddress() 获取本地 IP 地址
protected int	read0(ByteBuffer buffer) 读取消息到缓冲区
String	remoteAddress() 获取对端 IP 地址
int	remotePort() 获取对端端口
void	restart() 重连当前连接
protected int	send0(ByteBuffer buffer) 发送消息 注意直接调用不会出发 onSent 事件
String	toString()

从类继承的方法 org.voovan.network.IoSession

cancelIdle, checkIdle, containAttribute, enabledMessageSpliter, getAttribute, getAttributes, getByteBufferChannel, getHeartBeat, getIdleInterval, getMessageLoader, getSSLParser, getState, read, removeAttribute, send, setAttribute, setHeartBeat, setIdleInterval, setSSLParser, socketContext, syncRead, syncSend, wait

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

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

构造器详细资料

AioSession

public AioSession(AioSocket socket)

构造函数

参数:

socket - AioSocket对象

方法详细资料

localAddress

public String localAddress()

从类复制的说明: IoSession

获取本地 IP 地址

指定者:

localAddress 在类中 IoSession<AioSocket>

返回:

本地 IP 地址

loaclPort

public int loaclPort()

从类复制的说明: IoSession

获取本地端口

指定者:

loaclPort 在类中 IoSession<AioSocket>

返回:

返回-1为没有取到本地端口

remoteAddress

public String remoteAddress()

从类复制的说明: IoSession

获取对端 IP 地址

指定者:

remoteAddress 在类中 IoSession<AioSocket>

返回:

对端 ip 地址

remotePort

public int remotePort()

从类复制的说明: IoSession

获取对端端口

指定者:

remotePort 在类中 IoSession<AioSocket>

返回:

返回-1为没有取到对端端口

read0

protected int read0(ByteBuffer buffer)
             throws IOException

从类复制的说明: IoSession

读取消息到缓冲区

指定者:

read0 在类中 IoSession<AioSocket>

参数:

buffer - 接收数据的缓冲区

返回:

接收数据大小

抛出:

IOException - IO 异常

send0

protected int send0(ByteBuffer buffer)
             throws IOException

从类复制的说明: IoSession

发送消息 注意直接调用不会出发 onSent 事件

指定者:

send0 在类中 IoSession<AioSocket>

参数:

buffer - 发送缓冲区

返回:

读取的字节数

抛出:

IOException - IO 异常

getMessagePartition

protected MessageSplitter getMessagePartition()

从类复制的说明: IoSession

获取消息分割处理类

指定者:

getMessagePartition 在类中 IoSession<AioSocket>

返回:

消息分割处理类

isConnected

public boolean isConnected()

从类复制的说明: IoSession

会话是否连接

指定者:

isConnected 在类中 IoSession<AioSocket>

返回:

true: 连接,false: 关闭

isOpen

public boolean isOpen()

会话是否打开

指定者:

isOpen 在类中 IoSession<AioSocket>

返回:

true: 打开,false: 关闭

close

public boolean close()

从类复制的说明: IoSession

关闭会话

指定者:

close 在类中 IoSession<AioSocket>

返回:

是否关闭

restart

public void restart()
             throws IOException,
                    RestartException

重连当前连接

抛出:

IOException - IO 异常

RestartException - 重新启动的异常

toString

public String toString()

指定者:

toString 在类中 IoSession<AioSocket>