前言:
如今看官们对“java 磁盘缓存”大致比较关注,朋友们都想要了解一些“java 磁盘缓存”的相关文章。那么小编也在网上收集了一些关于“java 磁盘缓存””的相关知识,希望小伙伴们能喜欢,大家快快来了解一下吧!Redis学习3——Redis应用之缓存1. 引言1.1. 缓存的意义
Redis作为一个NoSql数据库,被广泛的当作缓存数据库使用,所谓缓存,就是数据交换的缓冲区。使用缓存的具体原因有:
缓存数据存储于代码中,而代码运行在内存中,内存的读写性能远高于磁盘,通过缓存,可以大大降低用户访问并发量带来的服务器读写压力。实际开发过程中,企业的数据量,少则几十万,多则上千万,如此大的数据量,如果没有缓存来作为“避震器”,系统是几乎撑不住的,所以企业会大量运用缓存技术。1.2. 缓存的分类
对于缓存,我们可以分为以下几类:
浏览器缓存:主要存在于浏览器端的缓存应用层缓存:本地缓存(比如tomcat本地缓存)或缓存数据库(比如redis)数据库缓存:在数据库中有一片空间是buffer pool,增删改查数据都会先加载到mysql的缓存中CPU缓存:当代计算机最大的问题是 cpu性能提升了,但内存读写速度没有跟上,所以为了适应当下的情况,增加了cpu的L1,L2,L3级的缓存2. 缓存模型2.1. 查询、添加缓存
一般情况下,在查询数据库之前,先查询缓存,如果缓存数据存在,就直接返回缓存数据,如果不存在,查询数据库,并将数据存入redis,具体的模型如下:
2.2. 缓存淘汰
内存的空间是有限的,当我们向redis存储太多数据时,redis会对部分数据进行淘汰,淘汰数据的场景有:
内存淘汰:Redis自动进行,当redis内存达到设定的max-memery时,会自动触发淘汰机制,淘汰掉一些不重要的数据。超时剔除:当对redis设置了过期时间TTL时,Redis会将超时的数据进行删除。主动更新:通过手动调用方法把缓存删除掉,常用于解决缓存与数据库不一致的问题。
Redis自动进行内存淘汰时,主要有6+2种数据淘汰机制,可以分为以下三大类:
不淘汰数据noeviction ,不进行数据淘汰,当缓存被写满后,Redis不提供服务直接返回错误。在设置过期时间的键值对中,volatile-random ,在设置过期时间的键值对中随机删除volatile-ttl ,在设置过期时间的键值对,基于过期时间的先后进行删除,越早过期的越先被删除。volatile-lru , 基于LRU(Least Recently Used) 算法筛选设置了过期时间的键值对, 最近最少使用的原则来筛选数据volatile-lfu ,使用 LFU( Least Frequently Used ) 算法选择设置了过期时间的键值对, 使用频率最少的键值对,来筛选数据。在所有键值对中allkeys-random, 从所有键值对中随机选择并删除数据allkeys-lru, 使用 LRU 算法在所有数据中进行筛选allkeys-lfu, 使用 LFU 算法在所有数据中进行筛选2.3. 数据库缓存不一致解决方案
因为我们的缓存数据来自于数据库,而数据库的数据会随业务的需要而发生变化,当数据库中的数据变化,而缓存没有同步该数据,此时便会产生一致性问题。具体的解决策略有:
Cache Aside Pattern(旁路缓存)Read/Write-Through Pattern(读写穿透)Write Behind Pattern(异步缓存写入)2.3.1. Cache Aside Pattern(旁路缓存模式)
该模式是平时使用比较多的一个缓存读写模式,比较适合读请求比较多的场景,在该模式中,需要同时维系db和cache,并且以db的结果为准。
2.3.1.1. 写
先更新db,然后再直接删除cache
注意,不能先删除cache,在写db,因为在并发的情况下,可能存在,请求1删除缓存,然后写db,并且写db操作还没结束,这时请求2获取缓存,此时因为缓存被删除了,因此会从数据库读数据, 并存入缓存,这个时候的数据是未更新的,当请求2结束后,请求1写db结束,此时就会造成数据库和缓存中的数据不一致。
旁路缓存理论上来说,也会造成数据库和缓存不一致的问题,比如:请求 1 先写数据 A,请求 2 随后读数据 A 的话,就很有可能产生数据不一致性的问题。
这个过程可以简单描述为:
但这种概率很小,因为缓存的写入速度比数据库的写入速度快很多。
2.3.1.2. 读
从cache中读取数据,读取到就直接返回。如果读取不到,从db中读取数据返回,然后再把数据放到cache中。
2.3.1.3. Cache Aside Pattern的缺陷
首次请求数据一定不在cache:这种情况可以先将热点数据提前放入cache中。写操作比较频繁,会导致cache的数据被频繁删除,影响缓存命中率:更新db的时候同时更新cache,但是给缓存设置一个比较短的过期时间,保证即使数据不一致的话,影响也比较小。2.3.2. Read/Write Through Pattern(读写穿透)
服务端把 cache 视为主要数据存储,从中读取数据并将数据写入其中。cache 服务负责将此数据读取和写入 db,从而减轻了应用程序的职责。这种策略比较少使用,因为Redis并没有提供cache将数据写入db的功能。
2.3.2.1. 写(Write Through)
先查 cache,cache 中不存在,直接更新 db。cache 中存在,则先更新 cache,然后 cache 服务自己更新 db(同步更新 cache 和 db)。
2.3.2.2. 读(Read Through)
从 cache 中读取数据,读取到就直接返回 。读取不到的话,先从 db 加载,写入到 cache 后返回响应。
2.3.2.3. 缺陷
实现困难,如Redis并没有提供cache将数据写入db的功能和Cache Aside Pattern一样,首次请求数据一定不在cache中2.3.3. Write Behind Pattern(异步缓存写入)
与Read/Write Through Pattern相似,都是由cache服务来负责cache和db的读写,但是,Read/Write Through是同步更新cache和db,而Write Behind是只更新缓存,不直接更新db,改为异步批量的方式,更新db。
这种方式对数据一致性带来了更大的挑战,比如 cache 数据可能还没异步更新 db 的话,cache 服务可能就就挂掉了。这种策略在我们平时开发过程中也非常非常少见,但是不代表它的应用场景少,比如消息队列中消息的异步写入磁盘、MySQL 的 Innodb Buffer Pool 机制都用到了这种策略。
Write Behind Pattern 下 db 的写性能非常高,非常适合一些数据经常变化又对数据一致性要求没那么高的场景,比如浏览量、点赞量。
3. 缓存常见的问题3.1. 缓存雪崩
缓存雪崩,指缓存在同一时间大面积的生效(比如缓存数据过期),导致大量的请求都直接落到数据库上,给数据库造成了巨大的压力。此外,如果缓存服务器宕机也会导致缓存雪崩现象,导致所有的请求都落到了数据库上。
解决方法有:
采用Redis集群,避免单机出现问题导致整个缓存服务器无法使用。限流,避免同时处理大量请求。多级缓存,比如本地缓存+Redis缓存的组合,当Redis缓存出现问题时,可以从本地缓存中获取部分数据。设置不同的生效时间比如随机设置缓存的失效时间。缓存永不生效。缓存预热,在程序启动后或运行过程中,主动将热点数据加载到缓存中。3.2. 缓存穿透
缓存穿透指大量请求的key是不合理的,根本不存在与缓存和数据库中,这就导致这些请求直接到了数据库,给数据库造成巨大压力。比如黑客故意制造一些非法的key发起大量请求,导致大量请求落到数据库,结果数据库上也没有查到对应的数据。
解决方法:
参数校验:对不合法的参数请求,直接抛出异常信息给客户端,比如查询的数据库id不能为0,手机格式不正确等。缓存无效key:将这些无效的key设置到缓存中,并设置一个较短的过期时间。这种方法可以解决请求的key变化不频繁的情况。接口限流。布隆过滤器:通过布隆过滤器判断一个给定数据是否存在于海量数据中。具体做法是:把所有可能存在的请求的值都存放在布隆过滤器中,当用户请求过来,先判断用户发来的请求的值是否存在于布隆过滤器中。不存在的话,直接返回请求参数错误信息给客户端,存在的话才会走下面的流程。3.3. 缓存击穿
缓存击穿,指请求的key对应的是热点数据,该数据存在于数据库中,但是不存在于缓存中(通常是因为缓存中的数据已经过期),这就会导致瞬时大量请求直接打到了数据库上,对数据库造成巨大压力。比如秒杀进行过程中,缓存中的某个秒杀商品数据过期,导致瞬时大量对该商品的请求直接落到数据库上,对数据库造成巨大压力。
解决方法:
设置热点数据永不过期或过期时间较长。针对热点数据提取预热,将其存入缓存中并设置合理的过期时间。请求数据库写数据到缓存之前,先获取互斥锁,保证只有一个请求会落到数据库上,减少数据库的压力。4. SpringBoot整合Redis实现缓存4.1. 准备数据库数据
首先我们创建一个t_user表,并插入几条数据,用于后续的查询:
4.2. 读缓存
创建User类和对应的UserMapper
@TableName(value = "t_user")@Datapublic class User implements Serializable { @TableId(type = IdType.AUTO) private Integer id; private String username; private String password;}@Mapperpublic interface UserMapper extends BaseMapper<User> {}
UserService
@Servicepublic class UserService { // 过期时间 private long ttl = 100L; @Autowired private UserMapper userMapper; @Autowired private RedisUtils redisUtils; public User getUserById(Integer id) { String key = "user:" + id; Object value = redisUtils.getKey(key); if (value != null) { // 缓存中存在该数据 return (User) value; } // 缓存中不存在该数据, 从数据库中查询 User userFromDB = getUserFromDB(id); if (userFromDB == null) { return null; } redisUtils.addKey(key, userFromDB, ttl); return userFromDB; } private User getUserFromDB(Integer id) { System.out.println("从数据库中查询===================="); return userMapper.selectById(id); }}
添加一个测试方法:
package org.example;import org.example.pojo.User;import org.example.service.UserService;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;@SpringBootTestpublic class RedisCacheTest { @Autowired private UserService userService; @Test public void testGetUserById() { User userById = userService.getUserById(1); System.out.println(userById); userById = userService.getUserById(1); System.out.println(userById); }}
执行测试方法,结果如下:
从上述内容中,可以看出,第一次查询时,因为数据不存在于缓存中,所以会查询数据库,第二次查询时,从缓存中查询到数据,直接返回。
但是这里涉及到一个序列化的问题,我们通过下载一些redis桌面可视化工具,查看这些数据,发现这些key和value都有一些奇怪的编码,如下图所示:
这是因为,默认情况下,redisTemplate使用JDK的序列化器(JdkSerializationRedisSerializer)对存储的对象进行序列哈和反序列化操作,这可能导致序列化结果不可读或占用较多的存储空间。因此,我们需要在配置redisTemplate的时候,设置对应的序列化器,我们修改上一章的RedisConfiguration类,修改结果如下:
package org.example.config;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;@Configurationpublic class RedisConfiguration { @Bean public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>(); redisTemplate.setConnectionFactory(redisConnectionFactory); StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper objectMapper = new ObjectMapper().enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(objectMapper); // 设置key的序列化器为StringRedisSerializer redisTemplate.setKeySerializer(stringRedisSerializer); // 设置value的序列化器为Jackson2JsonRedisSerializer redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); // 设置hash key的序列化器为StringRedisSerializer redisTemplate.setHashKeySerializer(stringRedisSerializer); // 设置hash value的序列化器为Jackson2JsonRedisSerializer redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer); // 完成其他配置后,初始化RedisTemplate redisTemplate.afterPropertiesSet(); return redisTemplate; }}
我们将之前那些key全部删除掉,然后重新运行测试代码,结果如下:
通过redis可视化工具,也能清楚地看到每个key和value的结构和信息。
上面的代码,存在一些问题,当请求1查询id=1的用户,从缓存中查询不到时,会查询数据库,然后将数据更新到数据库,然后请求2查询id=1的用户,从缓存中查询到,便直接返回,这是理想的情况。但是,可能请求1查询数据库还没执行完,请求2过来了,此时缓存中没有id=1的用户,因此请求2也会去查询数据库。
比如我们修改getUserFromDB,加上Thread.sleep(2000),模拟数据库的查询较慢,然后修改测试代码,模拟多个请求同时查询id=1的用户的情况:
@Test public void testGetUserById() throws ExecutionException, InterruptedException { ExecutorService executorService = Executors.newFixedThreadPool(2); Callable<User> getUserTask = () -> userService.getUserById(1); Future<User> submit1 = executorService.submit(getUserTask); Future<User> submit2 = executorService.submit(getUserTask); System.out.println(submit1.get()); System.out.println(submit2.get()); }
此时再次执行测试代码,结果如下:
解决上面的情况,方式就是加锁,我们修改UserService的代码如下,这里通过synchronized加锁,然后锁的对象使用key,这样可以将锁的粒度缩小一点。
public User getUserById(Integer id) { String key = "user:" + id; Object value = redisUtils.getKey(key); if (value != null) { // 缓存中存在该数据 return (User) value; } User userFromDB = null; synchronized (key.intern()) { // 再次查询缓存 value = redisUtils.getKey(key); if (value != null) { return (User) value; } // 缓存中不存在该数据, 从数据库中查询 userFromDB = getUserFromDB(id); if (userFromDB == null) { return null; } redisUtils.addKey(key, userFromDB, ttl); } return userFromDB; } private User getUserFromDB(Integer id) { try { Thread.sleep(2000); } catch (Exception e) { e.printStackTrace(); } System.out.println("从数据库中查询===================="); return userMapper.selectById(id); }
重新运行测试方法,结果如下:
通过加锁,可以解决被访问多次的情况,但是这样的锁有一个问题,这个锁,只适用于单机的情况,当我们的服务部署在多台服务器上时,这些服务器上的应用,对应的JVM都不同,因此锁住的,不是同一个对象,后续会单独对分布式锁进行讲解,这里先不予讨论。
4.3. 更新缓存
修改userService,添加修改用户的方法
public void updateUser(UpdateUserRequest updateUserRequest) { if (updateUserRequest.getId() == null) { return; } User user = getUserById(updateUserRequest.getId()); if (user == null) { return; } if (StringUtils.isNotEmpty(updateUserRequest.getUsername())) { user.setUsername(updateUserRequest.getUsername()); } if (StringUtils.isNotEmpty(updateUserRequest.getPassword())) { user.setPassword(updateUserRequest.getPassword()); } // 先更新数据库 int updateResult = userMapper.updateById(user); if (updateResult == 1) { // 更新成功,删除缓存 redisUtils.removeKey("user:" + updateUserRequest.getId()); } }
添加测试方法
@Test public void testUpdateUser() { UpdateUserRequest updateUserRequest = new UpdateUserRequest(); updateUserRequest.setId(1); updateUserRequest.setPassword("12345"); userService.updateUser(updateUserRequest); User userById = userService.getUserById(1); System.out.println(userById); }
测试结果如下
5. SpringBoot整合SpringCache+Redis
在上面的代码中,我们发现,和Redis查询的操作,和我们的业务代码糅合在一起, 不方便进行处理,如果后续我们缓存服务器从Redis改为其他缓存服务器,需要修改多处代码,不利于项目的扩展和维护。
SpringCache框架是Spring框架提供的一套基于注解的缓存解决方案,在应用程序中简化了缓存操作的管理和使用。它通过在方法上添加缓存注解,来实现自动缓存的功能,其常用注解有:
1)@Cacheable: 表示该方法返回结果可以被缓存,当方法被调用时,先检查缓存,如果缓存命中,直接返回缓存中的结果,不再执行方法体中的逻辑。
2) @CachePut:表示该方法的返回结果需要更新缓存,每次方法被调用后,都会将返回结果更新到缓存中。
3)@CacheEvit:表示该方法会清除缓存中的数据,可以用于在更新或删除数据时清除相应的缓存。
5.1. 整合SpringCache
添加Spring Cache的依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-cache</artifactId> </dependency>
在启动类上加上注解开启缓存
@SpringBootApplication@EnableCachingpublic class RedisApp { public static void main(String[] args) { SpringApplication.run(RedisApp.class, args); }}5.2. 测试Cacheable和CacheEvict
我们在userService类上,加上两个方法,用于测试Cacheable和CacheEvit注解。
添加getUserById2方法,该方法中的逻辑为查询数据库操作
@Cacheable(value = "user", key = "#id") public User getUserById2(Integer id) { System.out.println("从数据库中查询=============="); return userMapper.selectById(id); }
然后添加一个测试方法
@Autowired private UserService userService; @Test public void testGetUserById() { System.out.println(userService.getUserById2(1)); System.out.println(userService.getUserById2(1)); }
测试结果如下,第一次查询时,查询数据库,第二次直接查询缓存。
然后我们查看reids缓存,发现这个key的值是user::1,这个和我们之前定义的不太相同,而且没有过期时间,除此之外,这个value的值,序列化有问题
我们修改RedisConfiguration,添加RedisCacheConfiguration的相关配置
package org.example.config;import com.fasterxml.jackson.databind.ObjectMapper;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.cache.RedisCacheConfiguration;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.StringRedisSerializer;import java.time.Duration;@Configurationpublic class RedisConfiguration { @Bean public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>(); redisTemplate.setConnectionFactory(redisConnectionFactory); StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper objectMapper = new ObjectMapper().enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(objectMapper); // 设置key的序列化器为StringRedisSerializer redisTemplate.setKeySerializer(stringRedisSerializer); // 设置value的序列化器为Jackson2JsonRedisSerializer redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); // 设置hash key的序列化器为StringRedisSerializer redisTemplate.setHashKeySerializer(stringRedisSerializer); // 设置hash value的序列化器为Jackson2JsonRedisSerializer redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer); // 完成其他配置后,初始化RedisTemplate redisTemplate.afterPropertiesSet(); return redisTemplate; } @Bean public RedisCacheConfiguration redisCacheConfiguration(){ Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper objectMapper = new ObjectMapper().enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(objectMapper); //相当于new了一个RedisCacheConfiguration RedisCacheConfiguration configuration = RedisCacheConfiguration.defaultCacheConfig(); configuration = configuration.serializeValuesWith // 指定value序列化器 (RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)) // 指定 key的TTL .entryTtl(Duration.ofSeconds(100)) // 指定前缀 .prefixCacheNameWith("user::"); return configuration; }}
删除原先的缓存,然后重新运行测试代码,然后查看缓存信息,结果如下:
此时过期时间和序列化均设置成功。但这样配置还有一些问题,通过这种全局配置,所有cache key的TTL都一样,实际开发中,不同的cache key可能需要的TTL都不同,我们修改RedisConfiguration,为不同的key配置上不同的过期时间
package org.example.config;import com.fasterxml.jackson.databind.ObjectMapper;import org.springframework.boot.autoconfigure.cache.RedisCacheManagerBuilderCustomizer;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.cache.RedisCacheConfiguration;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.StringRedisSerializer;import java.time.Duration;import java.util.HashMap;import java.util.Map;@Configurationpublic class RedisConfiguration { @Bean public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>(); redisTemplate.setConnectionFactory(redisConnectionFactory); StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper objectMapper = new ObjectMapper().enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(objectMapper); // 设置key的序列化器为StringRedisSerializer redisTemplate.setKeySerializer(stringRedisSerializer); // 设置value的序列化器为Jackson2JsonRedisSerializer redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); // 设置hash key的序列化器为StringRedisSerializer redisTemplate.setHashKeySerializer(stringRedisSerializer); // 设置hash value的序列化器为Jackson2JsonRedisSerializer redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer); // 完成其他配置后,初始化RedisTemplate redisTemplate.afterPropertiesSet(); return redisTemplate; } @Bean public RedisCacheManagerBuilderCustomizer redisCacheManagerBuilderCustomizer() { Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class); ObjectMapper objectMapper = new ObjectMapper().enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(objectMapper); return (builder) -> { Map<String, RedisCacheConfiguration> cacheConfigurations = new HashMap<>(); cacheConfigurations.put("user", RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ofSeconds(60)) .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))); cacheConfigurations.put("product", RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ofSeconds(120)) .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))); builder.withInitialCacheConfigurations(cacheConfigurations); }; } }
运行结果如下:
接着,我们测试CacheEvict,首先在userService中添加一个更新方法
@CacheEvict(value = "user", key = "#updateUserRequest.id") public void updateUser2(UpdateUserRequest updateUserRequest) { if (updateUserRequest.getId() == null) { return; } User user = getUserById2(updateUserRequest.getId()); if (user == null) { return; } if (StringUtils.isNotEmpty(updateUserRequest.getUsername())) { user.setUsername(updateUserRequest.getUsername()); } if (StringUtils.isNotEmpty(updateUserRequest.getPassword())) { user.setPassword(updateUserRequest.getPassword()); } // 先更新数据库 userMapper.updateById(user); }
然后添加测试方法:
@Test public void testUpdateUser() { UpdateUserRequest updateUserRequest = new UpdateUserRequest(); updateUserRequest.setId(1); updateUserRequest.setPassword("123456"); userService.updateUser2(updateUserRequest); }
运行该测试方法,然后去看对应的redis缓存,发现更新成功后,该缓存被删除掉,说明CacheEvict生效
标签: #java 磁盘缓存