com.antchain.unionsdk.network.connection

类 TcpConnection

java.lang.Object

com.antchain.unionsdk.network.connection.TcpConnection

所有已实现的接口:

IConnection

直接已知子类:

BtnTcpConnection

public abstract class TcpConnection
extends Object
implements IConnection

字段概要

字段

限定符和类型	字段和说明
protected io.netty.bootstrap.Bootstrap	bootstrap
protected io.netty.channel.Channel	channel
protected ChannelStatus	channelStatus
protected int	connectIndex
protected List<IConnectionCallback>	connectionCallbackList
protected String	endpoint
protected AtomicLong	lastActiveTime
protected MessageProcessor	messageProcessor
protected INetworkEventHandler	networkEventHandler
protected NetworkOption	networkOption
protected Lock	reentrantLock
protected ISslOption	sslOption

构造器概要

构造器

构造器和说明
TcpConnection(NetworkOption networkOption, ISslOption option, MessageProcessor messageProcessor)

方法概要

限定符和类型	方法和说明
void	addConnectionCallbackList(IConnectionCallback connectionCallback)
abstract boolean	channelIsActive(Map param)
boolean	disConnect() channel disconnect
io.netty.channel.Channel	getChannel()
ChannelStatus	getChannelStatus()
int	getConnectIndex()
String	getEndpoint()
Long	getLastActiveTime()
long	getSendTaskCount()
boolean	init()
abstract void	notifyEvent(String endpoint)
protected ChainErrorCode	sendRequestInternal(int requestTimeouts, TimeUnit timeUnit, byte[] msg, boolean heartBeat, Map param)
void	setChannelStatus(ChannelStatus channelStatus)
void	setConnectIndex(int connectIndex)
void	setEndpoint(String endpoint)
void	setSendTaskCount(long sendTaskCount)
boolean	shutDown()
void	updateLastActiveTime()

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.antchain.unionsdk.network.IConnection

connect

字段详细资料

bootstrap

protected io.netty.bootstrap.Bootstrap bootstrap

channelStatus

protected volatile ChannelStatus channelStatus

channel

protected volatile io.netty.channel.Channel channel

networkOption

protected final NetworkOption networkOption

sslOption

protected final ISslOption sslOption

reentrantLock

protected final Lock reentrantLock

messageProcessor

protected MessageProcessor messageProcessor

networkEventHandler

protected final INetworkEventHandler networkEventHandler

connectIndex

protected int connectIndex

connectionCallbackList

protected final List<IConnectionCallback> connectionCallbackList

lastActiveTime

protected AtomicLong lastActiveTime

endpoint

protected String endpoint

构造器详细资料

TcpConnection

public TcpConnection(NetworkOption networkOption,
                     ISslOption option,
                     MessageProcessor messageProcessor)

方法详细资料

getConnectIndex

public int getConnectIndex()

setConnectIndex

public void setConnectIndex(int connectIndex)

getSendTaskCount

public long getSendTaskCount()

setSendTaskCount

public void setSendTaskCount(long sendTaskCount)

init

public boolean init()

指定者:

init 在接口中 IConnection

disConnect

public boolean disConnect()

从接口复制的说明: IConnection

channel disconnect

指定者:

disConnect 在接口中 IConnection

返回:

boolean

shutDown

public boolean shutDown()

channelIsActive

public abstract boolean channelIsActive(Map param)

getChannel

public io.netty.channel.Channel getChannel()

sendRequestInternal

protected ChainErrorCode sendRequestInternal(int requestTimeouts,
                                             TimeUnit timeUnit,
                                             byte[] msg,
                                             boolean heartBeat,
                                             Map param)

getChannelStatus

public ChannelStatus getChannelStatus()

setChannelStatus

public void setChannelStatus(ChannelStatus channelStatus)

notifyEvent

public abstract void notifyEvent(String endpoint)

addConnectionCallbackList

public void addConnectionCallbackList(IConnectionCallback connectionCallback)

getLastActiveTime

public Long getLastActiveTime()

updateLastActiveTime

public void updateLastActiveTime()

getEndpoint

public String getEndpoint()

setEndpoint

public void setEndpoint(String endpoint)