Memcached结合Spring

使用simple-spring-memcached
在POM中添加：

<dependencies>
   <dependency>
     <groupId>com.google.code.simple-spring-memcached</groupId>
     <artifactId>xmemcached-provider</artifactId>
     <version>3.6.1</version>
   </dependency> 
</dependencies>

在Spring配置文件中添加：

<beans xmlns="http://www.springframework.org/schema/beans" 
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">

  <import resource="simplesm-context.xml" />
  <aop:aspectj-autoproxy />
  /*simplesm-context.xml封装在simple-spring-memcached-*.jar文件当中，主要用来加载组件核心的Advice，供程序调度使用。
  而由于simple-spring-memcached主要是基于AOP的代理，所以加入<aop:aspectj-autoproxy />让代理机制起到作用。*/

  <bean name="defaultMemcachedClient" class="com.google.code.ssm.CacheFactory">
      <property name="cacheClientFactory">
            <bean class="com.google.code.ssm.providers.xmemcached.MemcacheClientFactoryImpl" />
      </property>
      <property name="addressProvider">
            <bean class="com.google.code.ssm.config.DefaultAddressProvider">
                 <property name="address" value="127.0.0.1:11211" />
            </bean>
      </property>
      <property name="configuration">
            <bean class="com.google.code.ssm.providers.CacheConfiguration">
                  <property name="consistentHashing" value="true" />
            </bean>
      </property>
   </bean>
</beans>

接下来就可以使用注解读写缓存了：

public class UserDaoImpl implements IUserDao {  
    private static final String NAMESPACE="user";  
    private Map<String,User> users=new HashMap<String,User>();  
    @Override  
    public void saveUser(User user) {  
        users.put(user.getUserId(), user);  
    }  
    /** 
     * 当执行getById查询方法时，系统首先会从缓存中获取userId对应的实体 
     * 如果实体还没有被缓存，则执行查询方法并将查询结果放入缓存中 
     */  
    @Override  
    @ReadThroughSingleCache(namespace = NAMESPACE, expiration = 3600)  //3600秒=1小时
    public User getById(@ParameterValueKeyProvider String userId) {  
        System.out.println(userId);  
        return users.get(userId);  
    }  
    /** 
     * 当执行updateUser方法时，系统会更新缓存中userId对应的实体 
     * 将实体内容更新成@*DataUpdateContent标签所描述的实体 
     */  
    @UpdateSingleCache(namespace = NAMESPACE, expiration = 3600)  
    @Override  
    public void updateUser(@ParameterValueKeyProvider @ParameterDataUpdateContent User user) {  
        users.put(user.getUserId(), user);  
    }  
    /** 
     * 当执行deleteUser方法时，系统会删除缓存中userId对应的实体 
     */  
    @InvalidateSingleCache(namespace = NAMESPACE)  
    @Override  
    public void deleteUser(@ParameterValueKeyProvider String userId) {  
        users.remove(userId);  
    }  
}

注意这里的User（实体及实体的每个成员变量）必须是可序列化的，需实现Serializable接口。
@ParameterValueKeyProvider: 标记将方法的参数做为计算缓存key.如果被其注解的对象有标记@CacheKeyMethod的getCacheKey()方法，这根据getCacheKey()方法生成缓存key。否则调用toString()生成
多个方法参数都作为cacheKey时，@ParameterValueKeyProvider必须指明其order值，之间用 '/' 号分隔。上面例子中生成的Key为user:{userId}（namespace:参数1|参数2），namespace可以设置成模块名加方法名等方法以避免Key重复。例如：
@ReadThroughSingleCache(namespace = "goodscenter:EventGoodsDo", expiration = 60)
public EventGoodsDo queryEventGoodsDo
(@ParameterValueKeyProvider(order = 0) long goodsId, @ParameterValueKeyProvider(order = 1) long eventId)
{
return getRemoteServiceBean().queryEventGoodsDo(goodsId, eventId);
}
SingleCache 类
操作单个 POJO 的 Cache 数据，由 ParameterValueKeyProvider 和 CacheKeyMethod 来标识组装 key。

SingleCache

MultiCache 类
操作 List 型的 Cache 数据（看做是 SingleCache 的批处理），由 ParameterValueKeyProvider 和 CacheKeyMethod 来标识组装 key。

MultiCache

AssignCache 类
操作所有类型的 Cache 数据。适用于无参方法或者需要自定义 Key 的场景。指定 key 操作 Cache 数据，由 annotation 中的 assignedKey 指定 key。

AssignCache

@ReadThroughSingleCache，@ReadThroughMultiCache，@ReadThroughAssignCache
当遇到查询方法声明这些切入点时，组件首先会从缓存中读取数据，取到数据则跳过查询方法，直接返回。取不到数据在执行查询方法，并将查询结果放入缓存，以便下一次获取。
@InvalidateSingleCache，@InvalidateMultiCache，@InvalidateAssignCache
当遇到删除方法声明这些切入点时，组件会删除缓存中的对应实体。
@UpdateSingleCache，@UpdateMultiCache，@UpdateAssignCache
当遇到更新方法声明这些切入点是，组件会更新缓存中对应的实体，以便下次从缓存中读取出的数据状态是最新的
使用UpdateCache 更新Cache中的数据key生成规则：@ParameterDataUpdateContent：参数中的数据，作为更新缓存的数据
@ReturnDataUpdateContent：方法调用后返回的数据，作为更新缓存的数据，这上述两个注解，必须与Update系列的注解一起使用
//@ParameterDataUpdateContent
@UpdateSingleCache(namespace = "Alpha", expiration = 30)
public void overrideDateString(final int trash, @ParameterValueKeyProvider final String key,
@ParameterDataUpdateContent final String overrideData) {
}
```
  //@ReturnDataUpdateContent
  @UpdateSingleCache(namespace = "Bravo", expiration = 300)  
  @ReturnDataUpdateContent  
  public String updateTimestampValue(@ParameterValueKeyProvider final Long key) {  
      try {  
          Thread.sleep(100);  
      } catch (InterruptedException ex) {  
      }  
      final Long now = new Date().getTime();  
      final String result = now.toString() + "-U-" + key.toString();  
      return result;  
  }  
```

和Spring Cache结合
于Ehcache一样，Memcached也可以和Spring Cache结合使用
在POM中添加：

<dependency>
  <groupId>com.google.code.simple-spring-memcached</groupId>
  <artifactId>spring-cache</artifactId>
  <version>3.6.1</version>
</dependency>
<dependency>
  <groupId>com.google.code.simple-spring-memcached</groupId>
  <artifactId>xmemcached-provider</artifactId>
  <version>3.6.1</version>
</dependency>

在Spring配置文件中添加：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:cache="http://www.springframework.org/schema/cache"
    xsi:schemaLocation="
       http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
           http://www.springframework.org/schema/context
           http://www.springframework.org/schema/context/spring-context-3.1.xsd
           http://www.springframework.org/schema/cache 
           http://www.springframework.org/schema/cache/spring-cache-3.1.xsd">

  <cache:annotation-driven />

  <bean name="cacheManager" class="com.google.code.ssm.spring.SSMCacheManager">
    <property name="caches">
      <set>
        <bean class="com.google.code.ssm.spring.SSMCache">
      <constructor-arg name="cache" index="0" ref="defaultCache" />
          <!-- 5 minutes -->
      <constructor-arg name="expiration" index="1" value="300" />
          <!-- @CacheEvict(..., "allEntries" = true) won't work because allowClear is false, 
           so we won't flush accidentally all entries from memcached instance -->
      <constructor-arg name="allowClear" index="2" value="false" />
    </bean>
      </set>
    </property>
  </bean>

  <bean name="defaultCache" class="com.google.code.ssm.CacheFactory" depends-on="cacheBase">
    <property name="cacheName" value="default" />
    <property name="cacheClientFactory">
      <bean name="cacheClientFactory" class="com.google.code.ssm.providers.xmemcached.MemcacheClientFactoryImpl" />
    </property>
    <property name="addressProvider">
      <bean class="com.google.code.ssm.config.DefaultAddressProvider">
        <property name="address" value="127.0.0.1:11211" />
      </bean>
    </property>
    <property name="configuration">
      <bean class="com.google.code.ssm.providers.CacheConfiguration">
        <property name="consistentHashing" value="true" />
        <!-- spring can produce keys that contain unacceptable characters -->
        <property name="useBinaryProtocol" value="true" />
      </bean>
    </property>
  </bean>
</beans>

然后就可以使用Spring Cache的注解了。

参考：
https://github.com/ragnor/simple-spring-memcached/wiki/Getting-Started
http://greemranqq.iteye.com/blog/2168710
http://www.myexception.cn/software-architecture-design/414190.html
http://blog.csdn.net/javaman_chen/article/details/7682290

最后编辑于：2017.12.04 01:40:48

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 213,992评论 6赞 493
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 91,212评论 3赞 388
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 159,535评论 0赞 349
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 57,197评论 1赞 287
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 66,310评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 50,383评论 1赞 292
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,409评论 3赞 412
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 38,191评论 0赞 269
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,621评论 1赞 306
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 36,910评论 2赞 328
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 39,084评论 1赞 342
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,763评论 4赞 337
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,403评论 3赞 322
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,083评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,318评论 1赞 267
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 46,946评论 2赞 365
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 43,967评论 2赞 351

Memcached结合Spring

推荐阅读更多精彩内容