com.tencent.tcaplus.net.impl

Class ProxyRouter

java.lang.Object

com.tencent.tcaplus.net.Router

com.tencent.tcaplus.net.impl.ProxyRouter

All Implemented Interfaces:

MessageFuture

public class ProxyRouter
extends Router
implements MessageFuture

ProxyRouter接口实现类

Version:

version 1.0

Author:

yahuiwang

Constructor Summary

Constructors

Constructor and Description
ProxyRouter(int appId, int zoneId, Reactor reactor, ProtocolSupport protocolSupport, MessageHandler messageHandler, RequestMetrics requestMetrics, AlarmCollector alarmCollector)

Method Summary

Modifier and Type	Method and Description
void	addChangedConnector(Connector connector)
protected Connector	findConnector(long hash) 根据hash值，获得一个连接器
Integer	getConnectErrorCode()
int	getNormalConnectorCount()
String	getRouteInformation()
boolean	isAllNormal()
boolean	isAnyNormal()
boolean	isLeastNormal() 当前可用的Proxy数量是否满足最低要求（>40%，并且最少1个）。
boolean	isMoreThanHalfNormal() 是否有超过50%的Proxy是可用的？
boolean	isMostNormal() 是否大多数（>80%，并且至少两个）Proxy是可用的。
void	onConnect(Connector connector)
void	onGetProxyAddressesResponse(ResGetTablesAndAccess response)
void	onMessage(Message message)
void	shutdown()
String	toString()
int	update()

Methods inherited from class com.tencent.tcaplus.net.Router

addRecvSize, addSendSize, getAddresses, getMessageCommand, getMessageMagic, getProtocolSupport, getReactor, getRecvBytes, getSendBytes, isAddressesChanged, sendMsg, setAddresses

Methods inherited from class java.lang.Object

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

Constructor Detail

ProxyRouter

public ProxyRouter(int appId,
                   int zoneId,
                   Reactor reactor,
                   ProtocolSupport protocolSupport,
                   MessageHandler messageHandler,
                   RequestMetrics requestMetrics,
                   AlarmCollector alarmCollector)

Method Detail

getNormalConnectorCount

public int getNormalConnectorCount()

getConnectErrorCode

public Integer getConnectErrorCode()

getRouteInformation

public String getRouteInformation()

isAnyNormal

public boolean isAnyNormal()

isAllNormal

public boolean isAllNormal()

isMostNormal

public boolean isMostNormal()

是否大多数（>80%，并且至少两个）Proxy是可用的。

isLeastNormal

public boolean isLeastNormal()

当前可用的Proxy数量是否满足最低要求（>40%，并且最少1个）。

isMoreThanHalfNormal

public boolean isMoreThanHalfNormal()

是否有超过50%的Proxy是可用的？

update

public int update()

Specified by:

update in class Router

Returns:

空闲返回0，忙返回正值

onConnect

public void onConnect(Connector connector)

Specified by:

onConnect in class Router

onMessage

public void onMessage(Message message)

Specified by:

onMessage in interface MessageFuture

Specified by:

onMessage in class Router

onGetProxyAddressesResponse

public void onGetProxyAddressesResponse(ResGetTablesAndAccess response)

findConnector

protected Connector findConnector(long hash)

Description copied from class: Router

根据hash值，获得一个连接器

Specified by:

findConnector in class Router

Parameters:

hash - hash值

Returns:

返回连接器

addChangedConnector

public void addChangedConnector(Connector connector)

Specified by:

addChangedConnector in class Router

shutdown

public void shutdown()

Specified by:

shutdown in class Router

toString

public String toString()

Overrides:

toString in class Object