首页 > 代码库 > Spring整合xmemcached过程
Spring整合xmemcached过程
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 <dependency2 <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=50memcached.failureMode=true#servermemcached.server.host=127.0.0.1memcached.server.port=11211memcached.server.weight=14. 上面可以设置多台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配置变更为：
#server1memcached.server1.host=127.0.0.1memcached.server1.port=11211memcached.server1.weight=1#server2memcached.server2.host=127.0.0.1memcached.server2.port=11212memcached.server2.weight=25. 下面简单提供了一份单台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:5828 */29 30 @Controller31 @RequestMapping(value = "http://www.mamicode.com/demo")32 public class DemoController extends BaseController {33 34 @Autowired35 private MemcachedClient memcachedClient;36 37 @SuppressWarnings("unchecked")38 @ResponseBody39 @RequestMapping(value = "http://www.mamicode.com/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}
Spring整合xmemcached过程
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。