com.alipay.mychain.sdk.network

类 ConnectionPoolManager

java.lang.Object

com.alipay.mychain.sdk.network.ConnectionPoolManager

public class ConnectionPoolManager
extends Object

构造器概要

构造器

构造器和说明
ConnectionPoolManager()

方法概要

限定符和类型	方法和说明
void	addNetworkConnection(String endpoint, NetworkConnection networkConnection)
void	chooseAvailableNetworkLink()
void	chooseBestNetworkLink()
Map<String,NetworkConnection>	getConnections()
String	getConnEndpoint(LoadBalanceMsgType loadBalanceMsgType, byte[] seed)
NetworkConnection	getConnNetworkConnection(LoadBalanceMsgType loadBalanceMsgType, byte[] seed)
NetworkConnection	getNetworkConnection(String endpoint)
String	getOptimalEndpoint()
String	getOptimalLinkEndpoint()
NetworkConnection	getOptimalNetworkConnection()
boolean	isRunning()
String	loadBalance(Map<String,NetworkConnection> map, byte[] seed)
void	registerEventHandler(IConnectionCallback connectionCallback)
void	removeConnecitonFromLoadbalancePool(String endpoint)
boolean	shutDown()
boolean	startUp(NetworkOption networkOption, ISslOption sslOption, ICodec codec, MessageProcessor messageProcessor, ILogger logger)
boolean	startUp(NetworkOption networkOption, ISslOption sslOption, ICodec codec, MessageProcessor msgProccessor, ILogger logger, ClientEnv clientEnv)
void	updateNodeStatus(String endpoint, HostStatus hostStatus)

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

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

构造器详细资料

ConnectionPoolManager

public ConnectionPoolManager()

方法详细资料

startUp

public boolean startUp(NetworkOption networkOption,
                       ISslOption sslOption,
                       ICodec codec,
                       MessageProcessor messageProcessor,
                       ILogger logger)

startUp

public boolean startUp(NetworkOption networkOption,
                       ISslOption sslOption,
                       ICodec codec,
                       MessageProcessor msgProccessor,
                       ILogger logger,
                       ClientEnv clientEnv)

chooseAvailableNetworkLink

public void chooseAvailableNetworkLink()

chooseBestNetworkLink

public void chooseBestNetworkLink()

updateNodeStatus

public void updateNodeStatus(String endpoint,
                             HostStatus hostStatus)

addNetworkConnection

public void addNetworkConnection(String endpoint,
                                 NetworkConnection networkConnection)

getOptimalNetworkConnection

public NetworkConnection getOptimalNetworkConnection()

getOptimalEndpoint

public String getOptimalEndpoint()

getNetworkConnection

public NetworkConnection getNetworkConnection(String endpoint)

isRunning

public boolean isRunning()

removeConnecitonFromLoadbalancePool

public void removeConnecitonFromLoadbalancePool(String endpoint)

loadBalance

public String loadBalance(Map<String,NetworkConnection> map,
                          byte[] seed)

getConnNetworkConnection

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

getConnEndpoint

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

getOptimalLinkEndpoint

public String getOptimalLinkEndpoint()

registerEventHandler

public void registerEventHandler(IConnectionCallback connectionCallback)

getConnections

public Map<String,NetworkConnection> getConnections()

shutDown

public boolean shutDown()