cn.hutool.socket.aio

Class AioSession

java.lang.Object

cn.hutool.socket.aio.AioSession

All Implemented Interfaces:

Closeable, AutoCloseable

public class AioSession
extends Object
implements Closeable

AIO会话
每个客户端对应一个会话对象

Author:

looly

Constructor Summary

Constructors

Constructor and Description
AioSession(AsynchronousSocketChannel channel, IoAction<ByteBuffer> ioAction, SocketConfig config) 构造

Method Summary

Modifier and Type	Method and Description
protected void	callbackRead() 执行读，用于读取事件结束的回调
void	close() 关闭会话
AioSession	closeIn() 关闭输出
AioSession	closeOut() 关闭输出
AsynchronousSocketChannel	getChannel() 获取AsynchronousSocketChannel
IoAction<ByteBuffer>	getIoAction() 获取消息处理器
ByteBuffer	getReadBuffer() 获取读取Buffer
SocketAddress	getRemoteAddress() 获取远程主机（客户端）地址和端口
ByteBuffer	getWriteBuffer() 获取写Buffer
boolean	isOpen() 会话是否打开状态 当Socket保持连接时会话始终打开
AioSession	read() 读取数据到Buffer
AioSession	read(CompletionHandler<Integer,AioSession> handler) 读取数据到Buffer
Future<Integer>	write(ByteBuffer data) 写数据到目标端
AioSession	write(ByteBuffer data, CompletionHandler<Integer,AioSession> handler) 写数据到目标端
AioSession	writeAndClose(ByteBuffer data) 写数据到目标端，并关闭输出

Methods inherited from class java.lang.Object

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

Constructor Detail

AioSession

public AioSession(AsynchronousSocketChannel channel,
                  IoAction<ByteBuffer> ioAction,
                  SocketConfig config)

构造

Parameters:

channel - AsynchronousSocketChannel

ioAction - IO消息处理类

config - 配置项

Method Detail

getChannel

public AsynchronousSocketChannel getChannel()

获取AsynchronousSocketChannel

Returns:

AsynchronousSocketChannel

getReadBuffer

public ByteBuffer getReadBuffer()

获取读取Buffer

Returns:

读取Buffer

getWriteBuffer

public ByteBuffer getWriteBuffer()

获取写Buffer

Returns:

写Buffer

getIoAction

public IoAction<ByteBuffer> getIoAction()

获取消息处理器

Returns:

IoAction

getRemoteAddress

public SocketAddress getRemoteAddress()

获取远程主机（客户端）地址和端口

Returns:

远程主机（客户端）地址和端口

read

public AioSession read()

读取数据到Buffer

Returns:

this

read

public AioSession read(CompletionHandler<Integer,AioSession> handler)

读取数据到Buffer

Parameters:

handler - CompletionHandler

Returns:

this

writeAndClose

public AioSession writeAndClose(ByteBuffer data)

写数据到目标端，并关闭输出

Parameters:

data - 数据

Returns:

this

write

public Future<Integer> write(ByteBuffer data)

写数据到目标端

Parameters:

data - 数据

Returns:

Future

write

public AioSession write(ByteBuffer data,
                        CompletionHandler<Integer,AioSession> handler)

写数据到目标端

Parameters:

data - 数据

handler - CompletionHandler

Returns:

this

isOpen

public boolean isOpen()

会话是否打开状态
当Socket保持连接时会话始终打开

Returns:

会话是否打开状态

closeIn

public AioSession closeIn()

关闭输出

Returns:

this

closeOut

public AioSession closeOut()

关闭输出

Returns:

this

close

public void close()

关闭会话

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

callbackRead

protected void callbackRead()

执行读，用于读取事件结束的回调