实战解析:SpringBoot AOP与Redis结合实现延时双删功能

本文主要是介绍实战解析:SpringBoot AOP与Redis结合实现延时双删功能,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

一、业务场景

1、此时存在的问题

2、解决方案

3、为何要延时500毫秒?

4、为何要两次删除缓存?

二、代码实践

1、引入Redis和SpringBoot AOP依赖

2、编写自定义aop注解和切面

3、application.yml

4、user.sql脚本

5、UserController

6、UserService

三、测试验证

1、ID=10,新增一条数据

2、第一次查询数据库,Redis会保存查询结果

3、第一次访问ID为10

4、第一次访问数据库ID为10,将结果存入Redis

5、更新ID为10对应的用户名(验证数据库和缓存不一致方案)

6、采用第二次删除


一、业务场景

在多线程并发情况下,假设有两个数据库修改请求,为保证数据库与redis的数据一致性,修改请求的实现中需要修改数据库后,级联修改Redis中的数据。

  • 请求一:A修改数据库数据 B修改Redis数据

  • 请求二:C修改数据库数据 D修改Redis数据

并发情况下就会存在A —> C —> D —> B的情况

一定要理解线程并发执行多组原子操作执行顺序是可能存在交叉现象的

1、此时存在的问题

A修改数据库的数据最终保存到了Redis中,C在A之后也修改了数据库数据。

此时出现了Redis中数据和数据库数据不一致的情况,在后面的查询过程中就会长时间去先查Redis, 从而出现查询到的数据并不是数据库中的真实数据的严重问题。

2、解决方案

在使用Redis时,需要保持Redis和数据库数据的一致性,最流行的解决方案之一就是延时双删策略。

注意:要知道经常修改的数据表不适合使用Redis,因为双删策略执行的结果是把Redis中保存的那条数据删除了,以后的查询就都会去查询数据库。所以Redis使用的是读远远大于改的数据缓存。

延时双删方案执行步骤

  1. 删除缓存

  2. 更新数据库

  3. 延时500毫秒 (根据具体业务设置延时执行的时间)

  4. 删除缓存

3、为何要延时500毫秒?

这是为了我们在第二次删除Redis之前能完成数据库的更新操作。假象一下,如果没有第三步操作时,有很大概率,在两次删除Redis操作执行完毕之后,数据库的数据还没有更新,此时若有请求访问数据,便会出现我们一开始提到的那个问题。

4、为何要两次删除缓存?

如果我们没有第二次删除操作,此时有请求访问数据,有可能是访问的之前未做修改的Redis数据,删除操作执行后,Redis为空,有请求进来时,便会去访问数据库,此时数据库中的数据已是更新后的数据,保证了数据的一致性。

二、代码实践

1、引入Redis和SpringBoot AOP依赖

<!-- redis使用 -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- aop -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId>
</dependency>

2、编写自定义aop注解和切面

ClearAndReloadCache延时双删注解

/***延时双删**/
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Target(ElementType.METHOD)
public @interface ClearAndReloadCache {String name() default "";
}

ClearAndReloadCacheAspect延时双删切面

@Aspect
@Component
public class ClearAndReloadCacheAspect {@Autowired
private StringRedisTemplate stringRedisTemplate;/**
* 切入点
*切入点,基于注解实现的切入点  加上该注解的都是Aop切面的切入点
*
*/@Pointcut("@annotation(com.pdh.cache.ClearAndReloadCache)")
public void pointCut(){}
/**
* 环绕通知
* 环绕通知非常强大,可以决定目标方法是否执行,什么时候执行,执行时是否需要替换方法参数,执行完毕是否需要替换返回值。
* 环绕通知第一个参数必须是org.aspectj.lang.ProceedingJoinPoint类型
* @param proceedingJoinPoint
*/
@Around("pointCut()")
public Object aroundAdvice(ProceedingJoinPoint proceedingJoinPoint){System.out.println("----------- 环绕通知 -----------");System.out.println("环绕通知的目标方法名:" + proceedingJoinPoint.getSignature().getName());Signature signature1 = proceedingJoinPoint.getSignature();MethodSignature methodSignature = (MethodSignature)signature1;Method targetMethod = methodSignature.getMethod();//方法对象ClearAndReloadCache annotation = targetMethod.getAnnotation(ClearAndReloadCache.class);//反射得到自定义注解的方法对象String name = annotation.name();//获取自定义注解的方法对象的参数即nameSet<String> keys = stringRedisTemplate.keys("*" + name + "*");//模糊定义keystringRedisTemplate.delete(keys);//模糊删除redis的key值//执行加入双删注解的改动数据库的业务 即controller中的方法业务Object proceed = null;try {proceed = proceedingJoinPoint.proceed();} catch (Throwable throwable) {throwable.printStackTrace();}//开一个线程 延迟1秒(此处是1秒举例,可以改成自己的业务)// 在线程中延迟删除  同时将业务代码的结果返回 这样不影响业务代码的执行new Thread(() -> {try {Thread.sleep(1000);Set<String> keys1 = stringRedisTemplate.keys("*" + name + "*");//模糊删除stringRedisTemplate.delete(keys1);System.out.println("-----------1秒钟后,在线程中延迟删除完毕 -----------");} catch (InterruptedException e) {e.printStackTrace();}}).start();return proceed;//返回业务代码的值}
}

3、application.yml

server:port: 8082spring:# redis settingredis:host: localhostport: 6379# cache settingcache:redis:time-to-live: 60000 # 60sdatasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/testusername: rootpassword: 1234# mp setting
mybatis-plus:mapper-locations: classpath*:com/pdh/mapper/*.xmlglobal-config:db-config:table-prefix:configuration:# log of sqllog-impl: org.apache.ibatis.logging.stdout.StdOutImpl# humpmap-underscore-to-camel-case: true

4、user.sql脚本

用于生产测试数据

DROP TABLE IF EXISTS `user`;
CREATE TABLE `user`  (`id` int(4) NOT NULL AUTO_INCREMENT,`username` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 8 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO `user` VALUES (1, '张三');
INSERT INTO `user` VALUES (2, '李四');
INSERT INTO `user` VALUES (3, '王二');
INSERT INTO `user` VALUES (4, '麻子');
INSERT INTO `user` VALUES (5, '王三');
INSERT INTO `user` VALUES (6, '李三');

5、UserController

/*** 用户控制层*/
@RequestMapping("/user")
@RestController
public class UserController {@Autowiredprivate UserService userService;@GetMapping("/get/{id}")@Cache(name = "get method")//@Cacheable(cacheNames = {"get"})public Result get(@PathVariable("id") Integer id){return userService.get(id);}@PostMapping("/updateData")@ClearAndReloadCache(name = "get method")public Result updateData(@RequestBody User user){return userService.update(user);}@PostMapping("/insert")public Result insert(@RequestBody User user){return userService.insert(user);}@DeleteMapping("/delete/{id}")public Result delete(@PathVariable("id") Integer id){return userService.delete(id);}
}

6、UserService

/*** service层*/
@Service
public class UserService {@Resourceprivate UserMapper userMapper;public Result get(Integer id){LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();wrapper.eq(User::getId,id);User user = userMapper.selectOne(wrapper);return Result.success(user);}public Result insert(User user){int line = userMapper.insert(user);if(line > 0)return Result.success(line);return Result.fail(3001,"操作数据库失败");}public Result delete(Integer id) {LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();wrapper.eq(User::getId, id);int line = userMapper.delete(wrapper);if (line > 0)return Result.success(line);return Result.fail(3001, "操作数据库失败");}public Result update(User user){int i = userMapper.updateById(user);if(i > 0)return Result.success(i);return Result.fail(3001,"操作数据库失败");}
}

三、测试验证

1、ID=10,新增一条数据

2、第一次查询数据库,Redis会保存查询结果

3、第一次访问ID为10

4、第一次访问数据库ID为10,将结果存入Redis

5、更新ID为10对应的用户名(验证数据库和缓存不一致方案)

数据库和缓存不一致验证方案:

打个断点,模拟A线程执行第一次删除后,在A更新数据库完成之前,另外一个线程B访问ID=10,读取的还是旧数据。

6、采用第二次删除

根据业务场景设置延时时间,两次删除缓存成功后,Redis结果为空。读取的都是数据库真实数据,不会出现读缓存和数据库不一致情况。

这篇关于实战解析:SpringBoot AOP与Redis结合实现延时双删功能的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/899836

相关文章

Java反转字符串的五种方法总结

《Java反转字符串的五种方法总结》:本文主要介绍五种在Java中反转字符串的方法,包括使用StringBuilder的reverse()方法、字符数组、自定义StringBuilder方法、直接... 目录前言方法一:使用StringBuilder的reverse()方法方法二:使用字符数组方法三:使用自

Qt把文件夹从A移动到B的实现示例

《Qt把文件夹从A移动到B的实现示例》本文主要介绍了Qt把文件夹从A移动到B的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学... 目录如何移动一个文件? 如何移动文件夹(包含里面的全部内容):如何删除文件夹:QT 文件复制,移动(

Flask 验证码自动生成的实现示例

《Flask验证码自动生成的实现示例》本文主要介绍了Flask验证码自动生成的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习... 目录生成图片以及结果处理验证码蓝图html页面展示想必验证码大家都有所了解,但是可以自己定义图片验证码

VSCode配置Anaconda Python环境的实现

《VSCode配置AnacondaPython环境的实现》VisualStudioCode中可以使用Anaconda环境进行Python开发,本文主要介绍了VSCode配置AnacondaPytho... 目录前言一、安装 Visual Studio Code 和 Anaconda二、创建或激活 conda

使用mvn deploy命令上传jar包的实现

《使用mvndeploy命令上传jar包的实现》本文介绍了使用mvndeploy:deploy-file命令将本地仓库中的JAR包重新发布到Maven私服,文中通过示例代码介绍的非常详细,对大家的学... 目录一、背景二、环境三、配置nexus上传账号四、执行deploy命令上传包1. 首先需要把本地仓中要

JAVA封装多线程实现的方式及原理

《JAVA封装多线程实现的方式及原理》:本文主要介绍Java中封装多线程的原理和常见方式,通过封装可以简化多线程的使用,提高安全性,并增强代码的可维护性和可扩展性,需要的朋友可以参考下... 目录前言一、封装的目标二、常见的封装方式及原理总结前言在 Java 中,封装多线程的原理主要围绕着将多线程相关的操

MySQL中实现多表查询的操作方法(配sql+实操图+案例巩固 通俗易懂版)

《MySQL中实现多表查询的操作方法(配sql+实操图+案例巩固通俗易懂版)》本文主要讲解了MySQL中的多表查询,包括子查询、笛卡尔积、自连接、多表查询的实现方法以及多列子查询等,通过实际例子和操... 目录复合查询1. 回顾查询基本操作group by 分组having1. 显示部门号为10的部门名,员

Java进阶学习之如何开启远程调式

《Java进阶学习之如何开启远程调式》Java开发中的远程调试是一项至关重要的技能,特别是在处理生产环境的问题或者协作开发时,:本文主要介绍Java进阶学习之如何开启远程调式的相关资料,需要的朋友... 目录概述Java远程调试的开启与底层原理开启Java远程调试底层原理JVM参数总结&nbsMbKKXJx

Spring Cloud之注册中心Nacos的使用详解

《SpringCloud之注册中心Nacos的使用详解》本文介绍SpringCloudAlibaba中的Nacos组件,对比了Nacos与Eureka的区别,展示了如何在项目中引入SpringClo... 目录Naacos服务注册/服务发现引⼊Spring Cloud Alibaba依赖引入Naco编程s依

java导出pdf文件的详细实现方法

《java导出pdf文件的详细实现方法》:本文主要介绍java导出pdf文件的详细实现方法,包括制作模板、获取中文字体文件、实现后端服务以及前端发起请求并生成下载链接,需要的朋友可以参考下... 目录使用注意点包含内容1、制作pdf模板2、获取pdf导出中文需要的文件3、实现4、前端发起请求并生成下载链接使