org.tio.client

Class ClientGroupContext

java.lang.Object

org.tio.utils.prop.MapWithLockPropSupport

org.tio.core.GroupContext

org.tio.client.ClientGroupContext

All Implemented Interfaces:

IPropSupport

public class ClientGroupContext
extends GroupContext

Author:

tanyaowu 2017年4月1日 上午9:31:31

Field Summary

Fields

Modifier and Type	Field and Description
SetWithLock<ChannelContext>	closeds
SetWithLock<ChannelContext>	connecteds
protected ReconnConf	reconnConf

Fields inherited from class org.tio.core.GroupContext

bsIds, clientNodes, closeRunnable, connections, debug, groupExecutor, groups, groupStat, heartbeatTimeout, id, ids, ipBlacklist, ips, ipStats, isShortConnection, maxDecodeErrorCountForIp, name, packetConverter, packetHandlerMode, READ_BUFFER_SIZE, sslConfig, startTime, statOn, tioExecutor, tokens, useQueueDecode, useQueueSend, users, waitingResps

Constructor Summary

Constructors

Constructor and Description
ClientGroupContext(ClientAioHandler aioHandler, ClientAioListener aioListener) 不重连
ClientGroupContext(ClientAioHandler aioHandler, ClientAioListener aioListener, ReconnConf reconnConf)
ClientGroupContext(ClientAioHandler aioHandler, ClientAioListener aioListener, ReconnConf reconnConf, SynThreadPoolExecutor tioExecutor, ThreadPoolExecutor groupExecutor)

Method Summary

Modifier and Type	Method and Description
AioHandler	getAioHandler() 获取AioHandler对象
AioListener	getAioListener() 获取AioListener对象
ClientAioHandler	getClientAioHandler()
ClientAioListener	getClientAioListener()
ConnectionCompletionHandler	getConnectionCompletionHandler()
ReconnConf	getReconnConf()
boolean	isServer() 是服务器端还是客户端
void	setClientAioHandler(ClientAioHandler clientAioHandler)
void	setClientAioListener(ClientAioListener clientAioListener)
void	setConnectionCompletionHandler(ConnectionCompletionHandler connectionCompletionHandler)
void	setReconnConf(ReconnConf reconnConf)
void	useSsl() 使用ssl访问

Methods inherited from class org.tio.core.GroupContext

getByteOrder, getGroupListener, getGroupStat, getId, getIpStatListener, getName, getReadBufferSize, getTioClusterConfig, getTioUuid, getWaitingResps, isCluster, isSsl, isStopped, setByteOrder, setGroupListener, setHeartbeatTimeout, setIpStatListener, setName, setPacketHandlerMode, setReadBufferSize, setShortConnection, setSslConfig, setStopped, setTioClusterConfig, setTioUuid, setUseQueueDecode, setUseQueueSend, share

Methods inherited from class org.tio.utils.prop.MapWithLockPropSupport

clearAttribute, getAttribute, removeAttribute, setAttribute

Methods inherited from class java.lang.Object

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

Field Detail

reconnConf

protected ReconnConf reconnConf

connecteds

public final SetWithLock<ChannelContext> connecteds

closeds

public final SetWithLock<ChannelContext> closeds

Constructor Detail

ClientGroupContext

public ClientGroupContext(ClientAioHandler aioHandler,
                          ClientAioListener aioListener)

不重连

Parameters:

aioHandler -

aioListener -

ClientGroupContext

public ClientGroupContext(ClientAioHandler aioHandler,
                          ClientAioListener aioListener,
                          ReconnConf reconnConf)

Parameters:

aioHandler -

aioListener -

reconnConf - 不用框架自动重连，就传null

ClientGroupContext

public ClientGroupContext(ClientAioHandler aioHandler,
                          ClientAioListener aioListener,
                          ReconnConf reconnConf,
                          SynThreadPoolExecutor tioExecutor,
                          ThreadPoolExecutor groupExecutor)

Parameters:

aioHandler -

aioListener -

reconnConf - 不用框架自动重连，就传null

tioExecutor -

groupExecutor -

Method Detail

useSsl

public void useSsl()
            throws Exception

使用ssl访问

Throws:

Exception

getAioHandler

public AioHandler getAioHandler()

Description copied from class: GroupContext

获取AioHandler对象

Specified by:

getAioHandler in class GroupContext

Returns:

See Also:

GroupContext.getAioHandler()

getAioListener

public AioListener getAioListener()

Description copied from class: GroupContext

获取AioListener对象

Specified by:

getAioListener in class GroupContext

Returns:

See Also:

GroupContext.getAioListener()

getClientAioHandler

public ClientAioHandler getClientAioHandler()

Returns:

the clientAioHandler

getClientAioListener

public ClientAioListener getClientAioListener()

Returns:

the clientAioListener

getConnectionCompletionHandler

public ConnectionCompletionHandler getConnectionCompletionHandler()

Returns:

the connectionCompletionHandler

setClientAioHandler

public void setClientAioHandler(ClientAioHandler clientAioHandler)

Parameters:

clientAioHandler - the clientAioHandler to set

setClientAioListener

public void setClientAioListener(ClientAioListener clientAioListener)

Parameters:

clientAioListener - the clientAioListener to set

setConnectionCompletionHandler

public void setConnectionCompletionHandler(ConnectionCompletionHandler connectionCompletionHandler)

Parameters:

connectionCompletionHandler - the connectionCompletionHandler to set

setReconnConf

public void setReconnConf(ReconnConf reconnConf)

Parameters:

reconnConf - the reconnConf to set

getReconnConf

public ReconnConf getReconnConf()

Returns:

isServer

public boolean isServer()

Description copied from class: GroupContext

是服务器端还是客户端

Specified by:

isServer in class GroupContext

Returns: