共计 13867 个字符，预计需要花费 35 分钟才能阅读完成。
看了好多篇文章，再根据自己的理解进行的配置。
一、Mevan 相关配置
1. 我的 SpringBoot 版本
| <parent> | |
| <groupId>org.springframework.boot</groupId> | |
| <artifactId>spring-boot-starter-parent</artifactId> | |
| <version>2.1.7.RELEASE</version> | |
| <relativePath/> <!-- lookup parent from repository --> | |
| </parent> |
2. 引入 spring-redis 的依赖
| <dependency> | |
| <groupId>org.springframework.boot</groupId> | |
| <artifactId>spring-boot-starter-data-redis</artifactId> | |
| </dependency> |
二、application.yml 中加入 redis 依赖
| spring: | |
| datasource: | |
| url: jdbc:mysql://localhost:3306/spring_cache?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT | |
| driver-class-name: com.mysql.cj.jdbc.Driver | |
| username: root | |
| password: 123456 | |
| redis: | |
| host: 39.107.250.174 | |
| port: 6379 | |
| database: 0 | |
| timeout: 1000s # 数据库连接超时时间，2.0 中该参数的类型为 Duration，这里在配置的时候需要指明单位 | |
| # 连接池配置，2.0 中直接使用 jedis 或者 lettuce 配置连接池 | |
| jedis: | |
| pool: | |
| # 最大空闲连接数 | |
| max-idle: 500 | |
| # 最小空闲连接数 | |
| min-idle: 50 | |
| # 等待可用连接的最大时间，负数为不限制 | |
| max-wait: -1 | |
| # 最大活跃连接数，负数为不限制 | |
| max-active: -1 | |
| cache: | |
| redis: | |
| time-to-live: -1 #毫秒 | |
| #以下可忽略 | |
| mybatis: | |
| configuration: | |
| #开启驼峰命名 | |
| map-underscore-to-camel-case: true | |
| logging: | |
| level: | |
| com.scitc.cache.mapper : debug |
三、配置编写 redis 配置类
| package com.scitc.cache.config; | |
| import com.fasterxml.jackson.annotation.JsonAutoDetect; | |
| import com.fasterxml.jackson.annotation.PropertyAccessor; | |
| import com.fasterxml.jackson.databind.ObjectMapper; | |
| import lombok.extern.slf4j.Slf4j; | |
| import org.springframework.beans.factory.annotation.Value; | |
| import org.springframework.boot.context.properties.ConfigurationProperties; | |
| import org.springframework.cache.CacheManager; | |
| import org.springframework.cache.annotation.CachingConfigurerSupport; | |
| import org.springframework.cache.annotation.EnableCaching; | |
| import org.springframework.context.annotation.Bean; | |
| import org.springframework.context.annotation.Configuration; | |
| import org.springframework.data.redis.cache.RedisCacheConfiguration; | |
| import org.springframework.data.redis.cache.RedisCacheManager; | |
| 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.RedisSerializationContext; | |
| import org.springframework.data.redis.serializer.RedisSerializer; | |
| import org.springframework.data.redis.serializer.StringRedisSerializer; | |
| import java.time.Duration; | |
| @Slf4j | |
| @Configuration | |
| @EnableCaching// 启用缓存，这个注解很重要；// 继承 CachingConfigurerSupport，为了自定义生成 KEY 的策略。可以不继承。public class RedisConfig extends CachingConfigurerSupport {@Value("${spring.cache.redis.time-to-live}") | |
| private Duration timeToLive = Duration.ZERO; | |
| @Bean(name = "redisTemplate") | |
| public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> template = new RedisTemplate<>(); | |
| template.setConnectionFactory(redisConnectionFactory); | |
| // 使用 Jackson2JsonRedisSerializer 来序列化和反序列化 redis 的 value 值 | |
| Jackson2JsonRedisSerializer<Object> redisSerializer = new Jackson2JsonRedisSerializer<>(Object.class); | |
| ObjectMapper mapper = new ObjectMapper(); | |
| mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); | |
| mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); | |
| redisSerializer.setObjectMapper(mapper); | |
| template.setValueSerializer(redisSerializer); | |
| // 使用 StringRedisSerializer 来序列化和反序列化 redis 的 key 值 | |
| template.setKeySerializer(new StringRedisSerializer()); | |
| template.afterPropertiesSet(); | |
| return template; | |
| } | |
| @Bean | |
| public CacheManager cacheManager(RedisConnectionFactory factory) {RedisSerializer<String> redisSerializer = new StringRedisSerializer(); | |
| 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); | |
| // 配置序列化（解决乱码的问题）RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig() | |
| .entryTtl(timeToLive) | |
| .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer)) | |
| .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)) | |
| .disableCachingNullValues(); | |
| RedisCacheManager cacheManager = RedisCacheManager.builder(factory) | |
| .cacheDefaults(config) | |
| .build(); | |
| return cacheManager; | |
| } | |
| } |
然后我发现有好几篇文章配置 CacheManager 采用的是如下配置：
| @Bean | |
| public CacheManager cacheManager(RedisConnectionFactory factory) { | |
| // 生成一个默认配置，通过 config 对象即可对缓存进行自定义配置 | |
| RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig(); | |
| // 设置缓存的默认过期时间，也是使用 Duration 设置 | |
| config = config.entryTtl(Duration.ofMinutes(1)) | |
| .disableCachingNullValues(); // 不缓存空值 | |
| // 设置一个初始化的缓存空间 set 集合 | |
| Set<String> cacheNames = new HashSet<>(); | |
| cacheNames.add("my-redis-cache1"); | |
| cacheNames.add("my-redis-cache2"); | |
| // 对每个缓存空间应用不同的配置 | |
| Map<String, RedisCacheConfiguration> configMap = new HashMap<>(); | |
| configMap.put("my-redis-cache1", config); | |
| configMap.put("my-redis-cache2", config.entryTtl(Duration.ofSeconds(120))); | |
| // 使用自定义的缓存配置初始化一个 cacheManager | |
| RedisCacheManager cacheManager = RedisCacheManager.builder(factory) | |
| .initialCacheNames(cacheNames) // 注意这两句的调用顺序，一定要先调用该方法设置初始化的缓存名，再初始化相关的配置 | |
| .withInitialCacheConfigurations(configMap) | |
| .build(); | |
| return cacheManager; | |
| } |
但经过我使用测试发现，他在 redis 中保存的数据是这样的，并不是 json
后面又找到一篇文章，重新配置 CacheManager （就是我直接贴出来的完整配置代码）
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/caojida…
经过测试访问保存的数据格式为 json（下方有图片）
到此 配置完成，正常运行
RedisUtils 工具类
作者：zeng1994
出处：http://www.cnblogs.com/zeng1994/
本文版权归作者和博客园共有，欢迎转载！但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文链接！
| package com.scitc.cache.utils; | |
| import java.util.List; | |
| import java.util.Map; | |
| import java.util.Set; | |
| import java.util.concurrent.TimeUnit; | |
| import org.springframework.beans.factory.annotation.Autowired; | |
| import org.springframework.data.redis.core.RedisTemplate; | |
| import org.springframework.stereotype.Component; | |
| import org.springframework.util.CollectionUtils; | |
| @Component | |
| public class RedisUtil { | |
| @Autowired | |
| private RedisTemplate<String, Object> redisTemplate; | |
| /** | |
| * 指定缓存失效时间 | |
| * @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; | |
| } | |
| } | |
| } |
自己遇到的问题
发现了个问题（不是配置文件的问题），我的对象实体类是这样的
| @Data | |
| public class Employee implements Serializable { | |
| private Integer id; | |
| private String lastName; | |
| private String email; | |
| private Integer gender; // 性别 1 男 0 女 | |
| // private Integer userId; | |
| private Integer dId; | |
| } |
在 json 数据中多了一个 did,
但获取然后打印出来并没有多数据
emp:Employee(id=2, lastName= 李四, email=132456798@qq.com, gender=0, dId=1)
问了大佬说是命名问题
当把 Employee 中的 dId 改成 userId 时（以及修改数据库字段）
这次 userId 居然不重复，后面吧 dId 换成了 uId，依旧重复。emmm 玄学。。。
最开始不知道集成 redis 怎么在业务中使用，根据自己理解发现，当你配置了 redis，SpringBoot 会自动把缓存加到 redis 中，并不使用默认的
| @Cacheable(value = {"emp"},key = "#id") | |
| public Employee getEmp(Integer id){log.info("查询" + id + "号员工"); | |
| Employee employee = employeeMapper.getEmpById(id); | |
| return employee; | |
| } |
因为配置了 redis 所以，使用 redis 缓存不使用默认的
正文完
