com.fr.third.jgroups.protocols.relay

类 Relayer

java.lang.Object

com.fr.third.jgroups.protocols.relay.Relayer

public class Relayer
extends java.lang.Object

Maintains bridges and routing table. Does the routing of outgoing messages and dispatches incoming messages to the right members.

A Relayer cannot be reused once it is stopped, but a new Relayer instance must be created.

从以下版本开始:

3.2

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	Relayer.Bridge
class	Relayer.Route Includes information about the site master of the route and the channel to be used

字段概要

字段

限定符和类型	字段和说明
protected java.util.Queue<Relayer.Bridge>	bridges The bridges which are used to connect to different sites
protected boolean	done Flag set when stop() is called.
protected Log	log
protected RELAY2	relay
protected java.util.concurrent.ConcurrentMap<java.lang.String,java.util.List<Relayer.Route>>	routes The routing table.
protected boolean	stats

构造器概要

构造器

构造器和说明
Relayer(RELAY2 relay, Log log)

方法概要

方法

限定符和类型	方法和说明
boolean	done()
protected View	getBridgeView(java.lang.String cluster_name)
protected Relayer.Route	getRoute(java.lang.String site) Grabs a random route
protected java.util.List<Relayer.Route>	getRoutes(java.lang.String... excluded_sites)
protected java.util.List<java.lang.String>	getSiteNames()
protected static boolean	isExcluded(Relayer.Route route, java.lang.String... excluded_sites)
java.lang.String	printRoutes()
void	start(java.util.List<RelayConfig.BridgeConfig> bridge_configs, java.lang.String bridge_name, java.lang.String my_site_id) Creates all bridges from site_config and connects them (joining the bridge clusters)
void	stop() Disconnects and destroys all bridges

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

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

字段详细资料

routes

protected java.util.concurrent.ConcurrentMap<java.lang.String,java.util.List<Relayer.Route>> routes

The routing table. Site IDs are the keys (e.g. "sfo", and list of routes are the values

bridges

protected final java.util.Queue<Relayer.Bridge> bridges

The bridges which are used to connect to different sites

log

protected final Log log

relay

protected final RELAY2 relay

done

protected volatile boolean done

Flag set when stop() is called. Since a Relayer should not be used after stop() has been called, a new instance needs to be created

stats

protected boolean stats

构造器详细资料

Relayer

public Relayer(RELAY2 relay,
       Log log)

方法详细资料

done

public boolean done()

start

public void start(java.util.List<RelayConfig.BridgeConfig> bridge_configs,
         java.lang.String bridge_name,
         java.lang.String my_site_id)
           throws java.lang.Throwable

Creates all bridges from site_config and connects them (joining the bridge clusters)

参数:

bridge_configs - A list of bridge configurations

bridge_name - The name of the local bridge channel, prefixed with '_'.

my_site_id - The ID of this site

抛出:

java.lang.Throwable

stop

public void stop()

Disconnects and destroys all bridges

printRoutes

public java.lang.String printRoutes()

getRoute

protected Relayer.Route getRoute(java.lang.String site)

Grabs a random route

参数:

site -

返回:

getSiteNames

protected java.util.List<java.lang.String> getSiteNames()

getRoutes

protected java.util.List<Relayer.Route> getRoutes(java.lang.String... excluded_sites)

getBridgeView

protected View getBridgeView(java.lang.String cluster_name)

isExcluded

protected static boolean isExcluded(Relayer.Route route,
                 java.lang.String... excluded_sites)