com.fr.ehcache.cluster.peer

类 JGroupsCacheManagerPeerProvider

java.lang.Object

com.fr.ehcache.cluster.peer.JGroupsCacheManagerPeerProvider

所有已实现的接口:

com.fr.third.net.sf.ehcache.distribution.CacheManagerPeerProvider, com.fr.third.net.sf.ehcache.management.ManagedCacheManagerPeerProvider

public class JGroupsCacheManagerPeerProvider
extends java.lang.Object
implements com.fr.third.net.sf.ehcache.management.ManagedCacheManagerPeerProvider

启动一个jgroups JChannel，接受其它节点的组网请求

The main Jgroup class for replication via JGroup. Starts up the Jgroup communication bus and listen for message in the bus. Because of Ehcache design we have to register this as a CachePeer. In reality this class listen for change on the bus and tells the cachemanager to update.

版本:

$Id: JGroupsCacheManagerPeerProvider.java 2608 2010-08-05 06:06:01Z gluck $

作者:

Pierre Monestie (pmonestie__REMOVE__THIS__@gmail.com), Greg Luck

字段概要

字段

限定符和类型	字段和说明
static java.lang.String	SCHEME_NAME Constant that defines the value returned by getScheme()

构造器概要

构造器

构造器和说明
JGroupsCacheManagerPeerProvider(com.fr.third.net.sf.ehcache.CacheManager cacheManager, ProtocolStackType stackType) 定制的构造方法，接受CacheManager和ProtocolStackType
JGroupsCacheManagerPeerProvider(com.fr.third.net.sf.ehcache.CacheManager cacheManager, java.lang.String properties) Construct a new JGroupsCacheManagerPeerProvider with a specific JGroups connection String
JGroupsCacheManagerPeerProvider(com.fr.third.net.sf.ehcache.CacheManager cacheManager, java.net.URL configUrl) Construct a new JGroupsCacheManagerPeerProvider with a specific JGroups connection String

方法概要

方法

限定符和类型	方法和说明
void	dispose()
BootstrapManagerProvider	getBootstrapManager()
JGroupsCacheManagerEventHandler	getCacheManagerEventHandler()
JGroupsCachePeer	getCachePeer()
static JGroupsCacheManagerPeerProvider	getCachePeerProvider(com.fr.third.net.sf.ehcache.CacheManager cacheManager) Given an CacheManager get the corresponding instance of this class.
static JGroupsCacheManagerPeerProvider	getCachePeerProvider(com.fr.third.net.sf.ehcache.Ehcache cache) Given an Ehcache get the corresponding instance of this class.
java.lang.String	getClusterName()
java.lang.String	getScheme() The replication scheme.
com.fr.third.net.sf.ehcache.Status	getStatus()
long	getTimeForClusterToForm() JGroups will be connected once init() returns and there is no per-cache connect time to worry about.
void	init()
java.util.List<com.fr.third.net.sf.ehcache.distribution.CachePeer>	listRemoteCachePeers(com.fr.third.net.sf.ehcache.Ehcache cache)
void	register(javax.management.MBeanServer mBeanServer)
void	registerPeer(java.lang.String rmiUrl)
void	setChannelName(java.lang.String channelName) Set the name of the JChannel, if null the cache manager name is used.
void	unregisterPeer(java.lang.String rmiUrl)

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

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

字段详细资料

SCHEME_NAME

public static final java.lang.String SCHEME_NAME

Constant that defines the value returned by getScheme()

另请参阅:

常量字段值

构造器详细资料

JGroupsCacheManagerPeerProvider

public JGroupsCacheManagerPeerProvider(com.fr.third.net.sf.ehcache.CacheManager cacheManager,
                               java.lang.String properties)

Construct a new JGroupsCacheManagerPeerProvider with a specific JGroups connection String

参数:

cacheManager - the cache manager

properties - the JGroups connection String

JGroupsCacheManagerPeerProvider

public JGroupsCacheManagerPeerProvider(com.fr.third.net.sf.ehcache.CacheManager cacheManager,
                               java.net.URL configUrl)

Construct a new JGroupsCacheManagerPeerProvider with a specific JGroups connection String

参数:

cacheManager - the cache manager

configUrl - the JGroups configuration file

JGroupsCacheManagerPeerProvider

public JGroupsCacheManagerPeerProvider(com.fr.third.net.sf.ehcache.CacheManager cacheManager,
                               ProtocolStackType stackType)

定制的构造方法，接受CacheManager和ProtocolStackType

参数:

cacheManager -

stackType -

方法详细资料

setChannelName

public void setChannelName(java.lang.String channelName)

Set the name of the JChannel, if null the cache manager name is used.

getCachePeerProvider

public static JGroupsCacheManagerPeerProvider getCachePeerProvider(com.fr.third.net.sf.ehcache.Ehcache cache)

Given an Ehcache get the corresponding instance of this class.

getCachePeerProvider

public static JGroupsCacheManagerPeerProvider getCachePeerProvider(com.fr.third.net.sf.ehcache.CacheManager cacheManager)

Given an CacheManager get the corresponding instance of this class.

getCacheManagerEventHandler

public JGroupsCacheManagerEventHandler getCacheManagerEventHandler()

init

public void init()

指定者:

init 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheManagerPeerProvider

register

public void register(javax.management.MBeanServer mBeanServer)

指定者:

register 在接口中 com.fr.third.net.sf.ehcache.management.ManagedCacheManagerPeerProvider

dispose

public void dispose()
             throws com.fr.third.net.sf.ehcache.CacheException

指定者:

dispose 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheManagerPeerProvider

抛出:

com.fr.third.net.sf.ehcache.CacheException

getTimeForClusterToForm

public long getTimeForClusterToForm()

JGroups will be connected once init() returns and there is no per-cache connect time to worry about.

指定者:

getTimeForClusterToForm 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheManagerPeerProvider

getScheme

public java.lang.String getScheme()

The replication scheme. Each peer provider has a scheme name, which can be used to specify the scheme for replication and bootstrap purposes. Each CacheReplicator should lookup the provider for its scheme type during replication. Similarly a BootstrapCacheLoader should also look up the provider for its scheme.

指定者:

getScheme 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheManagerPeerProvider

返回:

the well-known scheme name, which is determined by the replication provider author.

从以下版本开始:

1.6 introduced to permit multiple distribution schemes to be used in the same CacheManager

listRemoteCachePeers

public java.util.List<com.fr.third.net.sf.ehcache.distribution.CachePeer> listRemoteCachePeers(com.fr.third.net.sf.ehcache.Ehcache cache)
                                                                                        throws com.fr.third.net.sf.ehcache.CacheException

指定者:

listRemoteCachePeers 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheManagerPeerProvider

抛出:

com.fr.third.net.sf.ehcache.CacheException

registerPeer

public void registerPeer(java.lang.String rmiUrl)

指定者:

registerPeer 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheManagerPeerProvider

unregisterPeer

public void unregisterPeer(java.lang.String rmiUrl)

指定者:

unregisterPeer 在接口中 com.fr.third.net.sf.ehcache.distribution.CacheManagerPeerProvider

getBootstrapManager

public BootstrapManagerProvider getBootstrapManager()

返回:

the JGroupsBootstrapManager

getStatus

public com.fr.third.net.sf.ehcache.Status getStatus()

返回:

the Status of the manager

getCachePeer

public JGroupsCachePeer getCachePeer()

getClusterName

public java.lang.String getClusterName()

返回:

The cluster name for JMX registration