org.voovan.network.nio

Class NioSession

java.lang.Object

org.voovan.network.IoSession<NioSocket>

org.voovan.network.nio.NioSession

public class NioSession
extends IoSession<NioSocket>

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

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 事件
protected SocketChannel	socketChannel() 获取SocketChannel 对象
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

Method Detail

localAddress

public String localAddress()

获取本地 IP 地址

Specified by:

localAddress in class IoSession<NioSocket>

Returns:

本地 IP 地址

loaclPort

public int loaclPort()

获取本地端口

Specified by:

loaclPort in class IoSession<NioSocket>

Returns:

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

remoteAddress

public String remoteAddress()

获取对端 IP 地址

Specified by:

remoteAddress in class IoSession<NioSocket>

Returns:

对端 ip 地址

remotePort

public int remotePort()

获取对端端口

Specified by:

remotePort in class IoSession<NioSocket>

Returns:

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

socketChannel

protected SocketChannel socketChannel()

获取SocketChannel 对象

Returns:

SocketChannel 对象,连接断开时返回的是null

read0

protected int read0(ByteBuffer buffer)
             throws IOException

Description copied from class: IoSession

读取消息到缓冲区

Specified by:

read0 in class IoSession<NioSocket>

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<NioSocket>

Parameters:

buffer - 发送缓冲区

Returns:

读取的字节数

Throws:

IOException - IO 异常

getMessagePartition

protected MessageSplitter getMessagePartition()

Description copied from class: IoSession

获取消息分割处理类

Specified by:

getMessagePartition in class IoSession<NioSocket>

Returns:

消息分割处理类

isConnected

public boolean isConnected()

会话是否打开

Specified by:

isConnected in class IoSession<NioSocket>

Returns:

true: 打开,false: 关闭

isOpen

public boolean isOpen()

会话是否打开

Specified by:

isOpen in class IoSession<NioSocket>

Returns:

true: 打开,false: 关闭

close

public boolean close()

关闭会话

Specified by:

close in class IoSession<NioSocket>

Returns:

是否关闭

restart

public void restart()
             throws IOException,
                    RestartException

重连当前连接

Throws:

IOException - IO 异常

RestartException - 重新启动的异常

toString

public String toString()

Specified by:

toString in class IoSession<NioSocket>