缓存穿透讲解图

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-redis/artifactId/dependencydependencygroupIdorg.apache.commons/groupIdartifactIdcommons-pool2/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdscoperuntime/scopeversion5.1.47/version/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependencydependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-boot-starter/artifactIdversion3.4.3/version/dependency!--hutool--dependencygroupIdcn.hutool/groupIdartifactIdhutool-all/artifactIdversion5.7.17/version/dependency2.

public

addInterceptors(InterceptorRegistry

registry)

LoginInterceptor()).excludePathPatterns(/user/code,/user/login,/blog/hot,/shop/**,/shop-type/**,/voucher/**).order(2);registry.addInterceptor(new

RefreshTokenInterceptor(redis)).addPathPatterns(/**).order(1);}

---------------------------------------------

Slf4j

{//controller执行之前Overridepublic

boolean

{response.setStatus(401);return

false;}//7.放行return

true;}//渲染后返回给前台数据前Overridepublic

void

afterCompletion(HttpServletRequest

request,

{//移除用户避免内存泄露UserHolder.removeUser();}

---------------------------------------------------

Slf4j

{//这个对象不是由spring管理的所以不能用注解自动注入private

StringRedisTemplate

RefreshTokenInterceptor(StringRedisTemplate

redis)

redis;}//controller执行之前Overridepublic

boolean

request.getHeader(authorization);if

{return

true;}//2.基于token获取redis中的用户//通过key取到hash中的map集合数据MapObject,

Object

redis.opsForHash().entries(login:token:

(userMap.isEmpty())

true;}//5.将查询到的hash数据转为userDto对象UserDTO

userDTO

BeanUtil.fillBeanWithMap(userMap,

new

false);//6.存在保存用户信息到ThreadLocal中UserHolder.saveUser(userDTO);//7.刷新token有效期redis.expire(LOGIN_USER_KEY

token,

TimeUnit.MINUTES);log.info(我是第一个拦截器当前拦截所有请求的用户为线程为{},{},UserHolder.getUser(),Thread.currentThread());//8.放行return

true;}3.

商铺详情数据*/GetMapping(/{id})public

Result

Result.ok(shopService.queryShopById(id));}

}4.

redis.opsForValue().get(cache:shop:

(StrUtil.isNotBlank(shopCache))

{//3.存在直接返回Shop

Result.ok(shop);}//判断命中的是否是空值if

(shopCache!null)

解决缓存穿透redis.opsForValue().set(cache:shop:

id,,2,TimeUnit.MINUTES);//5.不存在返回错误return

Result.fail(当前商户不存在);}//6.存在写入redisredis.opsForValue().set(cache:shop:id,JSONUtil.toJsonStr(shop));redis.expire(cache:shop:id,30,TimeUnit.MINUTES);//7.返回return

Result.ok(shop);}