net.ymate.platform.serv.nio.server

Class NioSessionManager<SESSION_WRAPPER extends NioSessionWrapper,MESSAGE_TYPE>

java.lang.Object

net.ymate.platform.serv.AbstractSessionManager<SESSION_WRAPPER,String,MESSAGE_TYPE>

net.ymate.platform.serv.nio.server.NioSessionManager<SESSION_WRAPPER,MESSAGE_TYPE>

Type Parameters:

SESSION_WRAPPER - 会话包装类型

MESSAGE_TYPE - 消息类型

All Implemented Interfaces:

AutoCloseable, ISessionManager<SESSION_WRAPPER,String,MESSAGE_TYPE>

public class NioSessionManager<SESSION_WRAPPER extends NioSessionWrapper,MESSAGE_TYPE>
extends AbstractSessionManager<SESSION_WRAPPER,String,MESSAGE_TYPE>

TCP客户端会话管理器

Author:

刘镇 (suninformation@163.com) on 2018/11/12 3:40 PM

Constructor Summary

Constructors

Constructor and Description
NioSessionManager(IServerCfg serverCfg, INioCodec codec, INioSessionListener<SESSION_WRAPPER,MESSAGE_TYPE> listener)
NioSessionManager(IServerCfg serverCfg, INioCodec codec, INioSessionListener<SESSION_WRAPPER,MESSAGE_TYPE> listener, long idleTimeInMillis)

Method Summary

Modifier and Type	Method and Description
protected IServer<?,?>	buildServer(IServerCfg serverCfg, INioCodec codec) 根据服务端配置构建服务端实例
protected SESSION_WRAPPER	buildSessionWrapper(INioSession session, InetSocketAddress socketAddress) 根据会话对象构建包装器
void	closeSessionWrapper(SESSION_WRAPPER sessionWrapper) 关闭会话并从会话管理器中移除
INioSessionListener<SESSION_WRAPPER,MESSAGE_TYPE>	getSessionListener() 获取会话事件监听器
boolean	sendTo(String sessionId, MESSAGE_TYPE message) 向目标客户端发送消息

Methods inherited from class net.ymate.platform.serv.AbstractSessionManager

close, contains, idleChecker, initialize, putSessionWrapper, register, registerSession, removeSessionWrapper, sessionCount, sessionWrapper, sessionWrappers, speedometer, speedTouch

Methods inherited from class java.lang.Object

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

Constructor Detail

NioSessionManager

public NioSessionManager(IServerCfg serverCfg,
                         INioCodec codec,
                         INioSessionListener<SESSION_WRAPPER,MESSAGE_TYPE> listener)

NioSessionManager

public NioSessionManager(IServerCfg serverCfg,
                         INioCodec codec,
                         INioSessionListener<SESSION_WRAPPER,MESSAGE_TYPE> listener,
                         long idleTimeInMillis)

Method Detail

buildSessionWrapper

protected SESSION_WRAPPER buildSessionWrapper(INioSession session,
                                              InetSocketAddress socketAddress)

Description copied from class: AbstractSessionManager

根据会话对象构建包装器

Specified by:

buildSessionWrapper in class AbstractSessionManager<SESSION_WRAPPER extends NioSessionWrapper,String,MESSAGE_TYPE>

Parameters:

session - 会话对象

socketAddress - 目标来源套接字地址

Returns:

返回包装器对象

buildServer

protected IServer<?,?> buildServer(IServerCfg serverCfg,
                                   INioCodec codec)

Description copied from class: AbstractSessionManager

根据服务端配置构建服务端实例

Specified by:

buildServer in class AbstractSessionManager<SESSION_WRAPPER extends NioSessionWrapper,String,MESSAGE_TYPE>

Parameters:

serverCfg - 服务端配置

codec - 编解码器

Returns:

返回构建后的服务端接口实例对象

closeSessionWrapper

public void closeSessionWrapper(SESSION_WRAPPER sessionWrapper)

Description copied from interface: ISessionManager

关闭会话并从会话管理器中移除

Specified by:

closeSessionWrapper in interface ISessionManager<SESSION_WRAPPER extends NioSessionWrapper,String,MESSAGE_TYPE>

Overrides:

closeSessionWrapper in class AbstractSessionManager<SESSION_WRAPPER extends NioSessionWrapper,String,MESSAGE_TYPE>

Parameters:

sessionWrapper - 会话包装器实例

getSessionListener

public INioSessionListener<SESSION_WRAPPER,MESSAGE_TYPE> getSessionListener()

Description copied from interface: ISessionManager

获取会话事件监听器

Returns:

会话事件监听器接口实现

sendTo

public boolean sendTo(String sessionId,
                      MESSAGE_TYPE message)
               throws IOException

Description copied from interface: ISessionManager

向目标客户端发送消息

Parameters:

sessionId - 目标客户端会话唯一标识

message - 消息对象

Returns:

若指定的目标客户端标识存在且有效则返回true

Throws:

IOException - 可能产生的异常