场景

若依前后端分离版本地搭建开发环境并运行项目的教程：

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/108465662

基于上面搭建起来前后端分离的Vue+SpringBoot的项目。

其中数据库使用的是Mysql,缓存层用的是Redis。

数据库中某个表存储的信息，在业务代码比如定时任务中，需要频繁的查询。

所以将表中的数据存储到redis中一份。

其原理是，在调用查询方法时，判断redis中是否已经有，如果有则优先从redis中查询。

如果没有则在数据库中查询后并存入到Redis中一份，并给其设置过期时间。

这样在过期时间之内，查询数据会从redis中查询，过期之后会重新从Mysql中查询并存入到Redis一份。

并且还要实现，再对这个Mysql表进行新增、编辑、删除的操作时，将redis中存储的数据

进行删除，这样下次查询就会查询数据库中最新的。

注：

博客：
https://blog.csdn.net/badao_liumang_qizhi
关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。

实现

首先在Mysql中新建一个表bus_student

然后基于此表使用代码生成，前端Vue与后台各层代码生成并添加菜单。

然后来到后台代码中，在后台框架中已经添加了操作redis的相关依赖和工具类。

但是这里还需要添加aspect依赖

        <!-- https://mvnrepository.com/artifact/org.springframework/spring-aspects --><dependency><groupId>org.springframework</groupId><artifactId>spring-aspects</artifactId><version>4.3.14.RELEASE</version></dependency>

然后在存放配置类的地方新建新增redis缓存的注解

package com.ruoyi.system.redisAop;import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/** @Author* @Description 新增redis缓存**/
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface AopCacheEnable {//redis缓存keyString[] key();//redis缓存存活时间默认值（可自定义）long expireTime() default 3600;}

以及删除redis缓存的注解

package com.ruoyi.system.redisAop;import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/** @Description 删除redis缓存注解**/
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface AopCacheEvict {//redis中的key值String[] key();
}

然后再新建一个自定义缓存切面具体实现类CacheEnableAspect

存放位置

package com.ruoyi.system.redisAop;import com.ruoyi.system.domain.BusStudent;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;/** @Description 自定义缓存切面具体实现类**/
@Aspect
@Component
public class CacheEnableAspect {@Autowiredpublic RedisTemplate redisCache;/*** Mapper层切点 使用到了我们定义的 AopCacheEnable 作为切点表达式。*/@Pointcut("@annotation(com.ruoyi.system.redisAop.AopCacheEnable)")public void queryCache() {}/*** Mapper层切点 使用到了我们定义的 AopCacheEvict 作为切点表达式。*/@Pointcut("@annotation(com.ruoyi.system.redisAop.AopCacheEvict)")public void ClearCache() {}@Around("queryCache()")public Object Interceptor(ProceedingJoinPoint pjp) {Object result = null;//注解中是否有#标识boolean spelFlg = false;//判断是否需要走数据库查询boolean selectDb = false;//redis中缓存的keyString redisKey = "";//获取当前被切注解的方法名Method method = getMethod(pjp);//获取当前被切方法的注解AopCacheEnable aopCacheEnable = method.getAnnotation(AopCacheEnable.class);//获取方法参数值Object[] arguments = pjp.getArgs();//从注解中获取字符串String[] spels = aopCacheEnable.key();for (String spe1l : spels) {if (spe1l.contains("#")) {//注解中包含#标识，则需要拼接spel字符串,返回redis的存储redisKeyredisKey = spe1l.substring(1) + arguments[0].toString();} else {//没有参数或者参数是List的方法，在缓存中的keyredisKey = spe1l;}//取出缓存中的数据result = redisCache.opsForValue().get(redisKey);//缓存是空的，则需要重新查询数据库if (result == null || selectDb) {try {result =  pjp.proceed();//从数据库查询到的结果不是空的if (result != null && result instanceof ArrayList) {//将redis中缓存的结果转换成对象listList<BusStudent> students = (List<BusStudent>) result;//判断方法里面的参数是不是BusStudentif (arguments[0] instanceof BusStudent) {//将rediskey-students 存入到redisredisCache.opsForValue().set(redisKey, students, aopCacheEnable.expireTime(), TimeUnit.SECONDS);}}} catch (Throwable e) {e.printStackTrace();}}}return result;}/*** 定义清除缓存逻辑，先操作数据库，后清除缓存*/@Around(value = "ClearCache()")public Object evict(ProceedingJoinPoint pjp) throws Throwable {//redis中缓存的keyMethod method = getMethod(pjp);// 获取方法的注解AopCacheEvict cacheEvict = method.getAnnotation(AopCacheEvict.class);//先操作dbObject result = pjp.proceed();// 获取注解的key值String[] fieldKeys = cacheEvict.key();for (String spe1l : fieldKeys) {//根据key从缓存中删除redisCache.delete(spe1l);}return result;}/*** 获取被拦截方法对象*/public Method getMethod(ProceedingJoinPoint pjp) {Signature signature = pjp.getSignature();MethodSignature methodSignature = (MethodSignature) signature;Method targetMethod = methodSignature.getMethod();return targetMethod;}
}

注意这里的queryCache和ClearCache,里面切点表达式

分别对应上面自定义的两个AopCacheEnable和AopCacheEvict。

然后在环绕通知的queryCache方法执行前后时

获取被切方法的参数，参数中的key，然后根据key去redis中去查询，

如果查不到，就把方法的返回结果转换成对象List，并存入到redis中，

如果能查到，则将结果返回。

然后找到这个表的查询方法，mapper层，比如要将查询的返回结果存储进redis

    @AopCacheEnable(key = "BusStudent",expireTime = 40)public List<BusStudent> selectBusStudentList(BusStudent busStudent);

然后在这个表的新增、编辑、删除的mapper方法上添加

    /*** 新增学生** @param busStudent 学生* @return 结果*/@AopCacheEvict(key = "BusStudent")public int insertBusStudent(BusStudent busStudent);/*** 修改学生** @param busStudent 学生* @return 结果*/@AopCacheEvict(key = "BusStudent")public int updateBusStudent(BusStudent busStudent);/*** 删除学生** @param id 学生ID* @return 结果*/@AopCacheEvict(key = "BusStudent")public int deleteBusStudentById(Integer id);

注意这里的注解上的key要和上面的查询的注解的key一致。

然后启动项目，如果启动时提示:

Consider marking one of the beans as @Primary, updating the consumer to acce

因为sringboot通过@Autowired注入接口的实现类时发现有多个，也就是有多个类继承了这个接口，spring容器不知道使用哪一个。

找到redis的配置类，在RedisTemplate上添加@Primary注解

验证注解的使用

debug启动项目，在CacheEnableAspect中查询注解中打断点，然后调用查询方法，

就可以看到能进断点，然后就可以根据自己想要的逻辑和效果进行修改注解。

第一次查询时redis中是没有的，所以会走mysql查询，在过期时间之内就不再查询mysq，而是查询redis了。

然后再调用新增、编辑、删除接口时会将redis中缓存的数据删掉。

但是使用若依这套框架，在新增、编辑、删除操作后会调用查询接口，所以会直接又存储进来。

所以可以用postman等接口测试工具测试。

然后就是当操作完之后如果redis中的数据还没过期，前端页面查询的仍然是redis中的数据，不是最新数据。

所以redis中过期的时间自己把握。

另外此种缓存机制，建议不要和前端请求的mapper进行混用。

建议自定义新的mapper只取用需要的数据，然后给其他比如高频率的定时任务查询用。

SpringBoot中通过自定义缓存注解(AOP切面拦截)实现数据库数据缓存到Redis相关推荐

Springboot整合多数据源（自定义注解+aop切面实现）
原理: 通过后台配置多个数据源,自定义注解,通过aop配置注解切面,前端调用需要传递数据源参数,根据判断数据源参数,调用相应的service或mapper方法. 实现: 准备俩个数据库:俩张表表sq ...
spring boot之自定义的注解的切面编程
springBoot目录 1. 前言在上一章中我们知道了,注解的本质其实就是一个标签.但是我们可以通过反射或其他方式从注解的宿主对象上获取到注解对象信息,这就让注解的可玩性变得很强.可以通过注解来描 ...
springboot+mybatis集成自定义缓存ehcache用法笔记
今天小编给大家整理了springboot+mybatis集成自定义缓存ehcache用法笔记,希望对大家能有所办帮助! 一.ehcache介绍 EhCache 是一个纯Java的进程内缓存管理框架,属 ...
java 获取自定义参数类型_Springboot中使用自定义参数注解获取 token 中用户数据...
使用自定义参数注解获取 token 中User数据使用背景在springboot项目开发中需要从token中获取用户信息时通常的方式要经历几个步骤拦截器中截获token TokenUtil工具类 ...
Spring Boot自定义缓存注解
自定义缓存注解使用:
springboot中mongodb自定义类型转换器
文章目录 1 场景 1.1 BigDecimal写入mongo 1.2 人工转换 1.3 自定义转换器 2 版本 3 步骤 3.1 定义转换器 3.2 配置mongoDb工厂类 3.3 加载自定义转换 ...
日志管理（spring AOP切面拦截）
**最近,在写日志管理的东西呢,用了几种方法试,还是拦截比较好用,直接截下来传入到数据库中存储. 写的时候,真是头疼啊. 哦~对了,忘了说了,不需要用到Dao层哦. 首先,来一个POJO实体类吧,我看 ...
SpringBoot中利用自定义注解优雅地实现隐私数据脱敏（加密显示）
前言这两天在整改等保测出的问题,里面有一个"用户信息泄露"的风险项(就是后台系统里用户的一些隐私数据直接明文显示了),其实指的就是要做数据脱敏. 数据脱敏:把系统里的一些敏感数据 ...
springboot中得注解_Spring以及SpringBoot中的常用的注解小结
一.注解的基本概念 Annotation(注解)就是Java提供了一种元程序中的元素关联任何信息和着任何元数据(metadata)的途径和方法.Annotion(注解)是一个接口,程序可以通过反射来获 ...

SpringBoot中通过自定义缓存注解(AOP切面拦截)实现数据库数据缓存到Redis

场景

实现

SpringBoot中通过自定义缓存注解(AOP切面拦截)实现数据库数据缓存到Redis相关推荐

最新文章

热门文章