当前位置：移动技术网 > IT编程>开发语言>Java > spring整合redis缓存并以注解(@Cacheable、@CachePut、@CacheEvict)形式使用

spring整合redis缓存并以注解(@Cacheable、@CachePut、@CacheEvict)形式使用

2019年07月22日 | 移动技术网IT编程 | 我要评论

maven项目中在pom.xml中依赖2个jar包，其他的spring的jar包省略：

<dependency> 
  <groupid>redis.clients</groupid> 
  <artifactid>jedis</artifactid> 
  <version>2.8.1</version> 
</dependency> 
<dependency> 
  <groupid>org.springframework.data</groupid> 
  <artifactid>spring-data-redis</artifactid> 
  <version>1.7.2.release</version> 
</dependency>

spring-redis.xml中的内容：

<?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:p="http://www.springframework.org/schema/p"  
  xmlns:context="http://www.springframework.org/schema/context"  
  xmlns:mvc="http://www.springframework.org/schema/mvc"  
  xmlns:cache="http://www.springframework.org/schema/cache" 
  xsi:schemalocation="http://www.springframework.org/schema/beans   
            http://www.springframework.org/schema/beans/spring-beans-4.2.xsd   
            http://www.springframework.org/schema/context   
            http://www.springframework.org/schema/context/spring-context-4.2.xsd   
            http://www.springframework.org/schema/mvc   
            http://www.springframework.org/schema/mvc/spring-mvc-4.2.xsd 
            http://www.springframework.org/schema/cache  
            http://www.springframework.org/schema/cache/spring-cache-4.2.xsd">  
   
  <context:property-placeholder location="classpath:redis-config.properties" />  
 
  <!-- 启用缓存注解功能，这个是必须的，否则注解不会生效，另外，该注解一定要声明在spring主配置文件中才会生效 -->  
  <cache:annotation-driven cache-manager="cachemanager" />  
   
   <!-- redis 相关配置 -->  
   <bean id="poolconfig" class="redis.clients.jedis.jedispoolconfig">  
     <property name="maxidle" value="${redis.maxidle}" />   
     <property name="maxwaitmillis" value="${redis.maxwait}" />  
     <property name="testonborrow" value="${redis.testonborrow}" />  
   </bean>  
 
   <bean id="jedisconnectionfactory" class="org.springframework.data.redis.connection.jedis.jedisconnectionfactory"  
    p:host-name="${redis.host}" p:port="${redis.port}" p:password="${redis.pass}" p:pool-config-ref="poolconfig"/>  
  
   <bean id="redistemplate" class="org.springframework.data.redis.core.redistemplate">  
     <property name="connectionfactory" ref="jedisconnectionfactory" />  
   </bean>  
   
   <!-- spring自己的缓存管理器，这里定义了缓存位置名称 ，即注解中的value -->  
   <bean id="cachemanager" class="org.springframework.cache.support.simplecachemanager">  
     <property name="caches">  
      <set>  
        <!-- 这里可以配置多个redis --> 
        <!-- <bean class="com.cn.util.rediscache">  
           <property name="redistemplate" ref="redistemplate" />  
           <property name="name" value="default"/>  
        </bean> -->  
        <bean class="com.cn.util.rediscache">  
           <property name="redistemplate" ref="redistemplate" />  
           <property name="name" value="common"/>  
           <!-- common名称要在类或方法的注解中使用 --> 
        </bean> 
      </set>  
     </property>  
   </bean>  
   
</beans>

redis-config.properties中的内容：

# redis settings 
# server ip 
redis.host=127.0.0.1 
# server port 
redis.port=6379 
# server pass 
redis.pass= 
# use dbindex 
redis.database=0 
# 控制一个pool最多有多少个状态为idle(空闲的)的jedis实例 
redis.maxidle=300 
# 表示当borrow(引入)一个jedis实例时，最大的等待时间，如果超过等待时间(毫秒)，则直接抛出jedisconnectionexception；  
redis.maxwait=3000 
# 在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的  
redis.testonborrow=true

com.cn.util.rediscache类中的内容：

package com.cn.util;  
import java.io.bytearrayinputstream; 
import java.io.bytearrayoutputstream; 
import java.io.ioexception; 
import java.io.objectinputstream; 
import java.io.objectoutputstream; 
 
import org.springframework.cache.cache; 
import org.springframework.cache.support.simplevaluewrapper; 
import org.springframework.dao.dataaccessexception; 
import org.springframework.data.redis.connection.redisconnection; 
import org.springframework.data.redis.core.rediscallback; 
import org.springframework.data.redis.core.redistemplate; 
 
public class rediscache implements cache{ 
 
  private redistemplate<string, object> redistemplate;  
  private string name;  
  public redistemplate<string, object> getredistemplate() { 
    return redistemplate;  
  } 
    
  public void setredistemplate(redistemplate<string, object> redistemplate) { 
    this.redistemplate = redistemplate;  
  } 
    
  public void setname(string name) { 
    this.name = name;  
  } 
    
  @override  
  public string getname() { 
    // todo auto-generated method stub  
    return this.name;  
  } 
 
  @override  
  public object getnativecache() { 
   // todo auto-generated method stub  
    return this.redistemplate;  
  } 
  
  @override  
  public valuewrapper get(object key) { 
   // todo auto-generated method stub 
   system.out.println("get key"); 
   final string keyf = key.tostring(); 
   object object = null; 
   object = redistemplate.execute(new rediscallback<object>() { 
   public object doinredis(redisconnection connection)  
         throws dataaccessexception { 
     byte[] key = keyf.getbytes(); 
     byte[] value = connection.get(key); 
     if (value == null) { 
       return null; 
      } 
     return toobject(value); 
     } 
    }); 
    return (object != null ? new simplevaluewrapper(object) : null); 
   } 
  
   @override  
   public void put(object key, object value) { 
    // todo auto-generated method stub 
    system.out.println("put key"); 
    final string keyf = key.tostring();  
    final object valuef = value;  
    final long livetime = 86400;  
    redistemplate.execute(new rediscallback<long>() {  
      public long doinredis(redisconnection connection)  
          throws dataaccessexception {  
        byte[] keyb = keyf.getbytes();  
        byte[] valueb = tobytearray(valuef);  
        connection.set(keyb, valueb);  
        if (livetime > 0) {  
          connection.expire(keyb, livetime);  
         }  
        return 1l;  
       }  
     });  
   } 
 
   private byte[] tobytearray(object obj) {  
     byte[] bytes = null;  
     bytearrayoutputstream bos = new bytearrayoutputstream();  
     try {  
      objectoutputstream oos = new objectoutputstream(bos);  
      oos.writeobject(obj);  
      oos.flush();  
      bytes = bos.tobytearray();  
      oos.close();  
      bos.close();  
     }catch (ioexception ex) {  
        ex.printstacktrace();  
     }  
     return bytes;  
    }  
 
    private object toobject(byte[] bytes) { 
     object obj = null;  
      try { 
        bytearrayinputstream bis = new bytearrayinputstream(bytes);  
        objectinputstream ois = new objectinputstream(bis);  
        obj = ois.readobject();  
        ois.close();  
        bis.close();  
      } catch (ioexception ex) {  
        ex.printstacktrace();  
      } catch (classnotfoundexception ex) {  
        ex.printstacktrace();  
      }  
      return obj;  
    } 
  
    @override  
    public void evict(object key) {  
     // todo auto-generated method stub  
     system.out.println("del key"); 
     final string keyf = key.tostring();  
     redistemplate.execute(new rediscallback<long>() {  
     public long doinredis(redisconnection connection)  
          throws dataaccessexception {  
       return connection.del(keyf.getbytes());  
      }  
     });  
    } 
  
    @override  
    public void clear() {  
      // todo auto-generated method stub  
      system.out.println("clear key"); 
      redistemplate.execute(new rediscallback<string>() {  
        public string doinredis(redisconnection connection)  
            throws dataaccessexception {  
         connection.flushdb();  
          return "ok";  
        }  
      });  
    } 
 
    @override 
    public <t> t get(object key, class<t> type) { 
      // todo auto-generated method stub 
      return null; 
    } 
   
    @override 
    public valuewrapper putifabsent(object key, object value) { 
      // todo auto-generated method stub 
      return null; 
    } 
 
}

到了这一步，大部分人会想在web.xml的启动配置文件地方(context-param)加入了spring-redis.xml,让项目启动时加载这个配置文件吧，但是这样启动后注解不生效。

正确的做法是：web.xml中配置了servlet控制器：

<servlet> 
 <servlet-name>springmvc</servlet-name> 
 <servlet-class>org.springframework.web.servlet.dispatcherservlet</servlet-class> 
 <init-param> 
  <param-name>contextconfiglocation</param-name> 
  <param-value>/web-inf/spring-mvc.xml</param-value> 
 </init-param> 
 <load-on-startup>1</load-on-startup> 
 <async-supported>true</async-supported> 
</servlet>

在dispatcherservlet的初始化过程中，框架会在web应用的 web-inf文件夹下寻找名为spring-mvc.xml的配置文件，如果不指定的话，默认是applicationcontext.xml

只需要在spring-mvc.xml文件中引入spring-redis配置文件即可，正如spring-redis.xml中的启用注解说的：<cache:annotation-driven cache-manager="cachemanager" />注解一定要声明在spring主配置文件中才会生效。

spring-mvc.xml内容，省略了spring与spring mvc整合的那部分：

<?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:p="http://www.springframework.org/schema/p"  
  xmlns:context="http://www.springframework.org/schema/context"  
  xmlns:mvc="http://www.springframework.org/schema/mvc"  
  xsi:schemalocation="http://www.springframework.org/schema/beans   
            http://www.springframework.org/schema/beans/spring-beans-4.2.xsd   
            http://www.springframework.org/schema/context   
            http://www.springframework.org/schema/context/spring-context-4.2.xsd   
            http://www.springframework.org/schema/mvc   
            http://www.springframework.org/schema/mvc/spring-mvc-4.2.xsd"> 
  <!-- 自动扫描该包，使springmvc认为包下用了@controller注解的类是控制器 -->  
  <context:component-scan base-package="com.cn" />  
   
  <!-- 引入同文件夹下的redis属性配置文件 --> 
  <import resource="spring-redis.xml"/> 
   
</beans>

在service的实现类中：

@service 
public class userserviceimpl implements userservice{ 
 
  @autowired 
  private userbo userbo; 
 
  @cacheable(value="common",key="'id_'+#id") 
  public user selectbyprimarykey(integer id) { 
    return userbo.selectbyprimarykey(id); 
  } 
   
  @cacheput(value="common",key="#user.getusername()") 
  public void insertselective(user user) { 
    userbo.insertselective(user); 
  } 
 
  @cacheevict(value="common",key="'id_'+#id") 
  public void deletebyprimarykey(integer id) { 
    userbo.deletebyprimarykey(id); 
  } 
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。

您可能感兴趣的文章:

如对本文有疑问，点击进行留言回复！！

关于在IDEA中SpringBoot项目中activiti工作流的使用详解

记录一下工作流的在springboot中的使用,，顺便写个demo，概念，什么东西的我就不解释了，如有问题欢迎各位大佬指导一下。1.创建springboot项目... [阅读全文]
视频编辑工具ACDSee Luxea Video Editor安装及激活图文教程

acdsee luxea video editor如何免费激活？今天，小编为大家带来了acdsee luxea video editor安装及激活图文教程。感兴... [阅读全文]
解决java idea新建子目录时命名不是树形结构的问题

问题再现解决办法：点击设置，然后再点击compact middle packages，如下图：成功补充知识：idea 2019.2 svn 忽略文件/目录 .i... [阅读全文]
idea 普通文件夹转换成 module操作

经常会遇到从github上download的progect在idea里面打开是普通文件夹形式，而并不是我们想要的module形式（文件夹图标右下角有个蓝色的ta... [阅读全文]
SpringBoot中使用Ehcache的详细教程

ehcache 是一个纯 java 的进程内缓存框架，具有快速、精干等特点，是 hibernate 中默认的 cacheprovider。用惯了 redis，很... [阅读全文]
在idea 中添加和删除模块Module操作

1、添加模块2、删除模块补充知识：idea添加子module的正确姿势因需求要增加一个新的测试模块，于是要在一堆module中再添加一个module，单纯的我没... [阅读全文]
Unity3D生成一段隧道网格的方法

本文实例为大家分享了unity3d生成一段隧道网格的具体代码，供大家参考，具体内容如下一、需求最近有一个需求，生成段隧道的骨架网格。目前想到的方法就是，获取隧道... [阅读全文]
Django CBV模型源码运行流程详解

在view文件中编写一个类，并配置好路由class test(view): def get(self, request, *args, **kwargs): ... [阅读全文]
java spring整合junit操作(有详细的分析过程)

此博客解决了什么问题：解决测试的时候代码冗余的问题，解决了测试工程师的编码能力可能没有开发工程师编码能力的问题，解决了junit单元测试和spring注解相结合... [阅读全文]
详解JAVA 弱引用

定义弱引用是使用weakreference创建的引用，弱引用也是用来描述非必需对象的，它是比软引用更弱的引用类型。在发生gc时，只要发现弱引用，不管系统堆空间是... [阅读全文]

网友评论


验证码：

spring整合redis缓存并以注解(@Cacheable、@CachePut、@CacheEvict)形式使用

2019年07月22日 | 移动技术网IT编程 | 我要评论

您可能感兴趣的文章:

相关文章:

网友评论