程序包 org.apache.dubbo.rpc.cluster.router.tag

类 TagDynamicStateRouter

java.lang.Object

org.apache.dubbo.rpc.cluster.router.state.AbstractStateRouter

org.apache.dubbo.rpc.cluster.router.tag.TagDynamicStateRouter

所有已实现的接口:

Comparable<StateRouter>, EventListener, ConfigurationListener, StateRouter

public class TagDynamicStateRouter
extends AbstractStateRouter
implements ConfigurationListener

TagDynamicStateRouter, "application.tag-router"

字段概要

字段

修饰符和类型	字段	说明
static String	NAME

从接口继承的字段 org.apache.dubbo.rpc.cluster.router.state.StateRouter

DEFAULT_PRIORITY

构造器概要

构造器

构造器	说明
TagDynamicStateRouter(URL url, RouterChain chain)

方法概要

修饰符和类型	方法	说明
String	getName()
URL	getUrl()	Get the router url.
boolean	isEnable()
boolean	isForce()
boolean	isRuntime()	To decide whether this router need to execute every time an RPC comes or should only execute when addresses or rule change.
<T> void	notify(List<Invoker<T>> invokers)
<T> RouterCache<T>	pool(List<Invoker<T>> invokers)
void	process(ConfigChangedEvent event)	Listener call back method.
<T> BitList<Invoker<T>>	route(BitList<Invoker<T>> invokers, RouterCache<T> cache, URL url, Invocation invocation)	Filter invokers with current routing rule and only return the invokers that comply with the rule.
void	setApplication(String app)
boolean	shouldRePool()

从类继承的方法 org.apache.dubbo.rpc.cluster.router.state.AbstractStateRouter

getPriority, pool, setForce, setPriority, setUrl, tagMatchFail

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.dubbo.rpc.cluster.router.state.StateRouter

compareTo, stop

字段详细资料

NAME

public static final String NAME

另请参阅:

常量字段值

构造器详细资料

TagDynamicStateRouter

public TagDynamicStateRouter(URL url,
                             RouterChain chain)

方法详细资料

process

public void process(ConfigChangedEvent event)

从接口复制的说明: ConfigurationListener

Listener call back method. Listener gets notified by this method once there's any change happens on the config the listener listens on.

指定者:

process 在接口中 ConfigurationListener

参数:

event - config change event

getUrl

public URL getUrl()

从接口复制的说明: StateRouter

Get the router url.

指定者:

getUrl 在接口中 StateRouter

覆盖:

getUrl 在类中 AbstractStateRouter

返回:

url

route

public <T> BitList<Invoker<T>> route(BitList<Invoker<T>> invokers,
                                     RouterCache<T> cache,
                                     URL url,
                                     Invocation invocation)
                              throws RpcException

从接口复制的说明: StateRouter

Filter invokers with current routing rule and only return the invokers that comply with the rule. Caching address lists in BitMap mode improves routing performance.

指定者:

route 在接口中 StateRouter

覆盖:

route 在类中 AbstractStateRouter

参数:

invokers - invoker bit list

cache - router address cache

url - refer url

invocation - invocation

返回:

routed invokers

抛出:

RpcException

isRuntime

public boolean isRuntime()

从接口复制的说明: StateRouter

To decide whether this router need to execute every time an RPC comes or should only execute when addresses or rule change.

指定者:

isRuntime 在接口中 StateRouter

覆盖:

isRuntime 在类中 AbstractStateRouter

返回:

true if the router need to execute every time.

isEnable

public boolean isEnable()

指定者:

isEnable 在接口中 StateRouter

isForce

public boolean isForce()

指定者:

isForce 在接口中 StateRouter

覆盖:

isForce 在类中 AbstractStateRouter

getName

public String getName()

指定者:

getName 在接口中 StateRouter

shouldRePool

public boolean shouldRePool()

指定者:

shouldRePool 在接口中 StateRouter

pool

public <T> RouterCache<T> pool(List<Invoker<T>> invokers)

指定者:

pool 在接口中 StateRouter

setApplication

public void setApplication(String app)

notify

public <T> void notify(List<Invoker<T>> invokers)

指定者:

notify 在接口中 StateRouter

覆盖:

notify 在类中 AbstractStateRouter