com.tencent.tcaplus.net.impl

Class DirRouter

java.lang.Object

com.tencent.tcaplus.net.Router

com.tencent.tcaplus.net.impl.DirRouter

public class DirRouter
extends Router

DirRouter接口实现类

Version:

version 1.0

Author:

yahuiwang

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DirRouter.EventListener

Constructor Summary

Constructors

Constructor and Description
DirRouter(Reactor reactor, ProtocolSupport protocolSupport, List<String> initializeAddresses, List<DirRouter.EventListener> eventListeners, RequestMetrics requestMetrics, AlarmCollector alarmCollector)

Method Summary

Modifier and Type	Method and Description
void	addChangedConnector(Connector connector)
void	connect(int timeout)
protected Connector	findConnector(long hash) 根据hash值，获得一个连接器
boolean	isNormal() 保留一个连接后判断连接是否正常
void	onConnect(Connector connector)
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

DirRouter

public DirRouter(Reactor reactor,
                 ProtocolSupport protocolSupport,
                 List<String> initializeAddresses,
                 List<DirRouter.EventListener> eventListeners,
                 RequestMetrics requestMetrics,
                 AlarmCollector alarmCollector)

Method Detail

connect

public void connect(int timeout)
             throws TCaplusException

Throws:

TCaplusException

isNormal

public boolean isNormal()

保留一个连接后判断连接是否正常

addChangedConnector

public void addChangedConnector(Connector connector)

Specified by:

addChangedConnector in class Router

findConnector

protected Connector findConnector(long hash)

Description copied from class: Router

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

Specified by:

findConnector in class Router

Parameters:

hash - hash值

Returns:

返回连接器

onConnect

public void onConnect(Connector connector)

Specified by:

onConnect in class Router

onMessage

public void onMessage(Message message)

Specified by:

onMessage in class Router

update

public int update()

Specified by:

update in class Router

Returns:

空闲返回0，忙返回正值

shutdown

public void shutdown()

Specified by:

shutdown in class Router

toString

public String toString()

Overrides:

toString in class Object