com.tencent.tcaplus.net

Class Router

java.lang.Object

com.tencent.tcaplus.net.Router

Direct Known Subclasses:

DirRouter, ProxyRouter

public abstract class Router
extends Object

定义Router对象接口, 该接口对象维护多个连接器状态，并通过调用update方法来驱动。

Version:

Version 1.0

Author:

yahuiwang

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Router(Reactor reactor, ProtocolSupport protocolSupport)

Method Summary

Modifier and Type	Method and Description
abstract void	addChangedConnector(Connector connector)
void	addRecvSize(int size)
void	addSendSize(int size)
protected abstract Connector	findConnector(long hash) 根据hash值，获得一个连接器
List<String>	getAddresses()
static int	getMessageCommand(Message message)
static short	getMessageMagic(Message message)
ProtocolSupport	getProtocolSupport()
Reactor	getReactor()
long	getRecvBytes()
long	getSendBytes()
protected boolean	isAddressesChanged(List<String> newAddressList)
abstract void	onConnect(Connector connector)
abstract void	onMessage(Message message)
int	sendMsg(Message msg)
protected void	setAddresses(List<String> addresses)
abstract void	shutdown()
abstract int	update()

Methods inherited from class java.lang.Object

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

Constructor Detail

Router

protected Router(Reactor reactor,
                 ProtocolSupport protocolSupport)

Method Detail

getMessageMagic

public static short getMessageMagic(Message message)

getMessageCommand

public static int getMessageCommand(Message message)

getReactor

public Reactor getReactor()

getProtocolSupport

public ProtocolSupport getProtocolSupport()

getAddresses

public List<String> getAddresses()

getSendBytes

public long getSendBytes()

getRecvBytes

public long getRecvBytes()

isAddressesChanged

protected boolean isAddressesChanged(List<String> newAddressList)

setAddresses

protected void setAddresses(List<String> addresses)

onConnect

public abstract void onConnect(Connector connector)

onMessage

public abstract void onMessage(Message message)

addSendSize

public void addSendSize(int size)

addRecvSize

public void addRecvSize(int size)

addChangedConnector

public abstract void addChangedConnector(Connector connector)

sendMsg

public int sendMsg(Message msg)
            throws TCaplusException

Throws:

TCaplusException

update

public abstract int update()

Returns:

空闲返回0，忙返回正值

shutdown

public abstract void shutdown()

findConnector

protected abstract Connector findConnector(long hash)

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

Parameters:

hash - hash值

Returns:

返回连接器