com.tencent.tcaplus.net.impl

Class ProxyConnector

java.lang.Object

com.tencent.tcaplus.net.Connector

com.tencent.tcaplus.net.impl.ProxyConnector

public class ProxyConnector
extends Connector

Nested Class Summary

Nested classes/interfaces inherited from class com.tencent.tcaplus.net.Connector

Connector.PackageType

Field Summary

Fields

Modifier and Type	Field and Description
static Comparator<MessageKey>	MESSAGE_KEY_COMPARATOR

Fields inherited from class com.tencent.tcaplus.net.Connector

continualAbnormalTimes, healthy, id, reactor, requestProcessMetric, requestQueueMetric, router, sendMessageQueue, sendMessageQueueSize

Method Summary

Modifier and Type	Method and Description
protected boolean	canSendMessage()
boolean	checkAvailableForPolicy1() 策略1：默认每10秒检查一次，连续3次请求失败率大于90%，则认为Proxy不可用 判断连接是否可用，不可用时将设置连接为不健康状态，proxy收发数据正常后或重连成功后重置为健康状态 返回false时，内部会标记healthy为不健康状态[false]，
boolean	checkAvailableForPolicy2() 策略2：当前固定每300毫秒检查一次，本周期内发送的请求数超过10个，且失败率大于90%，则认为Proxy不可用 判断连接是否可用，不可用时将设置连接为不健康状态，proxy收发数据正常后或重连成功后重置为健康状态 返回false时，外部应该直接断开连接并重连，内部不会标记healthy为不健康状态[false]，
protected void	clearMessageCache()
protected int	getWaitingMessageCount() 获取当前已发送，正在等待接收响应的请求个数
void	increaseErrorCount(int errorCode) 自增请求错误数
void	increaseRequestCount() 自增请求数
void	onCloseMessage(int messageSequence)
protected void	onRecvMessageBuffer(MessageBuffer messageBuffer)
protected void	putMessageToCache(Message message)
void	reset4Reconnect()
int	update()

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

close, connect, getAddress, getConnectCount, getConnectErrorMessage, getConnectState, getDisconnectTime, getEstablishTime, getLastRecheckAvailableTime, getLastRecvTime, getLocalAddress, getSocketChannel, isHealth, onConnect, onConnectError, onRead, onWrite, send, setConnectState, setInterestOperators, setReadyOperators, toString, toString4Tbl

Methods inherited from class java.lang.Object

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

Field Detail

MESSAGE_KEY_COMPARATOR

public static final Comparator<MessageKey> MESSAGE_KEY_COMPARATOR

Method Detail

getWaitingMessageCount

protected int getWaitingMessageCount()

Description copied from class: Connector

获取当前已发送，正在等待接收响应的请求个数

Specified by:

getWaitingMessageCount in class Connector

update

public int update()

Specified by:

update in class Connector

onRecvMessageBuffer

protected void onRecvMessageBuffer(MessageBuffer messageBuffer)

Specified by:

onRecvMessageBuffer in class Connector

onCloseMessage

public void onCloseMessage(int messageSequence)

Specified by:

onCloseMessage in class Connector

canSendMessage

protected boolean canSendMessage()

Specified by:

canSendMessage in class Connector

putMessageToCache

protected void putMessageToCache(Message message)

Specified by:

putMessageToCache in class Connector

clearMessageCache

protected void clearMessageCache()

Specified by:

clearMessageCache in class Connector

checkAvailableForPolicy1

public boolean checkAvailableForPolicy1()

策略1：默认每10秒检查一次，连续3次请求失败率大于90%，则认为Proxy不可用 判断连接是否可用，不可用时将设置连接为不健康状态，proxy收发数据正常后或重连成功后重置为健康状态 返回false时，内部会标记healthy为不健康状态[false]，

checkAvailableForPolicy2

public boolean checkAvailableForPolicy2()

策略2：当前固定每300毫秒检查一次，本周期内发送的请求数超过10个，且失败率大于90%，则认为Proxy不可用 判断连接是否可用，不可用时将设置连接为不健康状态，proxy收发数据正常后或重连成功后重置为健康状态 返回false时，外部应该直接断开连接并重连，内部不会标记healthy为不健康状态[false]，

increaseRequestCount

public void increaseRequestCount()

Description copied from class: Connector

自增请求数

Overrides:

increaseRequestCount in class Connector

increaseErrorCount

public void increaseErrorCount(int errorCode)

Description copied from class: Connector

自增请求错误数

Overrides:

increaseErrorCount in class Connector

reset4Reconnect

public void reset4Reconnect()

Overrides:

reset4Reconnect in class Connector