Memcached的配置，SSH项目中的整合(com.whalin)，Memcached工具类，Memcached的代码调用

Posted 2020-09-23

??

1 改动pom.xml，加入依赖文件：

<dependency>     <groupId>com.whalin</groupId>     <artifactId>Memcached-Java-Client</artifactId>     <version>3.0.2</version> </dependency>

2 加入memcached-context.xml，注意要在web.xml中进行配置

<?xml version="1.0" encoding="UTF-8"?> <beans:beans xmlns="http://www.springframework.org/schema/mvc"     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:beans="http://www.springframework.org/schema/beans"     xmlns:p="http://www.springframework.org/schema/p" xmlns:tx="http://www.springframework.org/schema/tx"     xmlns:task="http://www.springframework.org/schema/task" xmlns:context="http://www.springframework.org/schema/context"     xsi:schemaLocation="http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd        http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">         <!—注意以下的：memcache在使用的时候会用到-->     <beans:bean id="memcache" class="com.whalin.MemCached.SockIOPool"        factory-method="getInstance" init-method="initialize" destroy-method="shutDown">        <beans:constructor-arg>            <beans:value>memcache</beans:value>        </beans:constructor-arg>        <beans:property name="servers">            <beans:list>                  <!--server地址-->               <beans:value>172.16.24.27:11211</beans:value>            </beans:list>        </beans:property>          <!--初始化时对每一个server建立的连接数目-->        <beans:property name="initConn">            <beans:value>20</beans:value>        </beans:property>          <!--每一个server建立最小的连接数-->        <beans:property name="minConn">            <beans:value>10</beans:value>        </beans:property>          <!--每一个server建立最大的连接数-->        <beans:property name="maxConn">            <beans:value>50</beans:value>        </beans:property>          <!--自查线程周期进行工作，其每次休眠时间-->        <beans:property name="maintSleep">            <beans:value>1000</beans:value>        </beans:property>          <!--Socket的參数，假设是true在写数据时不缓冲。马上发送出去-->        <beans:property name="nagle">            <beans:value>false</beans:value>        </beans:property>          <!--Socket堵塞读取数据的超时时间-->        <beans:property name="socketTO">            <beans:value>1000</beans:value>        </beans:property>          <!-- 当memcached的连接路径出现故障的时候，代码连接的时候时间超时设置 -->        <beans:property name="socketConnectTO">            <beans:value>500</beans:value>        </beans:property>     </beans:bean> </beans:beans>

3 在web.xml中配置：

4 编写MemcachedUtils,代码例如以下：

package com.kuman.cartoon.utils;    import java.util.Date;   import org.apache.log4j.Logger;   import com.whalin.MemCached.MemCachedClient;     /**  * @ClassName: MemcachedUtils  * @Description: Memcached工具类  * @author  * @date 2015-8-6  *   */ public class MemcachedUtils {     private static final Logger logger = Logger.getLogger(MemcachedUtils.class);      private static MemCachedClient cachedClient;     static {          if (cachedClient == null)             //括号里的名称要和配置文件memcached-context.xml中的名称一致             cachedClient = new MemCachedClient("memcache");     }        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日志                   logger.error("Memcached set方法报错，key值：" + key + "\r\n");          }          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日志              logger.error("Memcached add方法报错，key值：" + key + "\r\n");          }          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) {              logger.error("Memcached replace方法报错，key值：" + key + "\r\n");          }          return flag;      }        /**      * get 命令用于检索与之前加入的键值对相关的值。      *       * @param key      *            键      * @return      */      public static Object get(String key) {          Object obj = null;          try {              obj = cachedClient.get(key);          } catch (Exception e) {              logger.error("Memcached get方法报错，key值：" + key + "\r\n");          }          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      */      private static boolean deleteExp(String key, Date expire) {          boolean flag = false;          try {              flag = cachedClient.delete(key, expire);          } catch (Exception e) {              logger.error("Memcached delete方法报错，key值：" + key + "\r\n");         }          return flag;      }        /**      * 清理缓存中的全部键/值对      *       * @return      */      public static boolean flashAll() {          boolean flag = false;          try {              flag = cachedClient.flushAll();          } catch (Exception e) {              logger.error("Memcached flashAll方法报错\r\n");          }          return flag;      }        /*@Test     public void testMemcachedSpring() {          MemcachedUtils.set("aa", "bb", new Date(1000 * 60));          Object obj = MemcachedUtils.get("aa");          System.out.println("***************************");          System.out.println(obj.toString());      }*/          }

5 SpringMVC中调用的方式：

@RequestMapping(value = "/toIndex")          public String toIndex(Model model) {                  //方法一，这样的不建议使用                  //MemCachedClient memCachedClient = new MemCachedClient("memcache");               //memCachedClient.set("name", "simple");               //System.out.println(memCachedClient.get("name"));                              //方法二,建议这样的              MemcachedUtils.set("name", "simple");              String name = (String)MemcachedUtils.get("name");              System.out.println(name);                                 return "/admin/index";          }

 

??

??