Spring集成XMemcached

admin

一、Memcached Client简要介绍
Memcached Client目前有3种：
Memcached Client for java
SpyMemcached
XMemcached


这三种Client一直存在各种争议：
Memcached Client for Java 比 SpyMemcached更稳定、更早、更广泛；
SpyMemcached 比 Memcached Client for Java更高效；
XMemcached 比 SpyMemcache并发效果更好。


用数据来说话，参考官方性能对比：
Memcached Client for Java：https://github.com/gwhalin/Memcached-Java-Client/wiki/PERFORMANCE
XMemcached：http://xmemcached.googlecode.com ... mark/benchmark.html


二、XMemcached特性
XMemcached特性：
高性能
支持完整的memcached文本协议,二进制协议。
支持JMX，可以通过MBean调整性能参数、动态添加/移除server、查看统计等。
支持客户端统计
支持memcached节点的动态增减。
支持memcached分布:余数分布和一致性哈希分布。
更多的性能调整选项。
四、XMemcached与spring集成
memcached.properties做基本配置：

1. #连接池大小即客户端个数  
   
2. memcached.connectionPoolSize= 50  
   
3. #server1  
   
4. memcached.server1.host= 127.0.0.1
   
5. memcached.server1.port= 12000  
   
6. memcached.server1.weight= 4  

复制代码

XML配置文件：

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <beans xmlns="http://www.springframework.org/schema/beans"
   
3. xmlns:mvc="http://www.springframework.org/schema/mvc"
   
4.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   
5.         xmlns:context="http://www.springframework.org/schema/context"
   
6.         xmlns:aop="http://www.springframework.org/schema/aop"
   
7.         xmlns:tx="http://www.springframework.org/schema/tx"
   
8.         xmlns:p="http://www.springframework.org/schema/p"
   
9.         xmlns:cache="http://www.springframework.org/schema/cache"
   
10.         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    
11.                 http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd
    
12.             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
    
13.             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
    
14.             http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.1.xsd
    
15.             http://www.springframework.org/schema/context http://www.springframework.org/s ... ing-context-3.0.xsd">
    
16.     <!-- 加载资源文件  其中包含变量信息，必须在Spring配置文件的最前面加载，即第一个加载-->
    
17.     <context:property-placeholder location="classpath:memcache.properties" />
    
18.     <bean  
    
19.          id= "memcachedClientBuilder"  
    
20.          class= "net.rubyeye.xmemcached.XMemcachedClientBuilder"
    
21.          p:connectionPoolSize = "${memcached.connectionPoolSize}">  
    
22.          <constructor-arg >  
    
23.              <list>  
    
24.                  <bean  class= "java.net.InetSocketAddress" >  
    
25.                      <constructor-arg >  
    
26.                          <value>${memcached.server1.host}</value >  
    
27.                      </constructor-arg >  
    
28.                      <constructor-arg >  
    
29.                          <value>${memcached.server1.port}</value >  
    
30.                      </constructor-arg >  
    
31.                  </bean>  
    
32.              </list >  
    
33.          </constructor-arg >  
    
34.          <constructor-arg >  
    
35.              <list >  
    
36.                  <value>${memcached.server1.weight} </value >  
    
37.              </list >  
    
38.          </constructor-arg >  
    
39.          <property  name= "commandFactory" >  
    
40.              <bean  class= "net.rubyeye.xmemcached.command.TextCommandFactory"  />  
    
41.          </property >  
    
42.          <property  name= "sessionLocator" >  
    
43.              <bean  class= "net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator"  />  
    
44.          </property >  
    
45.          <property  name= "transcoder" >  
    
46.              <bean  class= "net.rubyeye.xmemcached.transcoders.SerializingTranscoder"  />  
    
47.          </property >  
    
48.      </bean >  
    
49.      <bean  
    
50.          id= "memcachedClient"  
    
51.          factory-bean= "memcachedClientBuilder"  
    
52.          factory-method= "build"  
    
53.          destroy-method= "shutdown"  />
    
54. </beans>

复制代码

MemcachedSpringTest：

1. package com.itstyle.cache;
   
2. 
   
3. import static org.junit.Assert.*;
   
4. 
   
5. import java.util.concurrent.TimeoutException;
   
6. 
   
7. import net.rubyeye.xmemcached.MemcachedClient;
   
8. import net.rubyeye.xmemcached.exception.MemcachedException;
   
9. 
   
10. import org.junit.Before;
    
11. import org.junit.Test;
    
12. import org.springframework.context.ApplicationContext;
    
13. import org.springframework.context.support.ClassPathXmlApplicationContext;
    
14. 
    
15. public class MemcachedSpringTest {
    
16.         private ApplicationContext app;  
    
17.     private MemcachedClient memcachedClient;  
    
18. 
    
19.         @Before
    
20.         public void init() {
    
21.                 app = new ClassPathXmlApplicationContext("spring-mvc.xml");
    
22.                 memcachedClient = (MemcachedClient) app.getBean("memcachedClient");
    
23.         }
    
24.         @Test
    
25.         public void test() {
    
26.                 try {
    
27.                         // 设置/获取
    
28.                         memcachedClient.set("zlex", 36000, "set/get");
    
29.                         assertEquals("set/get", memcachedClient.get("zlex"));
    
30.                         // 替换
    
31.                         memcachedClient.replace("zlex", 36000, "replace");
    
32.                         assertEquals("replace", memcachedClient.get("zlex"));
    
33.                         // 移除
    
34.                         System.out.println(memcachedClient.get("zlex"));
    
35.                         memcachedClient.delete("zlex");
    
36.                         assertNull(memcachedClient.get("zlex"));
    
37.                 } catch (TimeoutException e) {
    
38.                         e.printStackTrace();
    
39.                 } catch (InterruptedException e) {
    
40.                         e.printStackTrace();
    
41.                 } catch (MemcachedException e) {
    
42.                         e.printStackTrace();
    
43.                 }
    
44.         }
    
45. }
    

复制代码

项目所需JAR包

项目结构：