Spring+redis集成redis缓存

  1、引入maven依赖

        <dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.7.0</version></dependency><dependency><groupId>org.springframework.data</groupId><artifactId>spring-data-redis</artifactId><version>1.6.2.RELEASE</version></dependency>

2、配置文件redis.properties

#redis的配置文件
#服务的ip地址
redis.host=127.0.0.1
#服务器连接端口号
redis.port=6379
#服务器连接密码(默认为空)
redis.password=1234567
#连接超时时间(毫秒)
redis.timeout=3
#连接池中的最大连接数
redis.poolMaxTotal=10
#连接池中的最大空闲连接
redis.poolMaxIdle=10
#连接池中最大阻塞等待时间(使用负数表示没有限制)
redis.poolMaxWait=3
#最大空闲数，数据库连接的最大空闲时间。超过空闲时间，数据库连接将被标记为不可用，然后被释放。设为0表示无限制。  
redis.maxIdle=300
#连接池的最大数据库连接数。设为0表示无限制  
redis.maxActive=600
#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。  
redis.maxWait=1000 
#在borrow一个jedis实例时，是否提前进行alidate操作；如果为true，则得到的jedis实例均是可用的；  
redis.testOnBorrow=true 

3、redis的配置bean的xml文件redis-config.xml

<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:tx="http://www.springframework.org/schema/tx"xmlns:context="http://www.springframework.org/schema/context"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsdhttp://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-3.0.xsd"><!-- 引入配置文件 --><context:property-placeholder ignore-unresolvable="true" location="classpath:redis.properties"/><!-- redis连接池 --><bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">  <property name="maxIdle" value="${redis.maxIdle}" />  <property name="maxTotal" value="${redis.maxActive}" /><property name="testOnBorrow" value="${redis.testOnBorrow}" />  </bean><!-- redis连接池配置，类似于数据连接池 --><bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"><property name="hostName" value="${redis.host}"></property><property name="port" value="${redis.port}"></property><property name="password" value="${redis.password}"></property><property name="poolConfig" ref="jedisPoolConfig"></property></bean><!--redis操作模版,使用该对象可以操作redis  -->  <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate" >    <property name="connectionFactory" ref="jedisConnectionFactory" />    <!--如果不配置Serializer，那么存储的时候缺省使用String，如果用User类型存储，那么会提示错误User can't cast to String！！  -->    <property name="keySerializer" >    <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />    </property>    <property name="valueSerializer" >    <bean class="org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer" />    </property>    <property name="hashKeySerializer">    <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>    </property>    <property name="hashValueSerializer">    <bean class="org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer"/>    </property>    <!--开启事务  -->  <property name="enableTransactionSupport" value="true"></property>  </bean > </beans>

       注意：如果在多个spring配置文件中引入<context:property-placeholder .../>标签，最后需要加上ignore-unresolvable="true"，否则会报错。

4、测试

       4.1基于RedisTemplate基本数据类型类

@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(locations = { "classpath:/redis-config.xml" })
@SuppressWarnings("all")
public class TestRedis {@SuppressWarnings("rawtypes")@Resource(name="redisTemplate")private RedisTemplate redisTemplate;@Testpublic void testRedis() {		//String读写redisTemplate.delete("myString");redisTemplate.opsForValue().set("myString","zhangsan");System.out.println(redisTemplate.opsForValue().get("myString"));System.out.println("---------------");//List读写redisTemplate.delete("myList");redisTemplate.opsForList().rightPush("myList","T");redisTemplate.opsForList().rightPush("myList", "A");redisTemplate.opsForList().leftPush("myList", "B");List<String> listCache  = redisTemplate.opsForList().range("myList", 0, -1);for (String str : listCache) {System.out.println(str);}System.out.println("---------------");//Set读写redisTemplate.delete("mySet");redisTemplate.opsForSet().add("mySet", "A");redisTemplate.opsForSet().add("mySet", "B");redisTemplate.opsForSet().add("mySet", "C");Set<String> set  = redisTemplate.opsForSet().members("mySet");for (String s : set) {System.out.println(s);}System.out.println("---------------");//Hash读写redisTemplate.delete("myHash");redisTemplate.opsForHash().put("myHash", "BJ", "北京");redisTemplate.opsForHash().put("myHash", "TJ", "天津");redisTemplate.opsForHash().put("myHash","HN","河南");Map<String,String> map = redisTemplate.opsForHash().entries("myHash");for (String key : map.keySet()) {System.out.println(map.get(key));}System.out.println("---------------");//ZSet读写redisTemplate.delete("myZSet");redisTemplate.opsForZSet().add("myZSet", "A",1);redisTemplate.opsForZSet().add("myZSet", "B",3);redisTemplate.opsForZSet().add("myZSet", "C",2);redisTemplate.opsForZSet().add("myZSet", "D",5);Set<String> zset = redisTemplate.opsForZSet().range("myZSet", 0, -1);for (String s : zset) {System.out.println(s);}}
}

       输出内容为：

zhangsan
---------------
B
T
A
---------------
A
B
C
---------------
河南
北京
天津
---------------
A
C
B
D

       4.2基于封装了RedisTemplate的基本数据类型类

             首先封装一个RedisTemplate的工具类

@Component
public class RedisUtil {@Autowired//(自动注入redisTemplet)private RedisTemplate<String, Object> redisTemplate;  public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) {  this.redisTemplate = redisTemplate;  }  //=============================common============================  /** * 指定缓存失效时间 * @param key 键 * @param time 时间(秒) * @return */  public boolean expire(String key,long time){  try {  if(time>0){  redisTemplate.expire(key, time, TimeUnit.SECONDS);  }  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 根据key 获取过期时间 * @param key 键 不能为null * @return 时间(秒) 返回0代表为永久有效 */  public long getExpire(String key){  return redisTemplate.getExpire(key,TimeUnit.SECONDS);  }  /** * 判断key是否存在 * @param key 键 * @return true 存在 false不存在 */  public boolean hasKey(String key){  try {  return redisTemplate.hasKey(key);  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 删除缓存 * @param key 可以传一个值 或多个 */  @SuppressWarnings("unchecked")  public void del(String ... key){  if(key!=null&&key.length>0){  if(key.length==1){  redisTemplate.delete(key[0]);  }else{  redisTemplate.delete(CollectionUtils.arrayToList(key));  }  }  }  //============================String=============================  /** * 普通缓存获取 * @param key 键 * @return 值 */  public Object get(String key){  return key==null?null:redisTemplate.opsForValue().get(key);  }  /** * 普通缓存放入 * @param key 键 * @param value 值 * @return true成功 false失败 */  public boolean set(String key,Object value) {  try {  redisTemplate.opsForValue().set(key, value);  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 普通缓存放入并设置时间 * @param key 键 * @param value 值 * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期 * @return true成功 false 失败 */  public boolean set(String key,Object value,long time){  try {  if(time>0){  redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);  }else{  set(key, value);  }  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 递增 * @param key 键 * @param by 要增加几(大于0) * @return */  public long incr(String key, long delta){    if(delta<0){  throw new RuntimeException("递增因子必须大于0");  }  return redisTemplate.opsForValue().increment(key, delta);  }  /** * 递减 * @param key 键 * @param by 要减少几(小于0) * @return */  public long decr(String key, long delta){    if(delta<0){  throw new RuntimeException("递减因子必须大于0");  }  return redisTemplate.opsForValue().increment(key, -delta);    }    //================================Map=================================  /** * HashGet * @param key 键 不能为null * @param item 项 不能为null * @return 值 */  public Object hget(String key,String item){  return redisTemplate.opsForHash().get(key, item);  }  /** * 获取hashKey对应的所有键值 * @param key 键 * @return 对应的多个键值 */  public Map<Object,Object> hmget(String key){  return redisTemplate.opsForHash().entries(key);  }  /** * HashSet * @param key 键 * @param map 对应多个键值 * @return true 成功 false 失败 */  public boolean hmset(String key, Map<String,Object> map){    try {  redisTemplate.opsForHash().putAll(key, map);  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * HashSet 并设置时间 * @param key 键 * @param map 对应多个键值 * @param time 时间(秒) * @return true成功 false失败 */  public boolean hmset(String key, Map<String,Object> map, long time){    try {  redisTemplate.opsForHash().putAll(key, map);  if(time>0){  expire(key, time);  }  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 向一张hash表中放入数据,如果不存在将创建 * @param key 键 * @param item 项 * @param value 值 * @return true 成功 false失败 */  public boolean hset(String key,String item,Object value) {  try {  redisTemplate.opsForHash().put(key, item, value);  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 向一张hash表中放入数据,如果不存在将创建 * @param key 键 * @param item 项 * @param value 值 * @param time 时间(秒)  注意:如果已存在的hash表有时间,这里将会替换原有的时间 * @return true 成功 false失败 */  public boolean hset(String key,String item,Object value,long time) {  try {  redisTemplate.opsForHash().put(key, item, value);  if(time>0){  expire(key, time);  }  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 删除hash表中的值 * @param key 键 不能为null * @param item 项 可以使多个 不能为null */  public void hdel(String key, Object... item){    redisTemplate.opsForHash().delete(key,item);  }   /** * 判断hash表中是否有该项的值 * @param key 键 不能为null * @param item 项 不能为null * @return true 存在 false不存在 */  public boolean hHasKey(String key, String item){  return redisTemplate.opsForHash().hasKey(key, item);  }   /** * hash递增 如果不存在,就会创建一个 并把新增后的值返回 * @param key 键 * @param item 项 * @param by 要增加几(大于0) * @return */  public double hincr(String key, String item,double by){    return redisTemplate.opsForHash().increment(key, item, by);  }  /** * hash递减 * @param key 键 * @param item 项 * @param by 要减少记(小于0) * @return */  public double hdecr(String key, String item,double by){    return redisTemplate.opsForHash().increment(key, item,-by);    }    //============================set=============================  /** * 根据key获取Set中的所有值 * @param key 键 * @return */  public Set<Object> sGet(String key){  try {  return redisTemplate.opsForSet().members(key);  } catch (Exception e) {  e.printStackTrace();  return null;  }  }  /** * 根据value从一个set中查询,是否存在 * @param key 键 * @param value 值 * @return true 存在 false不存在 */  public boolean sHasKey(String key,Object value){  try {  return redisTemplate.opsForSet().isMember(key, value);  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 将数据放入set缓存 * @param key 键 * @param values 值 可以是多个 * @return 成功个数 */  public long sSet(String key, Object...values) {  try {  return redisTemplate.opsForSet().add(key, values);  } catch (Exception e) {  e.printStackTrace();  return 0;  }  }  /** * 将set数据放入缓存 * @param key 键 * @param time 时间(秒) * @param values 值 可以是多个 * @return 成功个数 */  public long sSetAndTime(String key,long time,Object...values) {  try {  Long count = redisTemplate.opsForSet().add(key, values);  if(time>0) expire(key, time);  return count;  } catch (Exception e) {  e.printStackTrace();  return 0;  }  }  /** * 获取set缓存的长度 * @param key 键 * @return */  public long sGetSetSize(String key){  try {  return redisTemplate.opsForSet().size(key);  } catch (Exception e) {  e.printStackTrace();  return 0;  }  }  /** * 移除值为value的 * @param key 键 * @param values 值 可以是多个 * @return 移除的个数 */  public long setRemove(String key, Object ...values) {  try {  Long count = redisTemplate.opsForSet().remove(key, values);  return count;  } catch (Exception e) {  e.printStackTrace();  return 0;  }  }  //===============================list=================================  /** * 获取list缓存的内容 * @param key 键 * @param start 开始 * @param end 结束  0 到 -1代表所有值 * @return */  public List<Object> lGet(String key,long start, long end){  try {  return redisTemplate.opsForList().range(key, start, end);  } catch (Exception e) {  e.printStackTrace();  return null;  }  }  /** * 获取list缓存的长度 * @param key 键 * @return */  public long lGetListSize(String key){  try {  return redisTemplate.opsForList().size(key);  } catch (Exception e) {  e.printStackTrace();  return 0;  }  }  /** * 通过索引 获取list中的值 * @param key 键 * @param index 索引  index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推 * @return */  public Object lGetIndex(String key,long index){  try {  return redisTemplate.opsForList().index(key, index);  } catch (Exception e) {  e.printStackTrace();  return null;  }  }  /** * 将list放入缓存 * @param key 键 * @param value 值 * @param time 时间(秒) * @return */  public boolean lSet(String key, Object value) {  try {  redisTemplate.opsForList().rightPush(key, value);  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 将list放入缓存 * @param key 键 * @param value 值 * @param time 时间(秒) * @return */  public boolean lSet(String key, Object value, long time) {  try {  redisTemplate.opsForList().rightPush(key, value);  if (time > 0) expire(key, time);  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 将list放入缓存 * @param key 键 * @param value 值 * @param time 时间(秒) * @return */  public boolean lSet(String key, List<Object> value) {  try {  redisTemplate.opsForList().rightPushAll(key, value);  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 将list放入缓存 * @param key 键 * @param value 值 * @param time 时间(秒) * @return */  public boolean lSet(String key, List<Object> value, long time) {  try {  redisTemplate.opsForList().rightPushAll(key, value);  if (time > 0) expire(key, time);  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }  /** * 根据索引修改list中的某条数据 * @param key 键 * @param index 索引 * @param value 值 * @return */  public boolean lUpdateIndex(String key, long index,Object value) {  try {  redisTemplate.opsForList().set(key, index, value);  return true;  } catch (Exception e) {  e.printStackTrace();  return false;  }  }   /** * 移除N个值为value  * @param key 键 * @param count 移除多少个 * @param value 值 * @return 移除的个数 */  public long lRemove(String key,long count,Object value) {  try {  Long remove = redisTemplate.opsForList().remove(key, count, value);  return remove;  } catch (Exception e) {  e.printStackTrace();  return 0;  }  }  }

测试上面封装的类是否好用

@RunWith(SpringJUnit4ClassRunner.class)//这个地方因为在工具类上加了注解，所以需要引入spring的配置文件
@ContextConfiguration(locations = { "classpath:/redis-config.xml" , "classpath*:/spring-mybatis.xml"})
public class TestRedisUtils {@Autowiredprivate RedisUtil redisUtil;@Testpublic void testRedisUtils() {String  str = "string";//1.字符串List<String> list = new ArrayList<String>();//listlist.add("0");list.add("中国");list.add("2");Set<String> set = new HashSet<String>();//setset.add("0");set.add("中国");set.add("2");Map<String, Object> map = new HashMap();//mapmap.put("key1", "str1");map.put("key2", "中国");map.put("key3", "str3");//删除数据,可以删除多个redisUtil.del("list","str","set","map");//1.字符串操作redisUtil.set("str", str);redisUtil.expire("str", 120);//指定失效时间为2分钟String str1 = (String) redisUtil.get("str");System.out.println(str1);//2.list操作redisUtil.lSet("list", list);redisUtil.expire("list", 120);//指定失效时间为2分钟List<Object> list1 = redisUtil.lGet("list", 0, -1);System.out.println(list1);//3.set操作redisUtil.sSet("set", set);redisUtil.expire("set", 120);//指定失效时间为2分钟Set<Object> set1 = redisUtil.sGet("set");System.out.println(set1);//3.map操作redisUtil.hmset("map", map);redisUtil.expire("map", 120);//指定失效时间为2分钟Map<Object, Object> map1 = redisUtil.hmget("map");System.out.println(map1);}
}

        输出结果：

string
[[0, 中国, 2]]
[[0, 2, 中国]]
{key3=str3, key1=str1, key2=中国}

       4.3基于封装了RedisTemplate的javaBean类

        首先创建java Bean--Student，需要一个默认无参的构造方法且类上面需要序列化，否则会报错

//序列化很重要
public class Student implements Serializable{/*** */private static final long serialVersionUID = 1L;private int age;private String name;private Date birthday;//没有这个会报错public Student() {}public Student(int age, String name, Date birthday) {this.age = age;this.name = name;this.birthday = birthday;}public int getAge() {return age;}public void setAge(int age) {this.age = age;}public String getName() {return name;}public void setName(String name) {this.name = name;}public Date getBirthday() {return birthday;}public void setBirthday(Date birthday) {this.birthday = birthday;}@Overridepublic String toString() {return "Student [age=" + age + ", name=" + name + ", birthday=" + birthday + "]";}

 编写测试javaBean的方法

@RunWith(SpringJUnit4ClassRunner.class)//这个地方因为在工具类上加了注解，所以需要引入spring的配置文件
@ContextConfiguration(locations = { "classpath:/redis-config.xml" , "classpath*:/spring-mybatis.xml"})
public class TestRedisBean {@Autowiredprivate RedisUtil redisUtil;@Testpublic void testRedisBean() {List<Student> list = new ArrayList<Student>();//listlist.add(new Student(20,"张三list",new Date()));list.add(new Student(21,"李四list",new Date()));list.add(new Student(22,"王五list",new Date()));Set<Student> set = new HashSet<Student>();//listset.add(new Student(20,"张三set",new Date()));set.add(new Student(21,"李四set",new Date()));set.add(new Student(22,"王五set",new Date()));Map<String, Object> map = new HashMap();//mapmap.put("key1",new Student(20,"张三set",new Date()));map.put("key2",new Student(21,"李四set",new Date()));map.put("key3",new Student(22,"王五set",new Date()));redisUtil.del("list","set","map");//1.list操作redisUtil.lSet("list", list,1200);List<Object> list1 = redisUtil.lGet("list", 0, -1);System.out.println(list1);//3.set操作redisUtil.sSet("set", set);redisUtil.expire("set", 1200);//指定失效时间为2分钟Set<Object> set1 = redisUtil.sGet("set");System.out.println(set1);//3.map操作redisUtil.hmset("map", map);redisUtil.expire("map", 120);//指定失效时间为2分钟Map<Object, Object> map1 = redisUtil.hmget("map");System.out.println(map1);}

       输出结果为：

[[Student [age=20, name=张三list, birthday=Fri Aug 02 17:22:55 GMT+08:00 2019], Student [age=21, name=李四list, birthday=Fri Aug 02 17:22:55 GMT+08:00 2019], Student [age=22, name=王五list, birthday=Fri Aug 02 17:22:55 GMT+08:00 2019]]]
[[Student [age=20, name=张三set, birthday=Fri Aug 02 17:22:55 GMT+08:00 2019], Student [age=21, name=李四set, birthday=Fri Aug 02 17:22:55 GMT+08:00 2019], Student [age=22, name=王五set, birthday=Fri Aug 02 17:22:55 GMT+08:00 2019]]]
{key2=Student [age=21, name=李四set, birthday=Fri Aug 02 17:22:55 GMT+08:00 2019], key1=Student [age=20, name=张三set, birthday=Fri Aug 02 17:22:55 GMT+08:00 2019], key3=Student [age=22, name=王五set, birthday=Fri Aug 02 17:22:55 GMT+08:00 2019]}

参考博客：https://www.cnblogs.com/qlqwjy/p/8562703.html