<dependency><groupId>com.whalin</groupId><artifactId>Memcached-Java-Client</artifactId><version>3.0.2</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-simple</artifactId><version>1.6.2</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.6.2</version></dependency><dependency><groupId>commons-pool</groupId><artifactId>commons-pool</artifactId><version>1.5.6</version></dependency>

<bean id="memcachedPool" class="com.whalin.MemCached.SockIOPool" factory-method="getInstance" init-method="initialize" lazy-init="false" destroy-method="shutDown"><constructor-arg><value>memcachedPool</value></constructor-arg><!-- 可以设置多个memcached服务器 --><property name="servers"><list><value>${memcache_ip}</value></list></property><!-- 每个服务器初始连接数 --><property name="initConn"><value>10</value></property><!-- 每个服务器最小连接数 --><property name="minConn"><value>5</value></property><!-- 每个服务器最大连接数 --><property name="maxConn"><value>250</value></property><!-- 主线程睡眠时间 --><property name="maintSleep"><value>30</value></property><!-- TCP/Socket的参数，如果是true在写数据时不缓冲，立即发送出去参数 --><property name="nagle"><value>false</value></property><!-- 连接超时/阻塞读取数据的超时间是 --><property name="socketTO"><value>3000</value></property></bean><bean id="memcachedClient" class="com.whalin.MemCached.MemCachedClient" ><constructor-arg><value>memcachedPool</value></constructor-arg></bean>

import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.lang.management.ManagementFactory;
import java.lang.management.RuntimeMXBean;
import java.text.SimpleDateFormat;
import java.util.Date;import org.apache.log4j.Logger;import com.whalin.MemCached.MemCachedClient;public class MemcachedUtils {private static final Logger logger = Logger.getLogger(MemcachedUtils.class);  private static MemCachedClient cachedClient;  static {  if (cachedClient == null)  cachedClient = new MemCachedClient("memcachedPool");  }  private MemcachedUtils() {}  /** * 向缓存添加新的键值对。如果键已经存在，则之前的值将被替换。 *  * @param key *            键 * @param value *            值 * @return */  public static boolean set(String key, Object value) {  return setExp(key, value, null);  }  /** * 向缓存添加新的键值对。如果键已经存在，则之前的值将被替换。 *  * @param key *            键 * @param value *            值 * @param expire *            过期时间 New Date(1000*10)：十秒后过期 * @return */  public static boolean set(String key, Object value, Date expire) {  return setExp(key, value, expire);  }  /** * 向缓存添加新的键值对。如果键已经存在，则之前的值将被替换。 *  * @param key *            键 * @param value *            值 * @param expire *            过期时间 New Date(1000*10)：十秒后过期 * @return */  private static boolean setExp(String key, Object value, Date expire) {  boolean flag = false;  try {  flag = cachedClient.set(key, value, expire);  } catch (Exception e) {  // 记录Memcached日志  MemcachedLog.writeLog("Memcached set方法报错，key值：" + key + "\r\n" + exceptionWrite(e));  }  return flag;  }  /** * 仅当缓存中不存在键时，add 命令才会向缓存中添加一个键值对。 *  * @param key *            键 * @param value *            值 * @return */  public static boolean add(String key, Object value) {  return addExp(key, value, null);  }  /** * 仅当缓存中不存在键时，add 命令才会向缓存中添加一个键值对。 *  * @param key *            键 * @param value *            值 * @param expire *            过期时间 New Date(1000*10)：十秒后过期 * @return */  public static boolean add(String key, Object value, Date expire) {  return addExp(key, value, expire);  }  /** * 仅当缓存中不存在键时，add 命令才会向缓存中添加一个键值对。 *  * @param key *            键 * @param value *            值 * @param expire *            过期时间 New Date(1000*10)：十秒后过期 * @return */  private static boolean addExp(String key, Object value, Date expire) {  boolean flag = false;  try {  flag = cachedClient.add(key, value, expire);  } catch (Exception e) {  // 记录Memcached日志  MemcachedLog.writeLog("Memcached add方法报错，key值：" + key + "\r\n" + exceptionWrite(e));  }  return flag;  }  /** * 仅当键已经存在时，replace 命令才会替换缓存中的键。 *  * @param key *            键 * @param value *            值 * @return */  public static boolean replace(String key, Object value) {  return replaceExp(key, value, null);  }  /** * 仅当键已经存在时，replace 命令才会替换缓存中的键。 *  * @param key *            键 * @param value *            值 * @param expire *            过期时间 New Date(1000*10)：十秒后过期 * @return */  public static boolean replace(String key, Object value, Date expire) {  return replaceExp(key, value, expire);  }  /** * 仅当键已经存在时，replace 命令才会替换缓存中的键。 *  * @param key *            键 * @param value *            值 * @param expire *            过期时间 New Date(1000*10)：十秒后过期 * @return */  private static boolean replaceExp(String key, Object value, Date expire) {  boolean flag = false;  try {  flag = cachedClient.replace(key, value, expire);  } catch (Exception e) {  MemcachedLog.writeLog("Memcached replace方法报错，key值：" + key + "\r\n" + exceptionWrite(e));  }  return flag;  }  /** * get 命令用于检索与之前添加的键值对相关的值。 *  * @param key *            键 * @return */  public static Object get(String key) {  Object obj = null;  try {  obj = cachedClient.get(key);  } catch (Exception e) {  MemcachedLog.writeLog("Memcached get方法报错，key值：" + key + "\r\n" + exceptionWrite(e));  }  return obj;  }  /** * 删除 memcached 中的任何现有值。 *  * @param key *            键 * @return */  public static boolean delete(String key) {  return deleteExp(key, null);  }  /** * 删除 memcached 中的任何现有值。 *  * @param key *            键 * @param expire *            过期时间 New Date(1000*10)：十秒后过期 * @return */  public static boolean delete(String key, Date expire) {  return deleteExp(key, expire);  }  /** * 删除 memcached 中的任何现有值。 *  * @param key *            键 * @param expire *            过期时间 New Date(1000*10)：十秒后过期 * @return */  @SuppressWarnings("deprecation")private static boolean deleteExp(String key, Date expire) {  boolean flag = false;  try {  flag = cachedClient.delete(key, expire);  } catch (Exception e) {  MemcachedLog.writeLog("Memcached delete方法报错，key值：" + key + "\r\n" + exceptionWrite(e));  }  return flag;  }  /** * 清理缓存中的所有键/值对 *  * @return */  public static boolean flashAll() {  boolean flag = false;  try {  flag = cachedClient.flushAll();  } catch (Exception e) {  MemcachedLog.writeLog("Memcached flashAll方法报错\r\n" + exceptionWrite(e));  }  return flag;  }  /** * 返回异常栈信息，String类型 *  * @param e * @return */  private static String exceptionWrite(Exception e) {  StringWriter sw = new StringWriter();  PrintWriter pw = new PrintWriter(sw);  e.printStackTrace(pw);  pw.flush();  return sw.toString();  }  /** *  * @ClassName: MemcachedLog * @Description: Memcached日志记录 * @author yinjw * @date 2014-6-18 下午5:01:37 *  */  private static class MemcachedLog {  private final static String MEMCACHED_LOG = "D:\\memcached.log";  private final static String LINUX_MEMCACHED_LOG = "/usr/local/logs/memcached.log";  private static FileWriter fileWriter;  private static BufferedWriter logWrite;  // 获取PID，可以找到对应的JVM进程  private final static RuntimeMXBean runtime = ManagementFactory.getRuntimeMXBean();  private final static String PID = runtime.getName();  /** * 初始化写入流 */  static {  try {  String osName = System.getProperty("os.name");  if (osName.indexOf("Windows") == -1) {  fileWriter = new FileWriter(MEMCACHED_LOG, true);  } else {  fileWriter = new FileWriter(LINUX_MEMCACHED_LOG, true);  }  logWrite = new BufferedWriter(fileWriter);  } catch (IOException e) {  logger.error("memcached 日志初始化失败", e);  closeLogStream();  }  }  /** * 写入日志信息 *  * @param content *            日志内容 */  public static void writeLog(String content) {  try {  logWrite.write("[" + PID + "] " + "- [" + new SimpleDateFormat("yyyy年-MM月-dd日 hh时:mm分:ss秒").format(new Date().getTime()) + "]\r\n"  + content);  logWrite.newLine();  logWrite.flush();  } catch (IOException e) {  logger.error("memcached 写入日志信息失败", e);  }  }  /** * 关闭流 */  private static void closeLogStream() {  try {  fileWriter.close();  logWrite.close();  } catch (IOException e) {  logger.error("memcached 日志对象关闭失败", e);  }  }  }
}

memcache_ip=192.168.1.10:11211

public class MemCacheController {private final Logger logger = LoggerFactory.getLogger(getClass());/*** 查找memcache中的key* @param key* @return*/@RequestMapping(value = "/findSessionByKey", method = {RequestMethod.POST, RequestMethod.GET})@ResponseBodypublic String findByKey(@RequestParam String key){logger.info("MemCacheController.findByKey param:key="+key);if(StringUtils.isEmpty(key)){return "key must not be empty or null!";}return (String)MemcachedUtils.get(key);}}