当前位置:编程学习 > JAVA >>

memcached总结和与spring的集成


         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] 
<!-- xMemcached集群配置 --> 
<bean id="cacheManager" class="com.cr.common.cache.base.CacheManager"> 
    <property name="clnt" ref="xMemcachedClient" /> 
    <property name="expire" value="3600" /> 
</bean> 
<bean name="memcachedClientBuilder" class="net.rubyeye.xmemcached.XMemcachedClientBuilder"> 
    <constructor-arg> 
        <list> 
 
            <bean class="java.net.InetSocketAddress"> 
                <constructor-arg> 
                    <value>192.168.0.110</value> 
                </constructor-arg> 
                <constructor-arg> 
                    <value>11211</value> 
                </constructor-arg> 
            </bean> 
            <bean class="java.net.InetSocketAddress"> 
                <constructor-arg> 
                    <value>192.168.0.111</value> 
                </constructor-arg> 
                <constructor-arg> 
                    <value>11211</value> 
                </constructor-arg> 
            </bean> 
             
        </list> 
    </constructor-arg> 
    <constructor-arg> 
        <list> 
            <value>1</value> 
            <value>1</value> 
        </list> 
    </constructor-arg> 
    <property name="connectionPoolSize" value="30"></property> 
    <property name="commandFactory"> 
        <bean class="net.rubyeye.xmemcached.command.TextCommandFactory"></bean> 
    </property> 
    <property name="sessionLocator"> 
        <bean class="net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator"> 
            <constructor-arg index="0"> 
                <value>true</value> 
            </constructor-arg> 
        </bean> 
    </property> 
    <property name="transcoder"> 
        <bean class="net.rubyeye.xmemcached.transcoders.SerializingTranscoder"></bean> 
    </property> 
</bean> 
<bean name="xMemcachedClient" factory-bean="memcachedClientBuilder" 
    factory-method="build" destroy-method="shutdown"> 
    <property name="opTimeout" value="5000"></property> 
</bean> 

 
        memcachedClientBuilder完成MemcachedClientBuilder,在constructor-arg里面配置集群的节点。然后通过memcachedClient节点配置用于连接的client。
cacheManger是memcached的管理类,持有xMemcachedClient的实例,提供get,set操作,当然是通过bean注入的。
主要代码如下:
 
[java]
public <T> T getCache(String key) {        
        try {    
          &nb

补充:软件开发 , Java ,
CopyRight © 2012 站长网 编程知识问答 www.zzzyk.com All Rights Reserved
部份技术文章来自网络,