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=6379
spring.redis.password=

3. 定义缓存管理器

Redis缓存需要一个缓存管理器来管理缓存操作,可以通过如下方式定义一个Redis缓存管理器:

@Configuration
@EnableCaching
public 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)
@SpringBootTest
public 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: default
2020-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 findAllUsers
2020-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

数据运维技术 » Redis注解方式实现高效缓存(redis注解式缓存)