spring整合memeched

XMemcached是一个基于Java nio的memcached客户端。

它是线程安全，结构简单，支持所有的memcached文本协议和二进制协议，并且有比较优异的性能表现。还支持一些高级特性，如JMX、动态增删节点、客户端统计以及nio连接池等。

整合开始前，先确认有一个或多个可用的Memcached服务，XMemcached支持集群及服务的权重配置。

文章参考：

1. http://code.google.com/p/xmemcached/

2. http://code.google.com/p/xmemcached/wiki/Spring_Integration

 

1. 项目使用maven管理，那么请在pom.xml里边添加Xmemcached的依赖包：

1 <dependency
2     <groupId>com.googlecode.xmemcached</groupId>
3     <artifactId>xmemcached</artifactId>
4     <version>1.4.1</version>
5 </dependency>

2. 添加bean配置，自动装载到容器

 1 <bean id="propertyHolder" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
 2         <property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" />
 3         <property name="ignoreResourceNotFound" value="true" />
 4         <property name="locations">
 5             <list>
 6                 <value>classpath:conf/system.properties</value>
 7                 <value>classpath:conf/jdbc.properties</value>
 8                 <value>classpath:conf/memcached.properties</value>
 9             </list>
10         </property>
11 </bean>
12 
13 <bean id="memcachedClientBuilder" class="net.rubyeye.xmemcached.XMemcachedClientBuilder">
14         <constructor-arg>
15             <list>
16                 <bean class="java.net.InetSocketAddress">
17                     <constructor-arg>
18                             <value>${memcached.server.host}</value>
19                     </constructor-arg>
20                     <constructor-arg>
21                             <value>${memcached.server.port}</value>
22                     </constructor-arg>
23                 </bean>
24             </list>
25         </constructor-arg>
26         <constructor-arg>
27             <list>
28                 <value>${memcached.server.weight}</value>
29             </list>
30         </constructor-arg>
31         <property name="connectionPoolSize" value="${memcached.connectionPoolSize}" />
32         <property name="commandFactory">
33                 <bean class="net.rubyeye.xmemcached.command.TextCommandFactory"></bean>
34         </property>
35         <property name="sessionLocator">
36                 <bean class="net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator"></bean>
37         </property>
38         <property name="transcoder">
39                 <bean class="net.rubyeye.xmemcached.transcoders.SerializingTranscoder" />
40         </property>
41 </bean>
42 <bean id="memcachedClient" factory-bean="memcachedClientBuilder" factory-method="build" destroy-method="shutdown" />

3. memcached.properties 配置内容：

memcached.connectionPoolSize=50
memcached.failureMode=true
#server
memcached.server.host=127.0.0.1
memcached.server.port=11211
memcached.server.weight=1

4. 上面可以设置多台memcached服务器，并指定weight权重。XMemcachedClientBuilder 有两个参数，第一个参数是server配置的list，第二个参数是每台服务器的权重。如：

 1 <bean id="memcachedClientBuilder" class="net.rubyeye.xmemcached.XMemcachedClientBuilder">
 2         <constructor-arg>
 3             <list>
 4                 <bean class="java.net.InetSocketAddress">
 5                     <constructor-arg>
 6                             <value>${memcached.server1.host}</value>
 7                     </constructor-arg>
 8                     <constructor-arg>
 9                             <value>${memcached.server1.port}</value>
10                     </constructor-arg>
11                 </bean>
12                 <bean class="java.net.InetSocketAddress">
13                     <constructor-arg>
14                             <value>${memcached.server2.host}</value>
15                     </constructor-arg>
16                     <constructor-arg>
17                             <value>${memcached.server2.port}</value>
18                     </constructor-arg>
19                 </bean>
20             </list>
21         </constructor-arg>
22         <constructor-arg>
23             <list>
24                 <value>${memcached.server1.weight}</value>
25                 <value>${memcached.server2.weight}</value>
26             </list>
27         </constructor-arg>
28         <property name="connectionPoolSize" value="${memcached.connectionPoolSize}" />
29         <property name="commandFactory">
30                 <bean class="net.rubyeye.xmemcached.command.TextCommandFactory"></bean>
31         </property>
32         <property name="sessionLocator">
33                 <bean class="net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator"></bean>
34         </property>
35         <property name="transcoder">
36                 <bean class="net.rubyeye.xmemcached.transcoders.SerializingTranscoder" />
37         </property>
38     </bean>

相应properties配置变更为：

#server1
memcached.server1.host=127.0.0.1
memcached.server1.port=11211
memcached.server1.weight=1
#server2
memcached.server2.host=127.0.0.1
memcached.server2.port=11212
memcached.server2.weight=2

5. 下面简单提供了一份单台memcached服务器的存取操作及获取memcached状态信息的代码实例：

 1 /*
 2  * Copyright 2013 Alibaba.com All right reserved. This software is the
 3  * confidential and proprietary information of Alibaba.com ("Confidential
 4  * Information"). You shall not disclose such Confidential Information and shall
 5  * use it only in accordance with the terms of the license agreement you entered
 6  * into with Alibaba.com.
 7  */
 8 package com.yunos.tv.server.controller.web;
 9 
10 import java.net.InetSocketAddress;
11 import java.util.Iterator;
12 import java.util.Map;
13 import java.util.Map.Entry;
14 import java.util.concurrent.TimeoutException;
15 
16 import net.rubyeye.xmemcached.MemcachedClient;
17 import net.rubyeye.xmemcached.exception.MemcachedException;
18 
19 import org.springframework.beans.factory.annotation.Autowired;
20 import org.springframework.stereotype.Controller;
21 import org.springframework.web.bind.annotation.RequestMapping;
22 import org.springframework.web.bind.annotation.RequestMethod;
23 import org.springframework.web.bind.annotation.ResponseBody;
24 
25 /**
26  * 类DemoController.java的实现描述：TODO 类实现描述
27  * @author riqi 2013-6-28 上午10:48:58
28  */
29 
30 @Controller
31 @RequestMapping(value = "/demo")
32 public class DemoController extends BaseController {
33 
34     @Autowired
35     private MemcachedClient memcachedClient;
36 
37     @SuppressWarnings("unchecked")
38     @ResponseBody
39     @RequestMapping(value = "/hello", method = RequestMethod.GET)
40     public String helloWorld() {
41         try {
42             memcachedClient.set("string", 3600, "Hello World!");
43             Map<InetSocketAddress, Map<String, String>> memcachedStats = memcachedClient.getStats();
44 
45             String helloWord = memcachedClient.get("string");
46             StringBuilder strBuilder = new StringBuilder(helloWord);
47             strBuilder.append("\n");
48 
49             for (Iterator<?> statsIterator = memcachedStats.entrySet().iterator(); statsIterator.hasNext();) {
50                 Map.Entry<InetSocketAddress, Map<String, String>> entry = (Entry<InetSocketAddress, Map<String, String>>) statsIterator.next();
51 
52                 strBuilder.append(entry.getKey() + ":" + entry.getValue());
53                 strBuilder.append("\n");
54             }
55 
56             return strBuilder.toString();
57 
58         } catch (TimeoutException e) {
59             e.printStackTrace();
60         } catch (InterruptedException e) {
61             e.printStackTrace();
62         } catch (MemcachedException e) {
63             e.printStackTrace();
64         }
65 
66         return "";
67     }
68 }

浏览器输入：http://localhost:8080/demo/hello.htm

输出内容：

Hello World! 
/127.0.0.1:11211:{delete_hits=0, bytes=68, total_items=62, listen_disabled_num=0, auth_errors=0, evictions=0, version=1.4.4-14-g9c660c0, pointer_size=32, time=1373528740, incr_hits=0, threads=4, limit_maxbytes=67108864, bytes_read=169146, curr_connections=109, get_misses=0, bytes_written=2559445, connection_structures=110, cas_hits=0, delete_misses=0, total_connections=310, cmd_flush=0, uptime=1426, pid=6312, cas_badval=0, get_hits=61, curr_items=1, cas_misses=0, accepting_conns=1, cmd_get=61, cmd_set=62, incr_misses=0, auth_cmds=0, decr_misses=0, decr_hits=0, conn_yields=0}