memcached总结和与spring的集成(一)

2014-11-24 10:24:10 · 作者: · 浏览: 2


Memcached是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻硬盘数据库的负载,基于一个存储键/值对的hashmap,守护进程用c写的,客户端可用各种语言实现。
特点有以下几个:
1.暂无认证以及安全管制,也没有冗余备份机制,考虑到时内存数据库,也就无所谓了。
2.Value大小 1.4.2以后可以到128M。
3.节点之间不互相通信。
4.c/s通信使用基于文本行的格式。
5.使用LRU算法管理内存。
6.客户端可以实现一致性哈希算法来决定数据在服务器节点的分布。
7.Lazy Expiration,不主动检查数据的过期。
原理图:



Perl:
整数哈希值根据余数计算分散
缺点:添加服务器后,余数就会产生巨变,这样就无法获取与保存时相同的服务器,从而影响缓存的命中率。

Php实现了Consistent Hashing:


首先求出memcached服务器(节点)的哈希值, 并将其配置到0~232的圆(continuum)上。add数据时,用同样的方法求出存储数据的键的哈希值,并映射到圆上。从数据映射到的位置开始顺时针查找,将数据保存到找到的第一个服务器上。 如果超过232仍然找不到服务器,就会保存到第一台memcached服务器上。

上图可以看出增加服务器后受影响的只有部分区域,因为本来是属于node4的hash范围,加入机器后变为node5的范围。

memcached的监视工具可以用nagios,MemcachePHP
下面说明java客户端的用法,以跟spring集成为例:

memcached的java客户端选用xmemcached,相关的包要下载下来。
一、客户端的bean配置:
[html]











192.168.0.110


11211




192.168.0.111


11211







1
1









true







factory-method="build" destroy-method="shutdown">


memcachedClientBuilder完成MemcachedClientBuilder,在constructor-arg里面配置集群的节点。然后通过memcachedClient节点配置用于连接的client。
cacheManger是memcached的管理类,持有xMemcachedClient的实例,提供get,set操作,当然是通过bean注入的。
主要代码如下:

[java]
public T getCache(String key) {
try {
log.info("get " + key);
return (T)(client.get(key));
} catch (TimeoutException e) {
log.error(e.getMessage(), e);
} catch (InterruptedException e) {
log.error(e.getMessage(), e);
} catch (MemcachedException e) {
log.error(e.getMessage(), e);
}
return null;
}

public boolean setCache(String key, T value) {
try {
log.info("add cache:"+key);
return client.set(key, expire, value);
} catch (TimeoutException e) {
log.error(e.getMessage(), e);
} catch (InterruptedException e) {
log.error(e.getMessage(), e);
} catch (MemcachedException e) {
log.error(e.getMessage(), e);
}
return false;
}

二、spring的AOP切面配置:
[html]

value="/WEB-INF/spring/SystemContext.properties" />




class="com.cr.common.log.LogAspect">



class="com.cr.common.cache.core.CacheAspect">








BeanFactory 类定义了通过名称获得Spring容器内的Bean实例:
[java]
public class BeanFactory implements ServletContextAware{
private static ServletContext servletContext;
public static T getBean(String beanName) {
WebApplicationContext wac = WebApplicationContextUtils.getRequiredWebApplicationContext(servletContext);
return wac.getBean(beanName);
}

@Override
public void se