com.antchain.unionsdk.btn.api.network

类 BtnClientNetwork

java.lang.Object

com.antchain.unionsdk.btn.api.network.BtnClientNetwork

所有已实现的接口:

INetwork<ProtobufRequest>

public class BtnClientNetwork
extends Object
implements INetwork<ProtobufRequest>

构造器概要

构造器

构造器和说明
BtnClientNetwork()

方法概要

限定符和类型	方法和说明
Set<String>	getDownloadingFileKeys()
long	getLastActiveTime(String endpoint)
long	getReceiveTaskCount()
long	getSendTaskCount()
NodeRegEntity.TnRouteType	getTnRoutType(String endpointArg)
boolean	isNodeGroupIsAreadyRegister()
boolean	listenDownloadFile(IEventCallBack eventCallBack)
boolean	listenEvent(IEventCallBack callBack, TnCmdIdEnums cmdIdEnums)
boolean	listenGetDownloadFileMetaData(IEventCallBack eventCallBack, long key)
boolean	nodeGroupReg(String endpoint)
boolean	noderegAll(String endpointArg)
boolean	removeConnection(String endpoint)
Response	sendAsyncRequest(ProtobufRequest protobufRequest, IAsyncCallBack callback, boolean isNecessaryNodeRegistered, boolean isNecessaryNodeGroupRegistered, int timeout)
Response	sendAsyncRequest(ProtobufRequest protobufRequest, IAsyncCallBack callback, String endpoint, boolean isNecessaryNodeRegistered, boolean isNecessaryNodeGroupRegistered)
Response	sendSyncRequest(ProtobufRequest protobufRequest, boolean isNecessaryNodeRegistered, boolean isNecessaryNodeGroupRegistered, int requestTimeouts)
Response	sendSyncRequest(ProtobufRequest protobufRequest, String endpoint, boolean isNecessaryNodeRegistered, boolean isNecessaryNodeGroupRegistered, int requestTimeouts)
void	setConnectionNodeRegisterStatus(String endpoint)
void	setNodeGroupIsAreadyRegister(boolean nodeGroupIsAreadyRegister)
boolean	shutDown()
boolean	startup(NetworkOption networkOption, RequestOption requestOption, ISslOption iSslOption, NodeRegisterConfig nodeRegisterConfig, NodeGroupRegisterConfig nodeGroupRegisterConfig, BtnClient btnClient, DownloadFileOption downloadFileOption)
boolean	unListenEvent(IEventCallBack callBack, TnCmdIdEnums cmdIdEnums)
boolean	unListenGetDownloadFileMetaData(long key)
boolean	unRegisterEvents(String endpoint)
void	updateLastActiveEndpointMaps(String endpoint)
void	updateNodeRegisterTask(int groupUpdateIntervalSecRG)

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

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

构造器详细资料

BtnClientNetwork

public BtnClientNetwork()

方法详细资料

startup

public boolean startup(NetworkOption networkOption,
                       RequestOption requestOption,
                       ISslOption iSslOption,
                       NodeRegisterConfig nodeRegisterConfig,
                       NodeGroupRegisterConfig nodeGroupRegisterConfig,
                       BtnClient btnClient,
                       DownloadFileOption downloadFileOption)

updateNodeRegisterTask

public void updateNodeRegisterTask(int groupUpdateIntervalSecRG)

getTnRoutType

public NodeRegEntity.TnRouteType getTnRoutType(String endpointArg)

noderegAll

public boolean noderegAll(String endpointArg)

setConnectionNodeRegisterStatus

public void setConnectionNodeRegisterStatus(String endpoint)

nodeGroupReg

public boolean nodeGroupReg(String endpoint)

shutDown

public boolean shutDown()

removeConnection

public boolean removeConnection(String endpoint)

指定者:

removeConnection 在接口中 INetwork<ProtobufRequest>

unRegisterEvents

public boolean unRegisterEvents(String endpoint)

listenEvent

public boolean listenEvent(IEventCallBack callBack,
                           TnCmdIdEnums cmdIdEnums)

unListenEvent

public boolean unListenEvent(IEventCallBack callBack,
                             TnCmdIdEnums cmdIdEnums)

listenGetDownloadFileMetaData

public boolean listenGetDownloadFileMetaData(IEventCallBack eventCallBack,
                                             long key)

unListenGetDownloadFileMetaData

public boolean unListenGetDownloadFileMetaData(long key)

listenDownloadFile

public boolean listenDownloadFile(IEventCallBack eventCallBack)

sendSyncRequest

public Response sendSyncRequest(ProtobufRequest protobufRequest,
                                boolean isNecessaryNodeRegistered,
                                boolean isNecessaryNodeGroupRegistered,
                                int requestTimeouts)

sendSyncRequest

public Response sendSyncRequest(ProtobufRequest protobufRequest,
                                String endpoint,
                                boolean isNecessaryNodeRegistered,
                                boolean isNecessaryNodeGroupRegistered,
                                int requestTimeouts)

sendAsyncRequest

public Response sendAsyncRequest(ProtobufRequest protobufRequest,
                                 IAsyncCallBack callback,
                                 boolean isNecessaryNodeRegistered,
                                 boolean isNecessaryNodeGroupRegistered,
                                 int timeout)

sendAsyncRequest

public Response sendAsyncRequest(ProtobufRequest protobufRequest,
                                 IAsyncCallBack callback,
                                 String endpoint,
                                 boolean isNecessaryNodeRegistered,
                                 boolean isNecessaryNodeGroupRegistered)

getLastActiveTime

public long getLastActiveTime(String endpoint)

指定者:

getLastActiveTime 在接口中 INetwork<ProtobufRequest>

getSendTaskCount

public long getSendTaskCount()

getReceiveTaskCount

public long getReceiveTaskCount()

updateLastActiveEndpointMaps

public void updateLastActiveEndpointMaps(String endpoint)
                                  throws com.google.protobuf.InvalidProtocolBufferException

抛出:

com.google.protobuf.InvalidProtocolBufferException

isNodeGroupIsAreadyRegister

public boolean isNodeGroupIsAreadyRegister()

setNodeGroupIsAreadyRegister

public void setNodeGroupIsAreadyRegister(boolean nodeGroupIsAreadyRegister)

getDownloadingFileKeys

public Set<String> getDownloadingFileKeys()