com.tencent.tcaplus.net

Class Connector

java.lang.Object

com.tencent.tcaplus.net.Connector

Direct Known Subclasses:

DirConnector, ProxyConnector

public abstract class Connector
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	Connector.PackageType

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicLong	continualAbnormalTimes
protected AtomicBoolean	healthy
protected UUID	id
protected Reactor	reactor
protected CostMetric	requestProcessMetric
protected CostMetric	requestQueueMetric
protected Router	router
protected BlockingQueue<Message>	sendMessageQueue
protected AtomicInteger	sendMessageQueueSize

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Connector(Reactor reactor, Router router, String address)

Method Summary

Modifier and Type	Method and Description
protected abstract boolean	canSendMessage()
protected abstract void	clearMessageCache()
void	close() 关闭连接
void	connect() 异步连接服务端
String	getAddress() 获得服务端连接地址
int	getConnectCount()
String	getConnectErrorMessage()
ConnectState	getConnectState()
long	getDisconnectTime()
long	getEstablishTime()
protected long	getLastRecheckAvailableTime()
long	getLastRecvTime() 获得最后收包时间
String	getLocalAddress()
SocketChannel	getSocketChannel() 获得该连接器的SocketChannel对象
protected abstract int	getWaitingMessageCount() 获取当前已发送，正在等待接收响应的请求个数
void	increaseErrorCount(int errorCode) 自增请求错误数
void	increaseRequestCount() 自增请求数
boolean	isHealth() 获取健康状态。
abstract void	onCloseMessage(int messageSequence)
void	onConnect() 连接成功后Reactor框架调用该方法
void	onConnectError(IOException exception)
void	onRead()
protected abstract void	onRecvMessageBuffer(MessageBuffer msgBuf)
void	onWrite()
protected abstract void	putMessageToCache(Message msg)
void	reset4Reconnect()
boolean	send(Message message)
boolean	setConnectState(ConnectState state)
void	setInterestOperators(int operators)
void	setReadyOperators(int operators)
String	toString()
String	toString4Tbl()
abstract int	update()

Methods inherited from class java.lang.Object

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

Field Detail

id

protected final UUID id

router

protected final Router router

reactor

protected final Reactor reactor

sendMessageQueue

protected final BlockingQueue<Message> sendMessageQueue

sendMessageQueueSize

protected final AtomicInteger sendMessageQueueSize

requestProcessMetric

protected final CostMetric requestProcessMetric

requestQueueMetric

protected final CostMetric requestQueueMetric

healthy

protected final AtomicBoolean healthy

continualAbnormalTimes

protected final AtomicLong continualAbnormalTimes

Constructor Detail

Connector

protected Connector(Reactor reactor,
                    Router router,
                    String address)

Method Detail

getAddress

public String getAddress()

获得服务端连接地址

Returns:

返回对端地址, 地址格式：tcp://127.0.0.1:8080

getLocalAddress

public String getLocalAddress()

getLastRecvTime

public long getLastRecvTime()

获得最后收包时间

getDisconnectTime

public long getDisconnectTime()

getEstablishTime

public long getEstablishTime()

getConnectState

public ConnectState getConnectState()

getConnectCount

public int getConnectCount()

getConnectErrorMessage

public String getConnectErrorMessage()

getLastRecheckAvailableTime

protected long getLastRecheckAvailableTime()

getWaitingMessageCount

protected abstract int getWaitingMessageCount()

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

getSocketChannel

public SocketChannel getSocketChannel()

获得该连接器的SocketChannel对象

isHealth

public boolean isHealth()

获取健康状态。

Returns:

boolean [true] 健康/可用 | [false] 不健康/不可用

See Also:

setConnectState(ConnectState)

setConnectState

public boolean setConnectState(ConnectState state)

setReadyOperators

public void setReadyOperators(int operators)

setInterestOperators

public void setInterestOperators(int operators)

increaseRequestCount

public void increaseRequestCount()

自增请求数

increaseErrorCount

public void increaseErrorCount(int errorCode)

自增请求错误数

onConnect

public void onConnect()

连接成功后Reactor框架调用该方法

onConnectError

public void onConnectError(IOException exception)

onWrite

public void onWrite()

onRead

public void onRead()
            throws TCaplusException

Throws:

TCaplusException

onCloseMessage

public abstract void onCloseMessage(int messageSequence)

onRecvMessageBuffer

protected abstract void onRecvMessageBuffer(MessageBuffer msgBuf)

canSendMessage

protected abstract boolean canSendMessage()

putMessageToCache

protected abstract void putMessageToCache(Message msg)

update

public abstract int update()

connect

public void connect()
             throws TCaplusException

异步连接服务端

Throws:

TCaplusException

send

public boolean send(Message message)

Returns:

返回true表示发送成功，false表示发送失败，需要重新获取connector并重新发送

reset4Reconnect

public void reset4Reconnect()

close

public void close()

关闭连接

clearMessageCache

protected abstract void clearMessageCache()

toString

public String toString()

Overrides:

toString in class Object

toString4Tbl

public String toString4Tbl()