引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
写测试
@Resource
private RedisTemplate redisTemplate;
@Test
void test(){
// 从 redisTemplate 对象中获取了一个 ValueOperations 对象。
// ValueOperations 是专门用于操作 Redis 中的字符串值(String values)的。
ValueOperations valueOperations = redisTemplate.opsForValue();
// 增
valueOperations.set("name","dog");
valueOperations.set("age",1);
valueOperations.set("testDouble",2.0);
User user = new User();
user.setId(0L);
user.setUsername("username");
valueOperations.set("testObject",user);
// 查
Object obj = valueOperations.get("name");
obj = valueOperations.get("age");
obj = valueOperations.get("testDouble");
obj = valueOperations.get("testObject");
}
自定义序列化
一款国人开源、免费、功能强大的 Redis 可视化管理工具:QuickRedis
官网:https://quick123.net/
使用 QuickRedis 查看一下
发现 存储的 key 是一串奇怪的编码
通过追踪 RedisRedisTem 这个类的源码,发现有一个默认的序列化器 JdkSerializationRedisSerializer,这是 RedisTemplate 在 Spring Data Redis 中默认使用的序列化器,它使用 Java 的序列化机制对对象进行序列化和反序列化。然而,这种序列化方式并不是最优的,因为它生成的数据比较大,并且不是人类可读的。此外,它也可能导致跨语言或跨平台的不兼容问题。
在实际应用中,更常见的做法是为 RedisTemplate 配置自定义的序列化器,比如使用 StringRedisSerializer 来序列化键,以及 Jackson2JsonRedisSerializer 或 GenericJackson2JsonRedisSerializer 来序列化值,从而将对象序列化为 JSON 格式的字符串。这样既可以减小序列化后数据的大小,又提高了可读性,并且更容易实现跨语言或跨平台的兼容性。
所以,我们来自定义序列化
/**
* 自定义序列化
*/
@Configuration
public class RedisTemplateConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
// 创建RedisTemplate对象
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
// 设置连接工厂
redisTemplate.setConnectionFactory(connectionFactory);
// 设置Key的序列化
redisTemplate.setKeySerializer(RedisSerializer.string());
// 创建Json序列化工具
GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
// 设置Value的序列化
redisTemplate.setValueSerializer(jsonRedisSerializer);
return redisTemplate;
}
}
使用 QuickRedis 查看一下,发现键和值都变成我们熟悉的样子了
实现数据缓存
@GetMapping("/recommend")
public BaseResponse<Page<User>> recommendUsers(long pageSize, long pageNum, HttpServletRequest request){
// 从request中获取已登录用户信息
User loginUser = userService.getLoginUser(request);
// 构造Redis中存储推荐用户的key,其中包含了用户的ID
String redisKey = String.format("sys:user:recommend:%s",loginUser.getId());
// 获取Redis模板的ValueOperations对象,用于操作字符串类型的值
ValueOperations<String ,Object> valueOperations = redisTemplate.opsForValue();
// 尝试从Redis中获取缓存的推荐用户列表
Page<User> userPage = (Page<User>) valueOperations.get(redisKey);
// 如果Redis中存在缓存,则直接返回缓存中的推荐用户列表
if (userPage != null) {
return ResultUtils.success(userPage);
}
// 如果Redis中没有缓存,则查询数据库获取推荐用户列表
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
// 调用userService的page方法,传入分页参数和查询条件,获取推荐用户列表
userPage = userService.page(new Page<>(pageNum, pageSize), queryWrapper);
// 将获取到的推荐用户列表存入Redis中,并设置过期时间(这里为10000毫秒)
try {
valueOperations.set(redisKey, userPage, 10000, TimeUnit.MILLISECONDS);
} catch (Exception e) {
// 如果设置缓存时发生异常,记录错误日志
log.error("redis set key error", e);
}
// 返回查询到的推荐用户列表
return ResultUtils.success(userPage);
}
来自河南