net.ymate.platform.serv.nio

Class AbstractNioServer<LISTENER extends IListener<INioSession>>

java.lang.Object

net.ymate.platform.serv.nio.AbstractNioServer<LISTENER>

Type Parameters:

LISTENER - 监听器类型

All Implemented Interfaces:

Closeable, AutoCloseable, IServer<LISTENER,INioCodec>

Direct Known Subclasses:

NioServer, NioUdpServer

public abstract class AbstractNioServer<LISTENER extends IListener<INioSession>>
extends Object
implements IServer<LISTENER,INioCodec>

Author:

刘镇 (suninformation@163.com) on 2018/11/15 4:49 PM

Constructor Summary

Constructors

Constructor and Description
AbstractNioServer()

Method Summary

Modifier and Type	Method and Description
protected abstract INioEventGroup<LISTENER>	buildEventGroup(IServerCfg serverCfg, LISTENER listener, INioCodec codec) 由子类实现创建多路复用通道事件处理器逻辑
void	close()
void	initialize(IServerCfg serverCfg, LISTENER listener, INioCodec codec) 初始化服务端
boolean	isStarted() 判断是否已启动
<T extends LISTENER> T	listener() 获取监听器对象
IServerCfg	serverCfg() 获取服务端配置
void	start() 启动服务端

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractNioServer

public AbstractNioServer()

Method Detail

buildEventGroup

protected abstract INioEventGroup<LISTENER> buildEventGroup(IServerCfg serverCfg,
                                                            LISTENER listener,
                                                            INioCodec codec)
                                                     throws IOException

由子类实现创建多路复用通道事件处理器逻辑

Parameters:

serverCfg - 服务端配置对象

listener - 事件监听器

codec - 编解码器

Returns:

返回多路复用通道事件处理器

Throws:

IOException - 可能产生的I/O异常

initialize

public void initialize(IServerCfg serverCfg,
                       LISTENER listener,
                       INioCodec codec)

Description copied from interface: IServer

初始化服务端

Specified by:

initialize in interface IServer<LISTENER extends IListener<INioSession>,INioCodec>

Parameters:

serverCfg - 服务端配置

listener - 事件适配器

codec - 解码器

start

public void start()
           throws IOException

Description copied from interface: IServer

启动服务端

Specified by:

start in interface IServer<LISTENER extends IListener<INioSession>,INioCodec>

Throws:

IOException - 可能产生的异常

isStarted

public boolean isStarted()

Description copied from interface: IServer

判断是否已启动

Specified by:

isStarted in interface IServer<LISTENER extends IListener<INioSession>,INioCodec>

Returns:

返回true表示已启动

serverCfg

public IServerCfg serverCfg()

Description copied from interface: IServer

获取服务端配置

Specified by:

serverCfg in interface IServer<LISTENER extends IListener<INioSession>,INioCodec>

Returns:

服务端配置对象

listener

public <T extends LISTENER> T listener()

Description copied from interface: IServer

获取监听器对象

Specified by:

listener in interface IServer<LISTENER extends IListener<INioSession>,INioCodec>

Type Parameters:

T - 监听器类型

Returns:

返回监听器接口实现类对象

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException