springboot框架 SpringBoot-Redis

SpringBoot 整合 Redis15. SpringBoot-Redis15.1 导入相关依赖<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-configuration-processor</artifactId><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies>15.2 编写Redis配置类文件路径：com--dzj--config--RedisConfig.java
@Configurationpublic class RedisConfig {//编写我们自己的RedisTemplate@Beanpublic RedisTemplate<String, Object> redisTemplates(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> template = new RedisTemplate<>();//配置具体的序列化方式// Json序列化配置Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(om);// String 的序列化StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();// key采用String的序列化方式template.setKeySerializer(stringRedisSerializer);// hash的key也采用String的序列化方式template.setHashKeySerializer(stringRedisSerializer);// value序列化方式采用jacksontemplate.setValueSerializer(jackson2JsonRedisSerializer);// hash的value序列化方式采用jacksontemplate.setHashValueSerializer(jackson2JsonRedisSerializer);template.afterPropertiesSet();//template.setConnectionFactory(redisConnectionFactory);return template;}}15.3 编写测试实体类文件路径：com--dzj--pojo--User.java
@Component@AllArgsConstructor@NoArgsConstructor@Datapublic class User{//如果需要序列化，可以实现Serializable接口进行序列化private String name;private int age;}15.4 编写配置文件# SpringBoot所有的配置，都有一个自动配置类 RedisAutoConfiguration# 自动配置类都会绑定一个properties配置文件@EnableConfigurationProperties(RedisProperties.class)# 配置redisspring.redis.host=127.0.0.1spring.redis.port=637915.5 在测试类中进行测试package com.dzj;import com.dzj.pojo.User;import com.dzj.utils.RedisUtils;import com.fasterxml.jackson.core.JsonProcessingException;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.data.redis.core.RedisTemplate;@SpringBootTestclass Springboot10RedisApplicationTests {@Autowired@Qualifier("redisTemplates")private RedisTemplate redisTemplate;@Autowiredprivate RedisUtils redisUtils;@Testpublic void testUtils(){redisUtils.set("dengzj","hello,redisUtils");System.out.println(redisUtils.get("dengzj"));}@Testvoid contextLoads() {/*redisTemplate:操作不同的数据类型， api和我们的指令是一样的 redisTemplate.opsForValue();opsForValue() 操作字符串，类似StringopsForList() 操作List ，类似ListopsForSet()、opsForHash()、opsForZSet()、opsForGeo()、opsForHyperLogLog()除了基本的操作，我们常用的方法都可以直接通过redisTemplate操作，比如事务、和基本的CRUD*//*获取redis的连接对象RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();connection.flushDb();connection.flushAll();*/redisTemplate.opsForValue().set("mykey","dengzj");System.out.println(redisTemplate.opsForValue().get("mykey"));}@Testpublic void test() throws JsonProcessingException {// 真实的开发一般都是用json传递对象User user = new User("dengzj", 18);//String jsonUser = new ObjectMapper().writeValueAsString(user);//进行序列化操作//redisTemplate.opsForValue().set("user",jsonUser);redisTemplate.opsForValue().set("user",user);//如果没有序列化，直接传递对象会报错System.out.println(redisTemplate.opsForValue().get("user"));}}【springboot框架 SpringBoot-Redis】运行测试！
15.6 Redis工具类package com.dzj.utils;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Component;import org.springframework.util.CollectionUtils;import java.util.Collection;import java.util.List;import java.util.Map;import java.util.Set;import java.util.concurrent.TimeUnit;@Componentpublic final class RedisUtils{@Autowired@Qualifier("redisTemplates")private RedisTemplate<String, Object> redisTemplate;// =============================common============================/*** 指定缓存失效时间** @param key键* @param time 时间(秒)*/public boolean expire(String key, long time, TimeUnit timeUnit) {try {if (time > 0) {redisTemplate.expire(key, time, timeUnit);}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((Collection<String>) 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 delta 要增加几(大于0)*/public long incr(String key, long delta) {if (delta < 0) {throw new RuntimeException("递增因子必须大于0");}return redisTemplate.opsForValue().increment(key, delta);}/*** 递减** @param key键* @param delta 要减少几(小于0)*/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*/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 对应多个键值*/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, TimeUnit timeUnit) {try {redisTemplate.opsForHash().putAll(key, map);if (time > 0) {expire(key, time, timeUnit);}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, TimeUnit timeUnit) {try {redisTemplate.opsForHash().put(key, item, value);if (time > 0) {expire(key, time, timeUnit);}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)*/public double hincr(String key, String item, double by) {return redisTemplate.opsForHash().increment(key, item, by);}/*** hash递减** @param key键* @param item 项* @param by要减少记(小于0)*/public double hdecr(String key, String item, double by) {return redisTemplate.opsForHash().increment(key, item, -by);}// ============================set=============================/*** 根据key获取Set中的所有值** @param key 键*/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, TimeUnit timeUnit, Object... values) {try {Long count = redisTemplate.opsForSet().add(key, values);if (time > 0) {expire(key, time, timeUnit);}return count;} catch (Exception e) {e.printStackTrace();return 0;}}/*** 获取set缓存的长度** @param key 键*/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代表所有值*/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 键*/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倒数第二个元素，依次类推*/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 值*/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时间(秒)*/public boolean lSet(String key, Object value, long time,TimeUnit timeUnit) {try {redisTemplate.opsForList().rightPush(key, value);if (time > 0) {expire(key, time,timeUnit);}return true;} catch (Exception e) {e.printStackTrace();return false;}}/*** 将list放入缓存** @param key键* @param value 值* @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,TimeUnit timeUnit) {try {redisTemplate.opsForList().rightPushAll(key, value);if (time > 0) {expire(key, time,timeUnit);}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;}}// ===============================HyperLogLog=================================public long pfadd(String key, String value) {return redisTemplate.opsForHyperLogLog().add(key, value);}public long pfcount(String key) {return redisTemplate.opsForHyperLogLog().size(key);}public void pfremove(String key) {redisTemplate.opsForHyperLogLog().delete(key);}public void pfmerge(String key1, String key2) {redisTemplate.opsForHyperLogLog().union(key1, key2);}}本文来自博客园，作者：小公羊，转载请注明原文链接：https://www.cnblogs.com/aadzj/p/15636871.html