org.smartboot.socket.transport

类 AioSession

java.lang.Object

org.smartboot.socket.transport.AioSession

public abstract class AioSession
extends Object

版本:

V1.0 , 2019/8/25

作者:

三刀

构造器概要

构造器

构造器和说明
AioSession()

方法概要

限定符和类型	方法和说明
abstract void	awaitRead()
void	close() 强制关闭当前AIOSession。
abstract void	close(boolean immediate) 是否立即关闭会话
<A> A	getAttachment() 获取附件对象
InputStream	getInputStream() 获得数据输入流对象。
InputStream	getInputStream(int length) 获取已知长度的InputStream
abstract InetSocketAddress	getLocalAddress() 获取当前会话的本地连接地址
abstract InetSocketAddress	getRemoteAddress() 获取当前会话的远程连接地址
String	getSessionID() 获取当前Session的唯一标识
boolean	isInvalid() 当前会话是否已失效
abstract ByteBuffer	readBuffer() 获取读缓冲区对象
<A> void	setAttachment(A attachment) 存放附件，支持任意类型
abstract void	signalRead() 继续触发读行为，该方法仅可在异步处理模式下可使用，否则会触发不可预知的异常
abstract WriteBuffer	writeBuffer() 获取WriteBuffer用以数据输出

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

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

AioSession

public AioSession()

方法详细资料

writeBuffer

public abstract WriteBuffer writeBuffer()

获取WriteBuffer用以数据输出

返回:

WriteBuffer

readBuffer

public abstract ByteBuffer readBuffer()

获取读缓冲区对象

close

public final void close()

强制关闭当前AIOSession。

若此时还存留待输出的数据，则会导致该部分数据丢失

awaitRead

public abstract void awaitRead()

signalRead

public abstract void signalRead()

继续触发读行为，该方法仅可在异步处理模式下可使用，否则会触发不可预知的异常

close

public abstract void close(boolean immediate)

是否立即关闭会话

参数:

immediate - true:立即关闭,false:响应消息发送完后关闭

getSessionID

public String getSessionID()

获取当前Session的唯一标识

返回:

sessionId

isInvalid

public boolean isInvalid()

当前会话是否已失效

返回:

是否失效

getAttachment

public final <A> A getAttachment()

获取附件对象

类型参数:

A - 附件对象类型

返回:

附件

setAttachment

public final <A> void setAttachment(A attachment)

存放附件，支持任意类型

类型参数:

A - 附件对象类型

参数:

attachment - 附件对象

getLocalAddress

public abstract InetSocketAddress getLocalAddress()
                                           throws IOException

获取当前会话的本地连接地址

返回:

本地地址

抛出:

IOException - IO异常

另请参阅:

AsynchronousSocketChannel.getLocalAddress()

getRemoteAddress

public abstract InetSocketAddress getRemoteAddress()
                                            throws IOException

获取当前会话的远程连接地址

返回:

远程地址

抛出:

IOException - IO异常

另请参阅:

AsynchronousSocketChannel.getRemoteAddress()

getInputStream

public InputStream getInputStream()
                           throws IOException

获得数据输入流对象。

faster模式下调用该方法会触发UnsupportedOperationException异常。

MessageProcessor采用异步处理消息的方式时，调用该方法可能会出现异常。

返回:

输入流

抛出:

IOException - IO异常

getInputStream

public InputStream getInputStream(int length)
                           throws IOException

获取已知长度的InputStream

参数:

length - InputStream长度

返回:

输入流

抛出:

IOException - IO异常