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

创建时间：2018/5/7 16:04
来源：http://www.jb51.net/article/111701.htm

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

转载  2017-04-20   作者：彩虹过后的羽翼   我要评论

..
本篇文章主要介绍了spring整合redis缓存并以注解(@Cacheable、@CachePut、@CacheEvict)形式使用，具有一定的参考价值，有兴趣的可以了解一下。
.
.

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

1
2
3
4
5
6
7
8
9
10
<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中的内容：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
<?xml version="1.0" encoding="UTF-8"?>
    
  <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中的内容：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# 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类中的内容：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
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控制器：

1
2
3
4
5
6
7
8
9
10
<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整合的那部分：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
<?xml version="1.0" encoding="UTF-8"?>
  <!-- 自动扫描该包，使SpringMVC认为包下用了@controller注解的类是控制器 --> 
  <context:component-scan base-package="com.cn" /> 
    
  <!-- 引入同文件夹下的redis属性配置文件 -->
  <import resource="spring-redis.xml"/>
    
</beans> 

在service的实现类中：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
@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);
  }
}

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

. .

原文链接：http://blog.csdn.net/aqsunkai/article/details/51758900

微信公众号搜索 “ 脚本之家 ” ，选择关注

程序猿的那些事、送书等活动等着你

.
.
.

相关文章

  • .
    .

  • 用java在web环境下上传和下载文件的技巧

    这篇文章主要介绍了用java在web环境下上传和下载文件的技巧的相关资料
    2016-01-01

  • java实现冒泡排序算法

    冒泡排序（Bubble Sort）是一种简单的排序算法。它重复地走访过要排序的数列，一次比较两个元素，如果他们的顺序错误就把他们交换过来。走访数列的工作是重复地进行直到没有再需要交换，也就是说该数列已经排序完成。
    2015-04-04

  • java final 和instanceof 关键字的区别

    这篇文章介绍了java final 和instanceof 关键字的区别，有需要的朋友可以参考一下
    2013-09-09

  • Java的特点和优点(动力节点整理)

    由于Java语言的设计者们十分熟悉C++语言，所以在设计时很好地借鉴了C++语言。可以说，Java语言是一种比C++语言“还面向对象”的一种编程语言，下面通过本文说下java的特点和优点
    2017-03-03

  • java实现上传图片并压缩图片大小功能

    这篇文章主要为大家详细介绍了java实现上传图片并压缩图片大小功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2017-05-05

  • Java实现二维码功能的实例代码

    今天这篇文章，主要是利用Java实现二维码功能，本文思路清晰，需要的朋友参考下
    2017-02-02

  • Java回调机制解读

    本文主要介绍了Java回调机制的相关知识，具有很好的参考价值，下面跟着小编一起来看下吧
    2017-02-02

  • Java自定义注解的详解

    这篇文章主要介绍了Java自定义注解的详解的相关资料,Java注解提供了关于代码的一些信息，但并不直接作用于它所注解的代码内容，需要的朋友可以参考下
    2017-08-08

  • java 设计模式之State(状态模式）

    这篇文章主要介绍了java 设计模式之State(状态模式）的相关资料,一个类的行为基于它的状态的改变而改变。状态模式归属于行为型模式，需要的朋友可以参考下
    2017-08-08

  • jfinal添加jcaptcha验证码实现方法

    这篇文章主要介绍了jfinal的jcaptcha验证码实现方法，大家参考使用吧
    2014-01-01
.
.
.

最新评论