com.alipay.mychain.sdk.network

类 ClientNetwork

java.lang.Object

com.alipay.mychain.sdk.network.ClientNetwork

所有已实现的接口:

INetwork

直接已知子类:

HttpClientNetwork, TcpClientNetwork

public class ClientNetwork
extends Object
implements INetwork

版本:

$Id: ClientNetwork, v0.1 2019年05月03日 上午11:08 xiuyi.lp Exp $

作者:

xiuyi.lp

嵌套类概要

嵌套类

限定符和类型	类和说明
class	ClientNetwork.ConnectCallback
class	ClientNetwork.LoadbalanceCallback

构造器概要

构造器

构造器和说明
ClientNetwork()

方法概要

限定符和类型	方法和说明
void	checkAndSetStatus(String endpoint, ChannelStatus status) 设置某个节点的状态
ConnectionPoolManager	getConnectionPoolManager()
String	getConnEndpoint(LoadBalanceMsgType loadBalanceMsgType, byte[] seed)
NetworkConnection	getConnNetworkConnection(LoadBalanceMsgType loadBalanceMsgType, byte[] seed)
String	getCurrentConnectionEndpoint() 获取当前的连接
long	getLastActiveTime(String endpoint) 获取某个节点的last active time
NetworkConnection	getSuitableConnection(Request request, ConnectionPoolManager connectionPoolManager)
long	getSystemTimestamp() get system timestamp
void	poolTask(ConnectionPoolManager connectionPoolManager)
boolean	registerAllConnectionEventHandler(IConnectionCallback eventHandler, ConnectionPoolManager connectionPoolManager)
boolean	registerConnectionEventHandler(IConnectionCallback eventHandler) 对于非最佳路径选择的时候，我们任意选择一个connectionpoolmanager中选择一个就可以了，因为都是同一个networkconenction
boolean	registerEventHandler(MessageType type, IEventCallback eventCallback) Register event handler.
boolean	registerOptimalConnectionEventHandler(IConnectionCallback connectionCallback) 如果是需要最优链路的话，我们 注册最优链路的事件处理器
int	sendAsyncRequest(Request request, Hash hash, IAsyncCallback callback, int timeout) Send async transaction.
int	sendAsyncRequest(Request request, Hash hash, IAsyncCallback callback, int timeout, String endpoint) send async request with endpoint
Response	sendSyncRequest(Request request, Hash hash, int timeout) Send sync transaction response.
Response	sendSyncRequest(Request request, Hash hash, int timeout, String endpoint) 给指定的endpoint 发送消息
void	setConnectionPoolManager(ConnectionPoolManager connectionPoolManager)
boolean	shutDown() Shut down boolean.
boolean	startup(NetworkOption networkOption, ISslOption sslOption, TimerTaskManager timerTaskManager, ILogger logger) startup
boolean	startup(NetworkOption networkOption, ISslOption sslOption, TimerTaskManager timerTaskManager, ILogger logger, ClientEnv clientEnv)
boolean	unRegisterEventHandler(MessageType type) unRegister event handler

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

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

构造器详细资料

ClientNetwork

public ClientNetwork()

方法详细资料

startup

public boolean startup(NetworkOption networkOption,
                       ISslOption sslOption,
                       TimerTaskManager timerTaskManager,
                       ILogger logger)

从接口复制的说明: INetwork

startup

指定者:

startup 在接口中 INetwork

参数:

networkOption - network option

sslOption - ssl option

timerTaskManager - time task mgr

logger - logger

返回:

boolean

startup

public boolean startup(NetworkOption networkOption,
                       ISslOption sslOption,
                       TimerTaskManager timerTaskManager,
                       ILogger logger,
                       ClientEnv clientEnv)

指定者:

startup 在接口中 INetwork

poolTask

public void poolTask(ConnectionPoolManager connectionPoolManager)

getConnectionPoolManager

public ConnectionPoolManager getConnectionPoolManager()

setConnectionPoolManager

public void setConnectionPoolManager(ConnectionPoolManager connectionPoolManager)

shutDown

public boolean shutDown()

从接口复制的说明: INetwork

Shut down boolean.

指定者:

shutDown 在接口中 INetwork

返回:

the boolean

getSuitableConnection

public NetworkConnection getSuitableConnection(Request request,
                                               ConnectionPoolManager connectionPoolManager)

sendSyncRequest

public Response sendSyncRequest(Request request,
                                Hash hash,
                                int timeout)

从接口复制的说明: INetwork

Send sync transaction response.

指定者:

sendSyncRequest 在接口中 INetwork

参数:

request - the base request

hash - hash

timeout - the timeout

返回:

the response

sendSyncRequest

public Response sendSyncRequest(Request request,
                                Hash hash,
                                int timeout,
                                String endpoint)

从接口复制的说明: INetwork

给指定的endpoint 发送消息

指定者:

sendSyncRequest 在接口中 INetwork

返回:

sendAsyncRequest

public int sendAsyncRequest(Request request,
                            Hash hash,
                            IAsyncCallback callback,
                            int timeout)

从接口复制的说明: INetwork

Send async transaction.

指定者:

sendAsyncRequest 在接口中 INetwork

参数:

request - the base request

hash - hash

callback - the callback

timeout - the timeout

返回:

int

sendAsyncRequest

public int sendAsyncRequest(Request request,
                            Hash hash,
                            IAsyncCallback callback,
                            int timeout,
                            String endpoint)

从接口复制的说明: INetwork

send async request with endpoint

指定者:

sendAsyncRequest 在接口中 INetwork

返回:

registerOptimalConnectionEventHandler

public boolean registerOptimalConnectionEventHandler(IConnectionCallback connectionCallback)

从接口复制的说明: INetwork

如果是需要最优链路的话，我们 注册最优链路的事件处理器

指定者:

registerOptimalConnectionEventHandler 在接口中 INetwork

返回:

registerAllConnectionEventHandler

public boolean registerAllConnectionEventHandler(IConnectionCallback eventHandler,
                                                 ConnectionPoolManager connectionPoolManager)

registerConnectionEventHandler

public boolean registerConnectionEventHandler(IConnectionCallback eventHandler)

对于非最佳路径选择的时候，我们任意选择一个connectionpoolmanager中选择一个就可以了，因为都是同一个networkconenction

指定者:

registerConnectionEventHandler 在接口中 INetwork

参数:

eventHandler - the event handler

返回:

registerEventHandler

public boolean registerEventHandler(MessageType type,
                                    IEventCallback eventCallback)

从接口复制的说明: INetwork

Register event handler.

指定者:

registerEventHandler 在接口中 INetwork

参数:

type - the msg type

eventCallback - the event callback

返回:

boolean

unRegisterEventHandler

public boolean unRegisterEventHandler(MessageType type)

从接口复制的说明: INetwork

unRegister event handler

指定者:

unRegisterEventHandler 在接口中 INetwork

参数:

type - the msg type

返回:

boolean

getLastActiveTime

public long getLastActiveTime(String endpoint)

从接口复制的说明: INetwork

获取某个节点的last active time

指定者:

getLastActiveTime 在接口中 INetwork

返回:

checkAndSetStatus

public void checkAndSetStatus(String endpoint,
                              ChannelStatus status)

从接口复制的说明: INetwork

设置某个节点的状态

指定者:

checkAndSetStatus 在接口中 INetwork

getSystemTimestamp

public long getSystemTimestamp()

从接口复制的说明: INetwork

get system timestamp

指定者:

getSystemTimestamp 在接口中 INetwork

返回:

system timestamp

getCurrentConnectionEndpoint

public String getCurrentConnectionEndpoint()

从接口复制的说明: INetwork

获取当前的连接

指定者:

getCurrentConnectionEndpoint 在接口中 INetwork

返回:

getConnNetworkConnection

public NetworkConnection getConnNetworkConnection(LoadBalanceMsgType loadBalanceMsgType,
                                                  byte[] seed)

指定者:

getConnNetworkConnection 在接口中 INetwork

getConnEndpoint

public String getConnEndpoint(LoadBalanceMsgType loadBalanceMsgType,
                              byte[] seed)

指定者:

getConnEndpoint 在接口中 INetwork