Redis学习------实战篇----2024/02/28

1.集群的session共享问题

在这里插入图片描述

2.基于Redis实现共享session登录

在这里插入图片描述

//4.保存验证码到redisstringRedisTemplate.opsForValue().set(LOGIN_CODE_KEY+phone,code,LOGIN_CODE_TTL, TimeUnit.MINUTES);

RedisTemplate
RedisTemplate使用的是JdkSerializationRedisSerializer存入数据，会将数据先序列化成字节数组，然后在存入Redis数据库。

如果数据是复杂的对象类型，而取出的时候又不想做任何的数据转换，直接从Redis里面取出一个对象，那么使用RedisTemplate是更好的选择。

你会看到你的数据不是以可读的形式展现的，而是以字节数组显示

当然从Redis获取数据的时候，也会默认将数据当做字节数组转化，这样就会导致一个问题，当需要获取的数据，不是以字节数组存在redis当中，而是正常的可读的字符串的时候，

RedisTemplate就无法获取导数据，这个时候获取到的值就是NULL。这个时候StringRedisTempate就派上了用场。

StringRedisTemplate使用的是StringRedisSerializer，当你的redis数据库里面本来存的是字符串数据，或者你要存取的数据就是字符串类型数据的时候，那么你就使用StringRedisTemplate即可。

当redis中存入的数据是可读形式而非字节数组时，使用redisTemplate取值的时候会无法获取导出数据，获得的值为null。可以使用 StringRedisTemplate 试试。

文章来源

出现报错
java.lang.ClassCastException: class java.lang.Long cannot be cast to class java.lang.String (java.lang.Long and java.lang.String are in module java.base of loader ‘bootstrap’)
at org.springframework.data.redis.serializer.StringRedisSerializer.serialize(StringRedisSerializer.java:36) ~[spring-data-redis-2.3.9.RELEASE.jar:2.3.9.RELEASE]

在这里插入图片描述
原因是这个类的属性是Long,不是String类型

解决方法
Map<String, Object> userMap = BeanUtil.beanToMap(userDTO,
new HashMap<>(),
CopyOptions.create()
.setIgnoreNullValue(true)
.setFieldValueEditor((fieldName,fieldValue)->fieldValue.toString()));

在这里插入图片描述

这段代码是使用了 BeanUtil 类中的 beanToMap 方法将一个 userDTO 对象转换为一个 Map<String, Object> 类型的对象。在转换过程中，使用了 CopyOptions 类的 create 方法创建了一些配置选项，包括忽略空值和字段值编辑器。

在这里，setIgnoreNullValue(true) 表示忽略空值，即在转换过程中忽略掉值为 null 的属性；setFieldValueEditor((fieldName,fieldValue)->fieldValue.toString()) 则表示对字段值进行编辑，将字段值转换为字符串类型。

通过这段代码，可以将 userDTO 对象的属性值以键值对的形式存储到 userMap 中，且在此过程中满足了忽略空值和字段值编辑的需求。

登录后的数据存储
在这里插入图片描述

    /*** 短信验证码登录* @param loginForm* @param session* @return*/@Override
public Result login(LoginFormDTO loginForm, HttpSession session) {//1.校验手机号String phone = loginForm.getPhone();//2.如果不符合，返回错误信息if(RegexUtils.isPhoneInvalid(phone)){return Result.fail("手机号格式错误");}//3.校验验证码String cacheCode = stringRedisTemplate.opsForValue().get(LOGIN_CODE_KEY + phone);String code = loginForm.getCode();//4.不一致报错if(code==null || !cacheCode.toString().equals(code)){return Result.fail("验证码错误");}//5.根据手机号查询用户是否存在User user = query().eq("phone", phone).one();if (user == null) {//6.不存在，创建新用户user=createUserWithPhone(phone);}//7.保存用户到redis中//7.1随机生成token，作为登录令牌String token = UUID.randomUUID().toString(true);//7.2将User对象转换为Hash存储UserDTO userDTO = BeanUtil.copyProperties(user, UserDTO.class);Map<String, Object> userMap = BeanUtil.beanToMap(userDTO,new HashMap<>(),CopyOptions.create().setIgnoreNullValue(true).setFieldValueEditor((fieldName,fieldValue)->fieldValue.toString()));//7.3存储String tokenKey=LOGIN_USER_KEY+token;stringRedisTemplate.opsForHash().putAll(tokenKey,userMap);//7.4设置token有效期stringRedisTemplate.expire(tokenKey,LOGIN_USER_TTL,TimeUnit.MINUTES);//8.返回tokenreturn Result.ok(token);}

LoginInterceptor.java的代码

    private StringRedisTemplate stringRedisTemplate;public LoginInterceptor(StringRedisTemplate stringRedisTemplate) {this.stringRedisTemplate = stringRedisTemplate;}@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {//1. 获取请求头中的tokenString token = request.getHeader("authorization");if ( StrUtil.isBlank(token)) {response.setStatus(401);return false;}String key=RedisConstants.LOGIN_USER_KEY + token;//2. 基于token获取redis中的用户Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(key);//3.判断用户是否存在if(userMap.isEmpty()){//4.用户不存在进行拦截response.setStatus(401);return false;}//5.查询到的Hash数据转换为UserDto对象UserDTO userDTO = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);// 6.用户存在将用户信息保存到ThreadLocalUserHolder.saveUser((UserDTO) userDTO);//7. 刷新token的有效期stringRedisTemplate.expire(key,RedisConstants.LOGIN_USER_TTL, TimeUnit.MINUTES);//8.放行return HandlerInterceptor.super.preHandle(request, response, handler);}

在这里插入图片描述

3.登录拦截器的优化

在这里插入图片描述

public class RefreshTokenInterceptor implements HandlerInterceptor {private StringRedisTemplate stringRedisTemplate;public RefreshTokenInterceptor(StringRedisTemplate stringRedisTemplate) {this.stringRedisTemplate = stringRedisTemplate;}@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {//1. 获取请求头中的tokenString token = request.getHeader("authorization");if ( StrUtil.isBlank(token)) {return true;}String key=RedisConstants.LOGIN_USER_KEY + token;//2. 基于token获取redis中的用户Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(key);//3.判断用户是否存在if(userMap.isEmpty()){//4.用户不存在进行拦截return true;}//5.查询到的Hash数据转换为UserDto对象UserDTO userDTO = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);// 6.用户存在将用户信息保存到ThreadLocalUserHolder.saveUser(userDTO);//7. 刷新token的有效期stringRedisTemplate.expire(key,RedisConstants.LOGIN_USER_TTL, TimeUnit.MINUTES);//8.放行return HandlerInterceptor.super.preHandle(request, response, handler);}@Overridepublic void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {//移除用户UserHolder.removeUser();HandlerInterceptor.super.afterCompletion(request, response, handler, ex);}
}

public class LoginInterceptor implements HandlerInterceptor {@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {//1.判断是否需要拦截---ThreadLocal中是否有用户if(UserHolder.getUser()==null){response.setStatus(401);return false;}return true;}@Overridepublic void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {//移除用户UserHolder.removeUser();HandlerInterceptor.super.afterCompletion(request, response, handler, ex);}
}

4.商户查询缓存

在这里插入图片描述

5.添加Redis缓存

在这里插入图片描述

@Service
public class ShopServiceImpl extends ServiceImpl<ShopMapper, Shop> implements IShopService {@Resourceprivate StringRedisTemplate stringRedisTemplate;@Overridepublic Result queryById(Long id) {//1.从redis中查询缓存String key = CACHE_SHOP_KEY + id;String shopJson = stringRedisTemplate.opsForValue().get(key); //2.判断是否存在//3.存在则直接返回if (StrUtil.isNotBlank(shopJson)){Shop shop = JSONUtil.toBean(shopJson, Shop.class);return Result.ok(shop);}//4.不存在，根据ID查询数据库Shop shop = getById(id);//5.不存在，返回错误if (shop== null){return Result.fail("店铺不存在");}//6.存在，写入redisstringRedisTemplate.opsForValue().set(key,JSONUtil.toJsonStr(shop));//7.返回return Result.ok(shop);}
}

缓存商品列表

@Service
public class ShopTypeServiceImpl extends ServiceImpl<ShopTypeMapper, ShopType> implements IShopTypeService {@Resourceprivate StringRedisTemplate stringRedisTemplate;@Overridepublic Result queryList() {String key = CACHE_TYPE_LIST;String shopJson = stringRedisTemplate.opsForValue().get(key);//查询缓存中是否有数据if(StrUtil.isNotBlank(shopJson)){List<ShopType> shopTypeList = JSONUtil.toList(shopJson, ShopType.class);return Result.ok(shopTypeList);}List<ShopType> shopTypeList = query().orderByAsc("sort").list();//将数据库中的数据保存到缓存中stringRedisTemplate.opsForValue().set(key,JSONUtil.toJsonStr(shopTypeList));return Result.ok(shopTypeList);}
}

5.缓存更新策略

在这里插入图片描述

6.数据库和缓存的双写一致的实现

 @Override@Transactionalpublic Result update(Shop shop) {Long shopId = shop.getId();if (shopId==null){return Result.fail("查询的店铺不存在");}//1.更新数据库updateById(shop);//2.删除缓存stringRedisTemplate.delete(CACHE_SHOP_KEY + shopId);return null;}