600字范文,内容丰富有趣,生活中的好帮手!
600字范文 > SpringBoot整合redis——redisTemplate RedisUtil的使用!

SpringBoot整合redis——redisTemplate RedisUtil的使用!

时间:2021-01-18 09:35:50

相关推荐

SpringBoot整合redis——redisTemplate RedisUtil的使用!

RedisTemplate默认采用的是JDK的序列化策略,保存的key和value都是采用此策略序列化保存的。

pom 加入redis相关依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><version>2.0.4.RELEASE</version></dependency>

yml redis配置:

redis:host: 192.168.0.0 # Redis服务器地址database: 0 # Redis数据库索引(默认为0)port: 6379 # Redis服务器连接端口password: # Redis服务器连接密码(默认为空)jedis:pool:max-active: 8 # 连接池最大连接数(使用负值表示没有限制)max-wait: -1ms # 连接池最大阻塞等待时间(使用负值表示没有限制)max-idle: 8 # 连接池中的最大空闲连接min-idle: 0 # 连接池中的最小空闲连接timeout: 3000ms # 连接超时时间(毫秒

配置一个RedisTemplate:

package com.mon.utils.RedisUtil;import com.fasterxml.jackson.annotation.JsonAutoDetect;import com.fasterxml.jackson.annotation.PropertyAccessor;import com.fasterxml.jackson.databind.ObjectMapper;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;import org.springframework.data.redis.serializer.StringRedisSerializer;/*** Created by on /9/22.*/@Configurationpublic class RedisConfig {/*** @SuppressWarnings 该批注的作用是给编译器一条指令,告诉它对被批注的代码元素内部的某些警告保持静默** 关键字 用途* deprecation 使用了不赞成使用的类或方法时的警告* unchecked执行了未检查的转换时的警告,例如当使用集合时没有用泛型 (Generics) 来指定集合保存的类型。* fallthrough 当 Switch 程序块直接通往下一种情况而没有 Break 时的警告。* path在类路径、源文件路径等中有不存在的路径时的警告。* serial 当在可序列化的类上缺少 serialVersionUID 定义时的警告。* finally 任何 finally 子句不能正常完成时的警告。* all 关于以上所有情况的警告。*/// 注入 Spring 容器中,忽略所有警告@Bean@SuppressWarnings("all")public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(factory);Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper objectMapper = new ObjectMapper();objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();// key 采用 String 的序列化方式template.setKeySerializer(stringRedisSerializer);// hash 的 key 也采用 String 的序列化方式template.setHashKeySerializer(stringRedisSerializer);// value 的序列化方式采用 JSONtemplate.setValueSerializer(jackson2JsonRedisSerializer);// hash value 的序列化方式也采用 JSONtemplate.setHashValueSerializer(jackson2JsonRedisSerializer);template.afterPropertiesSet();return template;}}

配置RedisUtil,直接用redisTemplate操作redis,需要很多行代码,因此直接封装好一个redisutils,这样写代码更方便点。这个redisUtils交给spring容器实例化,使用时直接注解注入。

package com.mon.utils.RedisUtil;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.RedisTemplate;import org.ponent;import org.springframework.util.CollectionUtils;import java.util.List;import java.util.Map;import java.util.Set;import java.util.concurrent.TimeUnit;/*** Created by on /9/22.* 直接用redisTemplate操作redis,需要很多行代码,因此直接封装好一个redisutils,这样写代码更方便点。这个redisUtils交给spring容器实例化,使用时直接注解注入。*//*** @component (把普通pojo实例化到spring容器中,相当于配置文件中的)泛指各种组件,就是说当我们的类不属于各种归类的时候(不属于@Controller、@Services等的时候),我们就可以使用@Component来标注这个类。1、@Service用于标注业务层组件2、@Controller用于标注控制层组件(如struts中的action)3、@Repository用于标注数据访问组件,即DAO组件.4、@Component泛指组件,当组件不好归类的时候,我们可以使用这个注解进行标注。*/@Componentpublic class RedisUtil {/*** @Autowired 注释,它可以对类成员变量、方法及构造函数进行标注,完成自动装配的工作。 通过 @Autowired的使用来消除 set ,get方法。在使用@Autowired之前,我们对一个bean配置起属性时,是这用用的* <property name="属性名" value=" 属性值"/> 通过这种方式来,配置比较繁琐,而且代码比较多。在Spring 2.5 引入了 @Autowired 注释*/@Autowiredprivate RedisTemplate<String, Object> redisTemplate;/*** 指定缓存失效时间* @param key 键* @param time 时间(秒)* @return true / false*/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 键* @return*/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;}}/*** 删除缓存* @SuppressWarnings("unchecked") 忽略类型转换警告* @param key 键(一个或者多个)*/@SuppressWarnings("unchecked")public void del(String... key) {if (key != null && key.length > 0) {if (key.length == 1) {redisTemplate.delete(key[0]);} else {//传入一个 Collection<String> 集合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 则设置无限时间* @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 delta 递增大小* @return*/public long incr(String key, long delta) {if (delta < 0) {throw new RuntimeException("递增因子必须大于 0");}return redisTemplate.opsForValue().increment(key, delta);}/*** 递减* @param key 键* @param delta 递减大小* @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 键(no null)* @param item 项(no null)* @return 值*/public Object hget(String key, String item) {return redisTemplate.opsForHash().get(key, item);}/*** 获取 key 对应的 map* @param key 键(no null)* @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<Object, 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<Object, 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 键* @param item 项(可以多个,no null)*/public void hdel(String key, Object... item) {redisTemplate.opsForHash().delete(key, item);}/*** 判断 Hash表 中是否有该键的值* @param key 键(no null)* @param item 值(no 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 递减大小* @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;}}/*** 从键为 key 的 set 中,根据 value 查询是否存在* @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 sSet(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;}}/*** 移除 set缓存中,值为 value 的* @param key 键* @param values 值* @return 成功移除个数*/public long setRemove(String key, Object... values) {try {return redisTemplate.opsForSet().remove(key, values);} 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;}}/*** 根据索引 index 获取键为 key 的 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;}}/*** 将值 value 插入键为 key 的 list 中,如果 list 不存在则创建空 list* @param key 键* @param value 值* @return true / false*/public boolean lSet(String key, Object value) {try {redisTemplate.opsForList().rightPush(key, value);return true;} catch (Exception e) {e.printStackTrace();return false;}}/*** 将值 value 插入键为 key 的 list 中,并设置时间* @param key 键* @param value 值* @param time 时间* @return true / false*/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;}}/*** 将 values 插入键为 key 的 list 中* @param key 键* @param values 值* @return true / false*/public boolean lSetList(String key, List<Object> values) {try {redisTemplate.opsForList().rightPushAll(key, values);return true;} catch (Exception e) {e.printStackTrace();return false;}}/*** 将 values 插入键为 key 的 list 中,并设置时间* @param key 键* @param values 值* @param time 时间* @return true / false*/public boolean lSetList(String key, List<Object> values, long time) {try {redisTemplate.opsForList().rightPushAll(key, values);if (time > 0) {expire(key, time);}return true;} catch (Exception e) {e.printStackTrace();return false;}}/*** 根据索引 index 修改键为 key 的值* @param key 键* @param index 索引* @param value 值* @return true / false*/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;}}/*** 在键为 key 的 list 中删除值为 value 的元素* @param key 键* @param count 如果 count == 0 则删除 list 中所有值为 value 的元素* 如果 count > 0 则删除 list 中最左边那个值为 value 的元素* 如果 count < 0 则删除 list 中最右边那个值为 value 的元素* @param value* @return*/public long lRemove(String key, long count, Object value) {try {return redisTemplate.opsForList().remove(key, count, value);} catch (Exception e) {e.printStackTrace();return 0;}}/*** ceshi* @param args*/public static void main(String[] args) {}}

在ServiceImpl 中使用:

@Autowiredprivate RedisUtil redisUtil;List<Object> strings = new ArrayList<>();strings.add("哈哈哈");strings.add("嘤嘤嘤");strings.add("嘎嘎嘎");redisUtil.lSetList("666", strings);

查看:

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。