问题描述:oscache集群环境下,如果网络发生故障,会导致集群变成多个小的子群甚至单节点,这期间如果其中一节点做了更新缓存的操作,当网络恢复后,集群中的cache状态会不一致,导致用户看到不同的view。
解决思路:获取网络恢复后子群合并时产生的通知,并进行更新。最简单有效的就是清空所有节点的缓存。
jar版本:oscache2.4.1 jgroups2.12.1
oscache在集群环境下的配置需要打开cache.event.listeners属性,里面包含JavaGroupsBroadcastingListener。
JavaGroupsBroadcastingListener使用了JGroups的NotificationBus进行通信,而NotificationBus实现了receiver接口,其中的ViewAccept就是在view变化时被调用的。
我们需要做的是重写JavaGroupsBroadcastingListener的初始化方法。
重写NotificationBus的viewAccept方法。
修改oscache.properties里面的cache.event.listeners.
红色是添加或修改的,上代码:
MySelfJavaGroupsBroadcastingListener类:
public synchronized void initialize(Cache cache, Config config) throws InitializationException {
super.initialize(cache, config);
String properties = config.getProperty(CHANNEL_PROPERTIES);
String multicastIP = config.getProperty(MULTICAST_IP_PROPERTY);
if ((properties == null) && (multicastIP == null)) {
multicastIP = DEFAULT_MULTICAST_IP;
}
if (properties == null) {
properties = DEFAULT_CHANNEL_PROPERTIES_PRE + multicastIP.trim() + DEFAULT_CHANNEL_PROPERTIES_POST;
} else {
properties = properties.trim();
}
if (log.isInfoEnabled()) {
log.info("Starting a new JavaGroups broadcasting listener with properties=" + properties);
}
try {
bus = new MySelfNotificationBus(BUS_NAME, properties); bus.start();
bus.getChannel().setOpt(Channel.LOCAL, new Boolean(false));
bus.setConsumer(this);
log.info("JavaGroups clustering support started successfully");
} catch (Exception e) {
throw new InitializationException("Initialization failed: " + e);
}
}
MySelfNotificationBus类:
public class MySelfNotificationBus extends NotificationBus {
public MySelfNotificationBus (String bus_name, String properties) throws Exception {
super(bus_name,properties);
}
public synchronized void viewAccepted(View new_view) {
super.viewAccepted(new_view);
final NotificationBus bus = this;
if(new_view instanceof MergeView){
new Thread() {
public void run() {
bus.notifyConsumer(new ClusterNotification(ClusterNotification.FLUSH_CACHE,new Date()));
}
}.start();
}
}
oscache.properties:
cache.event.listeners=
x.x.x.MySelfJavaGroupsBroadcastingListener, \
com.opensymphony.oscache.extra.CacheEntryEventListenerImpl, \
com.opensymphony.oscache.extra.CacheMapAccessEventListenerImpl, \
com.opensymphony.oscache.extra.ScopeEventListenerImpl
分享到:
相关推荐
oscache,java,缓存机制的使用
OSCache是一个广泛采用的高性能的J2EE缓存框架,OSCache能用于任何Java应用程序的普通的缓存解决方案。 OSCache有以下特点:缓存任何对象,你可以不受限制的缓存部分jsp页面或HTTP请求,任何java对象都可以缓存。...
oscache-java缓存框架插件和安装教程,使用教程一步到位
NULL 博文链接:https://zhenghuazhi.iteye.com/blog/1135620
OSCache是个一个广泛采用的高性能的J2EE缓存框架,OSCache能用于任何Java应用程序的普通的缓存解决方案。OSCache有以下特点:缓存任何对象,你可以不受限制的缓存部分jsp页面或HTTP请求,任何java对象都可以缓存。 ...
oscache缓存技术,压缩包中有详细代码及步骤
Hibernate OSCache缓存 Hibernate OSCache缓存
二级缓存插件OScache配置,很好的学习资料
1、OSCache是什么? 2、OSCache的特点 3、有关“用OSCache进行缓存对象”的研究
oscache缓存技术入门实例
OSCache是个一个被广泛采用的高性能的J2EE缓存框架,OSCache还能应用于任何Java应用程序的普通的缓存解决方案。 OSCache的特点 (1) 缓存任何对象:你可以不受限制的缓存部分jsp页面或HTTP请求,任何java对象都可以...
这里结合 天气预报的webservice 展示了OsCache框架的具体使用方法 项目可直接运行 ,代码简洁清晰
非常实用的一个例子,有关于缓存对象 list 或缓存地址或jsp或其它页面,在实例中都有,须望可以帮到大家
NULL 博文链接:https://davidxiaozhi.iteye.com/blog/1045223
OSCache标记库由OpenSymphony设计,它是一种开创性的缓存方案,它提供了在现有JSP页面之内实现内存缓存...OSCache是个一个被广泛采用的高性能的J2EE缓存框架,OSCache还能应用于任何Java应用程序的普通的缓存解决方案。
OSCACHE网页缓存.ppt ,页面cache
看就知道......................
Cache是一种用于提高系统响应速度、改善系统运行性能的技术。尤其是在Web应用中,通过缓存页面的输出...OSCache是个一个被广泛采用的高性能的J2EE缓存框架,OSCache还能应用于任何Java应用程序的普通的缓存解决方案。
oscache缓存使用总结
缓存技术 oscache-2.3.2.jar包下载