org.voovan.network.aio

Class AioSession

java.lang.Object

org.voovan.network.IoSession<AioSocket>

org.voovan.network.aio.AioSession

public class AioSession
extends IoSession<AioSocket>

NIO 会话连接对象

Author:

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

Nested Class Summary

Nested classes/interfaces inherited from class org.voovan.network.IoSession

IoSession.State

Field Summary

Fields inherited from class org.voovan.network.IoSession

readByteBufferChannel, sendByteBufferChannel

Constructor Summary

Constructors

Constructor and Description
AioSession(AioSocket socket) 构造函数

Method Summary

Modifier and Type	Method and Description
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()

Methods inherited from class org.voovan.network.IoSession

cancelIdle, checkIdle, containAttribute, enabledMessageSpliter, flush, getAttribute, getAttributes, getFlushedObjects, getHeartBeat, getIdleInterval, getMessageLoader, getReadByteBufferChannel, getSendByteBufferChannel, getSSLParser, getState, read, removeAttribute, send, sendByBuffer, setAttribute, setFlushedObjects, setHeartBeat, setIdleInterval, setSSLParser, socketContext, syncRead, syncSend, wait

Methods inherited from class java.lang.Object

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

Constructor Detail

AioSession

public AioSession(AioSocket socket)

构造函数

Parameters:

socket - AioSocket对象

Method Detail

localAddress

public String localAddress()

Description copied from class: IoSession

获取本地 IP 地址

Specified by:

localAddress in class IoSession<AioSocket>

Returns:

本地 IP 地址

loaclPort

public int loaclPort()

Description copied from class: IoSession

获取本地端口

Specified by:

loaclPort in class IoSession<AioSocket>

Returns:

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

remoteAddress

public String remoteAddress()

Description copied from class: IoSession

获取对端 IP 地址

Specified by:

remoteAddress in class IoSession<AioSocket>

Returns:

对端 ip 地址

remotePort

public int remotePort()

Description copied from class: IoSession

获取对端端口

Specified by:

remotePort in class IoSession<AioSocket>

Returns:

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

read0

protected int read0(ByteBuffer buffer)
             throws IOException

Description copied from class: IoSession

读取消息到缓冲区

Specified by:

read0 in class IoSession<AioSocket>

Parameters:

buffer - 接收数据的缓冲区

Returns:

接收数据大小

Throws:

IOException - IO 异常

send0

protected int send0(ByteBuffer buffer)
             throws IOException

Description copied from class: IoSession

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

Specified by:

send0 in class IoSession<AioSocket>

Parameters:

buffer - 发送缓冲区

Returns:

读取的字节数

Throws:

IOException - IO 异常

getMessagePartition

protected MessageSplitter getMessagePartition()

Description copied from class: IoSession

获取消息分割处理类

Specified by:

getMessagePartition in class IoSession<AioSocket>

Returns:

消息分割处理类

isConnected

public boolean isConnected()

Description copied from class: IoSession

会话是否连接

Specified by:

isConnected in class IoSession<AioSocket>

Returns:

true: 连接,false: 关闭

isOpen

public boolean isOpen()

会话是否打开

Specified by:

isOpen in class IoSession<AioSocket>

Returns:

true: 打开,false: 关闭

close

public boolean close()

Description copied from class: IoSession

关闭会话

Specified by:

close in class IoSession<AioSocket>

Returns:

是否关闭

restart

public void restart()
             throws IOException,
                    RestartException

重连当前连接

Throws:

IOException - IO 异常

RestartException - 重新启动的异常

toString

public String toString()

Specified by:

toString in class IoSession<AioSocket>