com.antchain.unionsdk.btn.api.network

类 BtnTcpConnection

java.lang.Object

com.antchain.unionsdk.network.connection.TcpConnection

com.antchain.unionsdk.btn.api.network.BtnTcpConnection

所有已实现的接口:

IConnection

public class BtnTcpConnection
extends TcpConnection

字段概要

从类继承的字段 com.antchain.unionsdk.network.connection.TcpConnection

bootstrap, channel, channelStatus, connectIndex, connectionCallbackList, endpoint, lastActiveTime, messageProcessor, networkEventHandler, networkOption, reentrantLock, sslOption

构造器概要

构造器

构造器和说明
BtnTcpConnection(NetworkOption networkOption, ISslOption sslOption, MessageProcessor messageProcessor, TimerTaskManager timerTaskManager, String nodeId)
BtnTcpConnection(NetworkOption networkOption, ISslOption sslOption, MessageProcessor messageProcessor, TimerTaskManager timerTaskManager, String nodeId, NodeGroupIsRegisterObserver nodeGroupIsRegisterObserver)

方法概要

限定符和类型	方法和说明
boolean	channelIsActive(Map param)
boolean	connect() channel connect
BtnNetSocketAddress	getBtnNetSocketAddress()
String	getNodeId()
boolean	isNodeRegisterStatus()
void	notifyEvent(String endpoint)
boolean	registerEvents(TnCmdIdEnums tnCmdIdEnums, IEventCallBack eventCallBack)
Response	sendAsyncRequest(byte[] msg, String contextKey, IAsyncCallBack callback, int timeout, int cmdId)
Response	sendSyncRequest(byte[] bytes, String contextKey, int requestTimeouts, int cmdId)
Response	sendSyncRequestForNodeAndGroupReRegister(byte[] msg, String contextKey, int requestTimeouts, int cmdId)
void	setBtnNetSocketAddress(BtnNetSocketAddress btnNetSocketAddress)
void	setNodeId(String nodeId)
void	setNodeRegisterStatus(boolean nodeRegisterStatus)
void	unRegisterEvents(TnCmdIdEnums tnCmdIdEnums)

从类继承的方法 com.antchain.unionsdk.network.connection.TcpConnection

addConnectionCallbackList, disConnect, getChannel, getChannelStatus, getConnectIndex, getEndpoint, getLastActiveTime, getSendTaskCount, init, sendRequestInternal, setChannelStatus, setConnectIndex, setEndpoint, setSendTaskCount, shutDown, updateLastActiveTime

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

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

构造器详细资料

BtnTcpConnection

public BtnTcpConnection(NetworkOption networkOption,
                        ISslOption sslOption,
                        MessageProcessor messageProcessor,
                        TimerTaskManager timerTaskManager,
                        String nodeId)

BtnTcpConnection

public BtnTcpConnection(NetworkOption networkOption,
                        ISslOption sslOption,
                        MessageProcessor messageProcessor,
                        TimerTaskManager timerTaskManager,
                        String nodeId,
                        NodeGroupIsRegisterObserver nodeGroupIsRegisterObserver)

方法详细资料

sendSyncRequest

public Response sendSyncRequest(byte[] bytes,
                                String contextKey,
                                int requestTimeouts,
                                int cmdId)

sendSyncRequestForNodeAndGroupReRegister

public Response sendSyncRequestForNodeAndGroupReRegister(byte[] msg,
                                                         String contextKey,
                                                         int requestTimeouts,
                                                         int cmdId)

sendAsyncRequest

public Response sendAsyncRequest(byte[] msg,
                                 String contextKey,
                                 IAsyncCallBack callback,
                                 int timeout,
                                 int cmdId)

registerEvents

public boolean registerEvents(TnCmdIdEnums tnCmdIdEnums,
                              IEventCallBack eventCallBack)

unRegisterEvents

public void unRegisterEvents(TnCmdIdEnums tnCmdIdEnums)

notifyEvent

public void notifyEvent(String endpoint)

指定者:

notifyEvent 在类中 TcpConnection

connect

public boolean connect()

从接口复制的说明: IConnection

channel connect

返回:

boolean

channelIsActive

public boolean channelIsActive(Map param)

指定者:

channelIsActive 在类中 TcpConnection

isNodeRegisterStatus

public boolean isNodeRegisterStatus()

setNodeRegisterStatus

public void setNodeRegisterStatus(boolean nodeRegisterStatus)

getBtnNetSocketAddress

public BtnNetSocketAddress getBtnNetSocketAddress()

setBtnNetSocketAddress

public void setBtnNetSocketAddress(BtnNetSocketAddress btnNetSocketAddress)

getNodeId

public String getNodeId()

setNodeId

public void setNodeId(String nodeId)