spring cache整合redis

spring cache整合redis

在项目中，我们经常需要将一些常用的数据使用缓存起来，避免频繁的查询数据库造成效率低下。spring 为我们提供了一套基于注解的缓存实现，方便我们实际的开发。我们可以扩展spring的cache接口以达到使用redis来做缓存的效果。

步骤:

1.编写一个类用于实现   org.springframework.cache.Cache  这个接口

2.编写一个类实现  org.springframework.cache.CacheManager 这个接口或继承 org.springframework.cache.support.AbstractCacheManager这个类

3.在配置文件中进行配置。

代码:

1.使用redis实现spring的cache接口 -- 数据以hash的方式存入到redis中

package com.huan.redis.springcache;import org.springframework.cache.Cache;import org.springframework.cache.support.SimpleValueWrapper;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;/** * 自定义redis缓存 * * @描述 * @作者 huan * @时间 2016年6月26日 - 下午2:14:26 */public class RedisCache implements Cache { private JedisPool jedisPool; /** 缓存的过期时间，单位是秒 */ private int timeouts; public void setJedisPool(JedisPool jedisPool) { this.jedisPool = jedisPool; } public int getTimeouts() { return timeouts; } public void setTimeouts(int timeouts) { this.timeouts = timeouts; } private String name; public void setName(String name) { this.name = name; } @Override public String getName() { return name; } @Override public Object getNativeCache() { return jedisPool; } @Override public ValueWrapper get(Object key) { ValueWrapper result = null; Jedis jedis = null; try { jedis = jedisPool.getResource(); String value = jedis.hget(getName(), (String) key); if (value != null) { result = new SimpleValueWrapper(value); } } catch (Exception e) { e.printStackTrace(); } finally { if (null != jedis) { jedis.close(); } } return result; } @Override public void put(Object key, Object value) { String cacheKey = (String) key; String cacheValue = (String) value; Jedis jedis = null; try { jedis = jedisPool.getResource(); jedis.hset(getName(), cacheKey, cacheValue); jedis.expire(getName(), getTimeouts()); } catch (Exception e) { e.printStackTrace(); } finally { if (null != jedis) { jedis.close(); } } } @Override public void evict(Object key) { if (null != key) { Jedis jedis = null; try { jedis = jedisPool.getResource(); jedis.hdel(getName(), (String) key); } catch (Exception e) { e.printStackTrace(); } finally { if (null != jedis) { jedis.close(); } } } } @Override public void clear() { Jedis jedis = null; try { jedis = jedisPool.getResource(); jedis.hdel(getName()); } catch (Exception e) { e.printStackTrace(); } finally { if (null != jedis) { jedis.close(); } } }}

2.实现自己的缓存管理器

package com.huan.redis.springcache;import java.util.Collection;import org.springframework.cache.Cache;import org.springframework.cache.support.AbstractCacheManager;/** * 继承spring的抽象缓存管理器，用于实现我们自己的缓存管理 * @描述 * @作者 huan * @时间 2016年6月26日 - 下午2:17:15 */public class RedisCacheManager extends AbstractCacheManager{ private Collection caches; public void setCaches(Collection caches) { this.caches = caches; } @Override protected Collection loadCaches() { return this.caches; }}

3.配置文件中进行配置

注意：1. 这一句用于开启spring的缓存注解

2.redis.clients.jedis.JedisPool 用于配置redis的地址和端口，默认端口是6379，如果自己的redis不是这个端口，可以选择JedisPool中适当的构造方法进行配置

4.编写业务方法 -- UserService类中比较简单，就是UserServiceImpl中方法的申明。

package com.huan.redis.service;import org.springframework.cache.annotation.CacheEvict;import org.springframework.cache.annotation.Cacheable;import org.springframework.stereotype.Service;/** * 测试业务员方法 * @描述 * @作者 huan * @时间 2016年6月26日 - 下午3:20:58 */@Servicepublic class UserServiceImpl implements UserService { /** 将数据放入到usersCache这个缓存中，缓存的key使用spirng的spel表达式获取值 */ @Override @Cacheable(value = "usersCache", key = "#loginName") public String getUser(String loginName) { System.out.println("no user cache:" + loginName); return loginName; } @Override public String getUserNoCache(String loginName) { return getUser(loginName); } @Override @Cacheable(value = "booksCache", key = "#bookId") public String addBook(String bookId) { System.out.println("no book cache:" + bookId); return bookId; } /** 使usersCache中的缓存key为#loginName这个值的缓存失效 */ @Override @CacheEvict(value = "usersCache", key = "#loginName") public void evictUser(String loginName) { System.out.println("evict cache loginName:" + loginName); }}

5.进行测试

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。