public class JGroupEventMessage
extends com.fr.third.net.sf.ehcache.distribution.LegacyEventMessage
消息类型
限定符和类型 | 字段和说明 |
---|---|
static int |
BOOTSTRAP_COMPLETE
启动引导同步完成
|
static int |
BOOTSTRAP_INCOMPLETE
启动引导同步未完成
|
static int |
BOOTSTRAP_REQUEST
启动引导资源同步请求
|
static int |
BOOTSTRAP_RESPONSE
资源同步响应(发送已经存在的Cache)
|
static int |
CACHE_ADDED
新增缓存
|
static int |
CACHE_REMOVED
删除缓存
|
static int |
MANAGER_BOOTSTRAP_REQUEST
CacheManager启动引导请求,获取已有节点上的缓存列表
|
static int |
MANAGER_BOOTSTRAP_RESPONSE
CacheManager启动引导返回
|
static java.lang.String |
MD5_CHECK_MAP
MD5校验标识
MD5校验的具体方式:
1、新节点读取下层资源仓库所有资源的MD5值,存在Map<(资源path), (MD5值)>;
2、在启动引导时,作为BOOTSTRAP_REQUEST的element消息发送到其它节点;
3、指定的引导响应节点会和本地的资源MD5进行对比,并以本节点为基准,找出MD5不一致的资源;
4、这些MD5不一致的资源,如果本节点Cache中存在,则直接发送BOOTSTRAP_RESPONSE类型消息到新节点;
5、若不存在,按正常的缓存方式进行,本节点缓存之后会通知其它包括新节点的所有节点;
|
构造器和说明 |
---|
JGroupEventMessage(int event,
java.io.Serializable key,
com.fr.third.net.sf.ehcache.Element element,
java.lang.String cacheName) |
JGroupEventMessage(int event,
java.io.Serializable key,
com.fr.third.net.sf.ehcache.Element element,
java.lang.String cacheName,
long asyncTime)
An event message for the JGroupsCacheReplicator.
|
限定符和类型 | 方法和说明 |
---|---|
long |
getAsyncTime() |
java.lang.String |
getCacheName()
Returns the cache name
|
static java.lang.String |
getEventName(int event)
Convert a numeric event ID to a String name.
|
boolean |
isAsync() |
java.lang.String |
toString() |
public static final java.lang.String MD5_CHECK_MAP
MD5校验的具体方式: 1、新节点读取下层资源仓库所有资源的MD5值,存在Map<(资源path), (MD5值)>; 2、在启动引导时,作为BOOTSTRAP_REQUEST的element消息发送到其它节点; 3、指定的引导响应节点会和本地的资源MD5进行对比,并以本节点为基准,找出MD5不一致的资源; 4、这些MD5不一致的资源,如果本节点Cache中存在,则直接发送BOOTSTRAP_RESPONSE类型消息到新节点; 5、若不存在,按正常的缓存方式进行,本节点缓存之后会通知其它包括新节点的所有节点;
public static final int BOOTSTRAP_REQUEST
public static final int BOOTSTRAP_RESPONSE
public static final int BOOTSTRAP_COMPLETE
public static final int BOOTSTRAP_INCOMPLETE
public static final int CACHE_ADDED
public static final int CACHE_REMOVED
public static final int MANAGER_BOOTSTRAP_REQUEST
public static final int MANAGER_BOOTSTRAP_RESPONSE
public JGroupEventMessage(int event, java.io.Serializable key, com.fr.third.net.sf.ehcache.Element element, java.lang.String cacheName)
public JGroupEventMessage(int event, java.io.Serializable key, com.fr.third.net.sf.ehcache.Element element, java.lang.String cacheName, long asyncTime)
event
- (PUT,REMOVE,REMOVE_ALL)key
- the serializable key of the cache elementelement
- The element itself. In case of a put.cacheName
- the name of the cacheasyncTime
- the asynchronous replication period for this message, -1 results in synchronous replicationpublic boolean isAsync()
public long getAsyncTime()
public java.lang.String getCacheName()
public java.lang.String toString()
toString
在类中 java.lang.Object
public static java.lang.String getEventName(int event)