博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Spring 整合 Redis
阅读量:4965 次
发布时间:2019-06-12

本文共 7084 字,大约阅读时间需要 23 分钟。

pom构建:

org.springframework.data
spring-data-redis
1.6.0.RELEASE
org.springframework
spring-test
3.1.2.RELEASE
test
redis.clients
jedis
2.9.0
junit
junit
4.8.2
test

spring配置文件(applicationContext.xml):

开启Spring采用CGLIB代理

<!-- 配置使Spring采用CGLIB代理 -->

<aop:aspectj-autoproxy proxy-target-class="true" />

redis.properties:

# Redis settingsredis.host=192.168.1.39redis.port=6379redis.pass=jayredis.timeout=0redis.maxIdle=300redis.maxTotal=50redis.maxWaitMillis=1000redis.testOnBorrow=trueredis.testOnReturn=true

代码:

自己实现的缓存类 RedisCache

package com.github.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
redisTemplate; private String name; public RedisTemplate
getRedisTemplate() { return redisTemplate; } public void setRedisTemplate(RedisTemplate
redisTemplate) { this.redisTemplate = redisTemplate; } public void setName(String name) { this.name = name; } @Override public String getName() { return this.name; } @Override public Object getNativeCache() { return this.redisTemplate; } @Override public ValueWrapper get(Object key) { System.out.println("get key"); final String keyf = key.toString(); Object object = null; object = redisTemplate.execute(new RedisCallback
() { 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) { System.out.println("put key"); final String keyf = key.toString(); final Object valuef = value; final long liveTime = 10 * 6; //86400一天 redisTemplate.execute(new RedisCallback
() { 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) { System.out.println("del key"); final String keyf = key.toString(); redisTemplate.execute(new RedisCallback
() { public Long doInRedis(RedisConnection connection) throws DataAccessException { return connection.del(keyf.getBytes()); } }); } @Override public void clear() { System.out.println("clear key"); redisTemplate.execute(new RedisCallback
() { public String doInRedis(RedisConnection connection) throws DataAccessException { connection.flushDb(); return "ok"; } }); } @Override public
T get(Object key, Class
type) { return null; } @Override public ValueWrapper putIfAbsent(Object key, Object value) { return null; }}

注意:

spring配置文件中的

<bean class="com.github.util.RedisCache">

<property name="redisTemplate" ref="redisTemplate" />
<property name="name" value="common" />
<!-- common名称要在类或方法的注解中使用 -->
</bean>

name 的value  可以自定义 。后面方法注解的value要和这个对应 

这里配置就完成了。可以直接在service方法上面开启注解:

有4个注解

@Cacheable、@CachePut、@CacheEvict 注释介绍

@Cacheable 作用和配置方法

@Cacheable 的作用 主要针对方法配置,能够根据方法的请求参数对其结果进行缓存
@Cacheable 主要的参数
value 缓存的名称,在 spring 配置文件中定义,必须指定至少一个例如:这里和上面的name 的value对应,楼主这里写的是common
@Cacheable(value=”mycache”) 或者 
@Cacheable(value={”cache1”,”cache2”}
key 缓存的 key,可以为空,如果指定要按照 SpEL 表达式编写,如果不指定,则缺省按照方法的所有参数进行组合例如:
@Cacheable(value=”testcache”,key=”#userName”)
condition 缓存的条件,可以为空,使用 SpEL 编写,返回 true 或者 false,只有为 true 才进行缓存例如:
@Cacheable(value=”testcache”,condition=”#userName.length()>2”)
------------------------------------------------------------
--

 @CachePut 作用和配置方法

@CachePut 的作用 主要针对方法配置,能够根据方法的请求参数对其结果进行缓存,和 @Cacheable 不同的是,它每次都会触发真实方法的调用
@CachePut 主要的参数
value 缓存的名称,在 spring 配置文件中定义,必须指定至少一个例如:
@Cacheable(value=”mycache”) 或者 
@Cacheable(value={”cache1”,”cache2”}
key 缓存的 key,可以为空,如果指定要按照 SpEL 表达式编写,如果不指定,则缺省按照方法的所有参数进行组合例如:
@Cacheable(value=”testcache”,key=”#userName”)
condition 缓存的条件,可以为空,使用 SpEL 编写,返回 true 或者 false,只有为 true 才进行缓存例如:
@Cacheable(value=”testcache”,condition=”#userName.length()>2”)
@CachePut 不同的是不管有没有缓存,都会调用方法.使用于 数据库的插入
//

@CacheEvict 作用和配置方法

@CachEvict 的作用 主要针对方法配置,能够根据一定的条件对缓存进行清空
@CacheEvict 主要的参数
value 缓存的名称,在 spring 配置文件中定义,必须指定至少一个例如:
@CachEvict(value=”mycache”) 或者 
@CachEvict(value={”cache1”,”cache2”}
key 缓存的 key,可以为空,如果指定要按照 SpEL 表达式编写,如果不指定,则缺省按照方法的所有参数进行组合例如:
@CachEvict(value=”testcache”,key=”#userName”)
condition 缓存的条件,可以为空,使用 SpEL 编写,返回 true 或者 false,只有为 true 才清空缓存例如:
@CachEvict(value=”testcache”,
condition=”#userName.length()>2”)
allEntries 是否清空所有缓存内容,缺省为 false,如果指定为 true,则方法调用后将立即清空所有缓存例如:
@CachEvict(value=”testcache”,allEntries=true)
beforeInvocation 是否在方法执行前就清空,缺省为 false,如果指定为 true,则在方法还没有执行的时候就清空缓存,缺省情况下,如果方法执行抛出异常,则不会清空缓存例如:
@CachEvict(value=”testcache”,beforeInvocation=true)

额外补充

知道你们注意到一个问题没有,就是所有的@Cacheable()里面都有一个
value=“xxx”的属性,这显然如果方法多了,写起来也是挺累的,如果可以一次性声明完 那就省事了,
所以,有了@CacheConfig这个配置,
@CacheConfig
 is a class-level annotation that allows to share the cache names,不过不用担心,如果你在你的方法写别的名字,那么依然以方法的名字为准。
注释在类上面
@CacheConfig(cacheNames = "common")

转载于:https://www.cnblogs.com/zhousiwei/p/10625804.html

你可能感兴趣的文章
SignTool Error: No certificates were found that met all the given criteria
查看>>
sql server 查询分析器中表名无效,有红线,其实是这张表的
查看>>
hash 分区的用途是什么?
查看>>
linux/windows下启用和停止VMware后台服务的脚本
查看>>
在eclipse中API的封装和调用
查看>>
POJ 1330 Nearest Common Ancestors(Tree)
查看>>
小程序基础总结
查看>>
IDA Pro 数据库文件
查看>>
创建.htaccess文件
查看>>
20165305 《网络对抗技术》 Kali安装
查看>>
如何判断css是否加载完成
查看>>
MySQL数据库服务器逐渐变慢分析与解决
查看>>
C#学习-面向对象语言都有类
查看>>
故宫和雪
查看>>
易错java知识点总结(持续更新)
查看>>
01 基本数据类型
查看>>
06 文件处理
查看>>
大二暑假周进度总结02
查看>>
多线程和包
查看>>
.net实例:Asp.net把UTF-8编码转换为GB2312编码
查看>>