public class ClientChannelContext extends ChannelContext
ChannelContext.CloseCode, ChannelContext.CloseMeta
asynchronousSocketChannel, closeLock, closeMeta, decodeRunnable, handlerRunnable, hasTempDir, heartbeatTimeout, isClosed, isReconnect, isRemoved, isVirtual, isWaitingClose, logWhenDecodeError, packetNeededLength, sendRunnable, sslFacadeContext, stat, tioConfig, UNKNOWN_ADDRESS_IP, UNKNOWN_ADDRESS_PORT_SEQ, userid, writeCompletionHandler
Constructor and Description |
---|
ClientChannelContext(TioConfig tioConfig)
创建一个虚拟ChannelContext,主要用来模拟一些操作,真实场景中用得少
|
ClientChannelContext(TioConfig tioConfig,
AsynchronousSocketChannel asynchronousSocketChannel) |
Modifier and Type | Method and Description |
---|---|
Node |
createClientNode(AsynchronousSocketChannel asynchronousSocketChannel)
创建Node
|
String |
getBindIp() |
Integer |
getBindPort() |
AtomicInteger |
getReconnCount() |
ReconnRunnable |
getReconnRunnable() |
boolean |
isServer()
是否是服务器端
|
void |
setBindIp(String bindIp) |
void |
setBindPort(Integer bindPort) |
void |
setReconnCount(AtomicInteger reconnCount) |
void |
setReconnRunnable(ReconnRunnable reconnRunnable) |
equals, get, getAttribute, getBsId, getClientNode, getCloseCode, getGroups, getHeartbeatTimeout, getId, getProxyClientNode, getReadBufferSize, getReadCompletionHandler, getServerNode, getTioConfig, getToken, getWriteCompletionHandler, hashCode, init, processAfterSent, set, setAsynchronousSocketChannel, setAttribute, setBsId, setClientNode, setCloseCode, setClosed, setHeartbeatTimeout, setPacketNeededLength, setProxyClientNode, setReadBufferSize, setReconnect, setRemoved, setServerNode, setSslFacadeContext, setTioConfig, setToken, setUserid, toString
clear, clearAttribute, get, getAttribute, remove, removeAttribute, set, setAttribute
public ClientChannelContext(TioConfig tioConfig, AsynchronousSocketChannel asynchronousSocketChannel)
tioConfig
- asynchronousSocketChannel
- public ClientChannelContext(TioConfig tioConfig)
tioConfig
- public Node createClientNode(AsynchronousSocketChannel asynchronousSocketChannel) throws IOException
ChannelContext
createClientNode
in class ChannelContext
asynchronousSocketChannel
- IOException
ChannelContext.createClientNode(java.nio.channels.AsynchronousSocketChannel)
public String getBindIp()
public Integer getBindPort()
public void setBindIp(String bindIp)
bindIp
- the bindIp to setpublic void setBindPort(Integer bindPort)
bindPort
- the bindPort to setpublic boolean isServer()
ChannelContext
isServer
in class ChannelContext
public ReconnRunnable getReconnRunnable()
public void setReconnRunnable(ReconnRunnable reconnRunnable)
public AtomicInteger getReconnCount()
public void setReconnCount(AtomicInteger reconnCount)
Copyright © 2021. All rights reserved.