net.ymate.platform.serv.nio

Class AbstractNioClient<LISTENER extends IListener<INioSession>>

java.lang.Object

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

Type Parameters:

LISTENER - 监听器类型

All Implemented Interfaces:

Closeable, AutoCloseable, IClient<LISTENER,INioCodec>

Direct Known Subclasses:

NioClient, NioUdpClient

public abstract class AbstractNioClient<LISTENER extends IListener<INioSession>>
extends Object
implements IClient<LISTENER,INioCodec>

Author:

刘镇 (suninformation@163.com) on 15/11/19 下午4:55

Constructor Summary

Constructors

Constructor and Description
AbstractNioClient()

Method Summary

Modifier and Type	Method and Description
protected abstract INioEventGroup<LISTENER>	buildEventGroup(IClientCfg clientCfg, LISTENER listener, INioCodec codec) 由子类实现创建多路复用通道事件处理器逻辑
IClientCfg	clientCfg() 获取客户端配置对象
void	close()
void	connect() 连接远程服务端
void	initialize(IClientCfg clientCfg, LISTENER listener, INioCodec codec, IReconnectService reconnectService, IHeartbeatService<?> heartbeatService) 初始化客户端服务
boolean	isClosing() 是否正在关闭
boolean	isConnected() 是否已连接
long	lastTouchTime() 获取最后更新会话状态的时间(毫秒)
<T extends LISTENER> T	listener() 获取监听器
void	reconnect() 重连远程服务端
void	send(Object message) 向远程服务发送消息
void	touch() 更新会话活动状态

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractNioClient

public AbstractNioClient()

Method Detail

buildEventGroup

protected abstract INioEventGroup<LISTENER> buildEventGroup(IClientCfg clientCfg,
                                                            LISTENER listener,
                                                            INioCodec codec)
                                                     throws IOException

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

Parameters:

clientCfg - 客户端配置对象

listener - 事件监听器

codec - 编解码器

Returns:

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

Throws:

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

initialize

public void initialize(IClientCfg clientCfg,
                       LISTENER listener,
                       INioCodec codec,
                       IReconnectService reconnectService,
                       IHeartbeatService<?> heartbeatService)

Description copied from interface: IClient

初始化客户端服务

Specified by:

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

Parameters:

clientCfg - 客户端配置

listener - 事件适配器

codec - 解码器

reconnectService - 断线重连服务

heartbeatService - 链路维护(心跳)服务

connect

public void connect()
             throws IOException

Description copied from interface: IClient

连接远程服务端

Specified by:

connect in interface IClient<LISTENER extends IListener<INioSession>,INioCodec>

Throws:

IOException - 可能产生的异常

reconnect

public void reconnect()
               throws IOException

Description copied from interface: IClient

重连远程服务端

Specified by:

reconnect in interface IClient<LISTENER extends IListener<INioSession>,INioCodec>

Throws:

IOException - 可能产生的异常

isConnected

public boolean isConnected()

Description copied from interface: IClient

是否已连接

Specified by:

isConnected in interface IClient<LISTENER extends IListener<INioSession>,INioCodec>

Returns:

返回true表示已连接

isClosing

public boolean isClosing()

Description copied from interface: IClient

是否正在关闭

Specified by:

isClosing in interface IClient<LISTENER extends IListener<INioSession>,INioCodec>

Returns:

返回true表示正在关闭

clientCfg

public IClientCfg clientCfg()

Description copied from interface: IClient

获取客户端配置对象

Specified by:

clientCfg in interface IClient<LISTENER extends IListener<INioSession>,INioCodec>

Returns:

返回客户端配置对象

listener

public <T extends LISTENER> T listener()

Description copied from interface: IClient

获取监听器

Specified by:

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

Type Parameters:

T - 监听器类型

Returns:

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

send

public void send(Object message)
          throws IOException

Description copied from interface: IClient

向远程服务发送消息

Specified by:

send in interface IClient<LISTENER extends IListener<INioSession>,INioCodec>

Parameters:

message - 消息对象

Throws:

IOException - 可能产生的异常

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

touch

public void touch()

Description copied from interface: IClient

更新会话活动状态

Specified by:

touch in interface IClient<LISTENER extends IListener<INioSession>,INioCodec>

lastTouchTime

public long lastTouchTime()

Description copied from interface: IClient

获取最后更新会话状态的时间(毫秒)

Specified by:

lastTouchTime in interface IClient<LISTENER extends IListener<INioSession>,INioCodec>

Returns:

返回最后更新会话状态的时间(毫秒)