cn.hutool.socket.aio

Class AioServer

java.lang.Object

cn.hutool.socket.aio.AioServer

All Implemented Interfaces:

Closeable, AutoCloseable

public class AioServer
extends Object
implements Closeable

基于AIO的Socket服务端实现

Author:

looly

Field Summary

Fields

Modifier and Type	Field and Description
protected SocketConfig	config
protected IoAction<ByteBuffer>	ioAction

Constructor Summary

Constructors

Constructor and Description
AioServer(InetSocketAddress address, SocketConfig config) 构造
AioServer(int port) 构造

Method Summary

Modifier and Type	Method and Description
AioServer	accept() 处理接入的客户端
void	close() 关闭服务
AsynchronousServerSocketChannel	getChannel() 获取AsynchronousServerSocketChannel
IoAction<ByteBuffer>	getIoAction() 获取IO处理器
AioServer	init(InetSocketAddress address) 初始化
boolean	isOpen() 服务是否开启状态
AioServer	setIoAction(IoAction<ByteBuffer> ioAction) 设置IO处理器，单例存在
<T> AioServer	setOption(SocketOption<T> name, T value) 设置 Socket 的 Option 选项 选项见：StandardSocketOptions
void	start(boolean sync) 开始监听

Methods inherited from class java.lang.Object

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

Field Detail

ioAction

protected IoAction<ByteBuffer> ioAction

config

protected final SocketConfig config

Constructor Detail

AioServer

public AioServer(int port)

构造

Parameters:

port - 端口

AioServer

public AioServer(InetSocketAddress address,
                 SocketConfig config)

构造

Parameters:

address - 地址

config - SocketConfig 配置项

Method Detail

init

public AioServer init(InetSocketAddress address)

初始化

Parameters:

address - 地址和端口

Returns:

this

start

public void start(boolean sync)

开始监听

Parameters:

sync - 是否阻塞

setOption

public <T> AioServer setOption(SocketOption<T> name,
                               T value)
                        throws IOException

设置 Socket 的 Option 选项
选项见：StandardSocketOptions

Type Parameters:

T - 选项泛型

Parameters:

name - SocketOption 枚举

value - SocketOption参数

Returns:

this

Throws:

IOException - IO异常

getIoAction

public IoAction<ByteBuffer> getIoAction()

获取IO处理器

Returns:

IoAction

setIoAction

public AioServer setIoAction(IoAction<ByteBuffer> ioAction)

设置IO处理器，单例存在

Parameters:

ioAction - IoAction

Returns:

this;

getChannel

public AsynchronousServerSocketChannel getChannel()

获取AsynchronousServerSocketChannel

Returns:

AsynchronousServerSocketChannel

accept

public AioServer accept()

处理接入的客户端

Returns:

this

isOpen

public boolean isOpen()

服务是否开启状态

Returns:

服务是否开启状态

close

public void close()

关闭服务

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable