net.oschina.j2cache.cluster

Class JGroupsClusterPolicy

java.lang.Object

org.jgroups.ReceiverAdapter

net.oschina.j2cache.cluster.JGroupsClusterPolicy

All Implemented Interfaces:

ClusterPolicy, org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver

public class JGroupsClusterPolicy
extends org.jgroups.ReceiverAdapter
implements ClusterPolicy

使用 JGroups 组播进行集群内节点通讯

Author:

Winter Lau(javayou@gmail.com)

Constructor Summary

Constructors

Constructor and Description
JGroupsClusterPolicy(String name, Properties props) 构造函数

Method Summary

Modifier and Type	Method and Description
void	clear(String region) 清除本地整个缓存区域
void	connect(Properties props, CacheProviderHolder holder) 连接到集群
void	disconnect() 断开集群连接
void	evict(String region, String... keys) 删除本地某个缓存条目
boolean	isLocalCommand(Command cmd) 判断是否本地实例的命令
void	publish(Command cmd) 发送消息
void	receive(org.jgroups.Message msg)
void	viewAccepted(org.jgroups.View view)

Methods inherited from class org.jgroups.ReceiverAdapter

block, getState, setState, suspect, unblock

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.oschina.j2cache.cluster.ClusterPolicy

handleCommand, sendClearCmd, sendEvictCmd

Constructor Detail

JGroupsClusterPolicy

public JGroupsClusterPolicy(String name,
                            Properties props)

构造函数

Parameters:

name - 组播频道名称

props - 配置文件路径

Method Detail

isLocalCommand

public boolean isLocalCommand(Command cmd)

Description copied from interface: ClusterPolicy

判断是否本地实例的命令

Specified by:

isLocalCommand in interface ClusterPolicy

Parameters:

cmd - 命令信息

Returns:

evict

public void evict(String region,
                  String... keys)

删除本地某个缓存条目

Specified by:

evict in interface ClusterPolicy

Parameters:

region - 区域名称

keys - 缓存键值

clear

public void clear(String region)

清除本地整个缓存区域

Specified by:

clear in interface ClusterPolicy

Parameters:

region - 区域名称

connect

public void connect(Properties props,
                    CacheProviderHolder holder)

Description copied from interface: ClusterPolicy

连接到集群

Specified by:

connect in interface ClusterPolicy

Parameters:

props - j2cache 配置信息

holder - Cache Provider Instance

disconnect

public void disconnect()

Description copied from interface: ClusterPolicy

断开集群连接

Specified by:

disconnect in interface ClusterPolicy

receive

public void receive(org.jgroups.Message msg)

Specified by:

receive in interface org.jgroups.MessageListener

Overrides:

receive in class org.jgroups.ReceiverAdapter

viewAccepted

public void viewAccepted(org.jgroups.View view)

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

Overrides:

viewAccepted in class org.jgroups.ReceiverAdapter

publish

public void publish(Command cmd)

Description copied from interface: ClusterPolicy

发送消息

Specified by:

publish in interface ClusterPolicy

Parameters:

cmd - command to send