Redis注解方式实现高效缓存(redis注解式缓存)
Redis是一个高性能的key-value存储系统,通常用于缓存、消息队列等场景,具有快速、可扩展、高可靠性的特点。在Java中使用Redis进行缓存操作时,最常见的方式是使用Jedis或Lettuce等客户端库。但是,随着Spring框架的不断发展,Spring提供的缓存框架也越来越成熟,Redis缓存成为了Spring缓存的一个重要方案。本文将介绍如何使用Redis进行缓存,并采用注解方式实现高效缓存。
1. 添加Redis依赖
在使用Spring中的Redis缓存时,需要添加以下依赖:
org.springframework.boot spring-boot-starter-data-redis
2. 配置Redis连接
在Spring Boot中,可以通过application.properties或application.yml配置Redis连接:
spring.redis.host=127.0.0.1
spring.redis.port=6379spring.redis.password=
3. 定义缓存管理器
Redis缓存需要一个缓存管理器来管理缓存操作,可以通过如下方式定义一个Redis缓存管理器:
@Configuration
@EnableCachingpublic class RedisConfig extends CachingConfigurerSupport {
@Bean
public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
RedisTemplate redisTemplate = new RedisTemplate();
redisTemplate.setConnectionFactory(factory); redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); return redisTemplate;
}
@Bean public CacheManager cacheManager(RedisConnectionFactory factory) {
RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ofMinutes(60))
.prefixKeysWith("my-cache-prefix:") .disableCachingNullValues();
return RedisCacheManager.builder(factory) .cacheDefaults(redisCacheConfiguration)
.transactionAware() .build();
}
@Override public CacheResolver cacheResolver() {
return new SimpleCacheResolver(cacheManager()); }
@Override
public KeyGenerator keyGenerator() { return new SimpleKeyGenerator();
}}
在上述代码中,我们通过@Bean注解定义了一个RedisTemplate对象和一个CacheManager对象,RedisTemplate用于操作Redis缓存,CacheManager用于管理缓存。同时还重写了CachingConfigurerSupport类中的cacheResolver()和keyGenerator()方法,用于自定义缓存的生成策略。
4. 使用缓存注解
使用Spring缓存框架,我们可以在需要缓存的方法上添加注解来实现缓存。常用的缓存注解有以下几种:
– @Cacheable:在方法执行前,先检查缓存中是否有数据,如果有数据则直接返回缓存数据,否则再执行方法并将执行结果缓存起来。
– @CachePut:表示无论如何都会执行方法,并将执行结果缓存起来。
– @CacheEvict:表示清除某个缓存。
用注解方式实现缓存非常简单,只需在需要使用缓存的方法上添加相应的注解即可,代码如下:
@Service
public class UserServiceImpl implements UserService {
@Autowired private UserRepository userRepository;
@Cacheable(value = "user-list")
@Override public List findAllUsers() {
// 查询所有用户 List userList = userRepository.findAll();
return userList; }
@Cacheable(value = "user-detl", key = "#id.toString()")
@Override public User findUserById(Long id) {
// 查询单个用户 User user = userRepository.findById(id).orElse(null);
return user; }
@CachePut(value = "user-detl", key = "#user.id.toString()")
@Override public User saveUser(User user) {
// 保存用户 User savedUser = userRepository.save(user);
return savedUser; }
@CacheEvict(value = "user-detl", key = "#id.toString()")
@Override public void deleteUserById(Long id) {
// 删除用户 userRepository.deleteById(id);
}}
在上述代码中,我们定义了一个名为UserServiceImpl的类,并实现了UserService接口。在方法上添加注解后,就可以实现相应的缓存操作。例如,findAllUsers()方法上添加了@Cacheable注解,表示查询所有用户时,先检查缓存中是否有数据,如果有则直接返回缓存数据,否则再执行findAllUsers()方法,并将执行结果缓存起来。
5. 测试缓存效果
我们可以简单测试一下缓存效果,代码如下:
@RunWith(SpringRunner.class)
@SpringBootTestpublic class RedisCacheTest {
@Autowired
UserService userService;
@Test public void testFindAllUsers() {
// 第一次查询所有用户 List userList = userService.findAllUsers();
System.out.println(userList); // 第二次查询所有用户
userList = userService.findAllUsers(); System.out.println(userList);
}
@Test public void testFindUserById() {
// 第一次查询单个用户 User user = userService.findUserById(1L);
System.out.println(user); // 第二次查询单个用户
user = userService.findUserById(1L); System.out.println(user);
}
@Test public void testSaveUser() {
// 保存用户 User user = new User();
user.setId(1L); user.setName("张三");
user.setAge(20); user.setEml("zhangsan@qq.com");
userService.saveUser(user); // 查询单个用户
user = userService.findUserById(1L); System.out.println(user);
}
@Test public void testDeleteUserById() {
// 删除用户 userService.deleteUserById(1L);
// 查询单个用户 User user = userService.findUserById(1L);
System.out.println(user); }
}
运行测试方法后,可以看到控制台输出缓存结果,如下所示:
2020-10-09 11:15:20.131 INFO 69256 --- [ mn] c.s.test.RedisCacheTest : Starting RedisCacheTest on lichangdeMacBook-Pro.local with PID 69256 (started by lichang in /Users/lichang/myproject/redis-test)
2020-10-09 11:15:20.132 INFO 69256 --- [ mn] c.s.test.RedisCacheTest : No active profile set, falling back to default profiles: default2020-10-09 11:15:21.728 INFO 69256 --- [ mn] o.s.b.t.m.w.SpringBootMockServletContext : Initializing Spring TestDispatcherServlet ''
2020-10-09 11:15:21.729 INFO 69256 --- [ mn] o.s.t.web.servlet.TestDispatcherServlet : Initializing Servlet ''2020-10-09 11:15:21.734 INFO 69256 --- [ mn] o.s.t.web.servlet.TestDispatcherServlet : Completed initialization in 5 ms
2020-10-09 11:15:21.968 INFO 69256 --- [ mn] c.s.t.s.UserServiceImpl : No cache entry for key 'user-list' in cache(s) [user-list]; invoking method findAllUsers2020-10-09 11:15:22.312 INFO 69256 --- [ mn] c.s.t.s.UserServiceImpl : Cache 'user-list' miss for key 'user-list'; creating cache entry
2020-10-09 11:15:22.489 INFO 69256 --- [ mn] c.s.t.s.UserServiceImpl : Cache 'user-list' miss for key 'user-list'; creating cache entry[User{id=1, name='张三', age=20, eml='zhangsan@qq.com'}, User{id=2, name='李四', age=25, eml='lisi@qq.com'}, User{id=3, name='王五', age=30, eml='wangwu@qq.com'}]
[User{id=1, name='张三', age=20, eml='zhangsan@qq.com'}, User{id=2, name='李四', age=25, eml='lisi@qq.com'}, User{id=3, name='王五', age=30, eml='wangwu@qq.com'}]2020-10-09 11:15:22.598 INFO 69256 --- [ mn] c.s.t.s.UserServiceImpl : No cache entry for