public class ClientChannelContext extends ChannelContext
ChannelContext.CloseCode, ChannelContext.CloseMetaasynchronousSocketChannel, 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, toStringclear, clearAttribute, get, getAttribute, remove, removeAttribute, set, setAttributepublic ClientChannelContext(TioConfig tioConfig, AsynchronousSocketChannel asynchronousSocketChannel)
tioConfig - asynchronousSocketChannel - public ClientChannelContext(TioConfig tioConfig)
tioConfig - public Node createClientNode(AsynchronousSocketChannel asynchronousSocketChannel) throws IOException
ChannelContextcreateClientNode in class ChannelContextasynchronousSocketChannel - IOExceptionChannelContext.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()
ChannelContextisServer in class ChannelContextpublic ReconnRunnable getReconnRunnable()
public void setReconnRunnable(ReconnRunnable reconnRunnable)
public AtomicInteger getReconnCount()
public void setReconnCount(AtomicInteger reconnCount)
Copyright © 2021. All rights reserved.