SpringBoot AOP + Redis 延时双删功能实战

2023-10-23 21:15
文章标签 java 实战 springboot 功能 redis spring aop 延时 双删

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

一、业务场景

在多线程并发情况下，假设有两个数据库修改请求，为保证数据库与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依赖

<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-data-redis</artifactId>  
</dependency>  <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  
publicclassClearAndReloadCacheAspect{  @Autowired  
private StringRedisTemplate stringRedisTemplate;  */**  
* 切入点  
*切入点,基于注解实现的切入点  加上该注解的都是Aop切面的切入点  
*  
*/*  @Pointcut("@annotation(com.pdh.cache.ClearAndReloadCache)")  
publicvoidpointCut(){  }  
*/**  
* 环绕通知  
* 环绕通知非常强大，可以决定目标方法是否执行，什么时候执行，执行时是否需要替换方法参数，执行完毕是否需要替换返回值。  
* 环绕通知第一个参数必须是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();*//获取自定义注解的方法对象的参数即name*  Set<String> keys = stringRedisTemplate.keys("*" + name + "*");*//模糊定义key*  stringRedisTemplate.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: 8082  spring:  # redis setting  redis:  host: localhost  port: 6379  # cache setting  cache:  redis:  time-to-live: 60000 # 60s  datasource:  driver-class-name: com.mysql.cj.jdbc.Driver  
url: jdbc:mysql://localhost:3306/test  
username: root  
password: 1234  > 基于 SpringCloudAlibaba + Gateway + Nacos + RocketMQ + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能  
>  
> * 项目地址：<https://github.com/YunaiV/yudao-cloud>  
> * 视频教程：<https://doc.iocoder.cn/video/>  # mp setting  
mybatis-plus:  mapper-locations: classpath*:com/pdh/mapper/*.xml  global-config:  db-config:  table-prefix:  configuration:  # log of sql  log-impl: org.apache.ibatis.logging.stdout.StdOutImpl  # hump  map-underscore-to-camel-case: true  
`

4、user_db.sql脚本

用于生产测试数据

``DROP TABLE IF EXISTS `user_db`;  
CREATE TABLE `user_db`  (  `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_db  
-- ----------------------------  
INSERT INTO `user_db` VALUES (1, '张三');  
INSERT INTO `user_db` VALUES (2, '李四');  
INSERT INTO `user_db` VALUES (3, '王二');  
INSERT INTO `user_db` VALUES (4, '麻子');  
INSERT INTO `user_db` VALUES (5, '王三');  
INSERT INTO `user_db` VALUES (6, '李三');

``

5、UserController

/**  * 用户控制层  */*  
@RequestMapping("/user")  
@RestController  
public class UserController {  @Autowired  private 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 {  @Resource  private 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(888,"操作数据库失败");  }  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(888, "操作数据库失败");  }  public Result update(User user){  int i = userMapper.updateById(user);  if(i > 0)  return Result.success(i);  return Result.fail(888,"操作数据库失败");  }  
}

`

三、测试验证

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

图片

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

图片

3、第一次访问ID为10

图片

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

图片

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

图片

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

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

在这里插入图片描述

图片

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

图片

四、代码工程及地址

核心代码红色方框所示

❝

https://gitee.com/jike11231/redisDemo.git

❞

图片

https://mp.weixin.qq.com/s/VBr3E086U58PyQkNdFfNzg

这篇关于SpringBoot AOP + Redis 延时双删功能实战的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/270477。

相关文章

Java 正则表达式URL 匹配与源码全解析

Java 正则表达式URL 匹配与源码全解析

《Java正则表达式URL匹配与源码全解析》在Web应用开发中,我们经常需要对URL进行格式验证,今天我们结合Java的Pattern和Matcher类,深入理解正则表达式在实际应用中... 目录1.正则表达式分解：2. 添加域名匹配 (2)3. 添加路径和查询参数匹配 (3) 4. 最终优化版本5.设计思
阅读更多...
Java使用ANTLR4对Lua脚本语法校验详解

Java使用ANTLR4对Lua脚本语法校验详解

《Java使用ANTLR4对Lua脚本语法校验详解》ANTLR是一个强大的解析器生成器,用于读取、处理、执行或翻译结构化文本或二进制文件,下面就跟随小编一起看看Java如何使用ANTLR4对Lua脚本... 目录什么是ANTLR？第一个例子ANTLR4 的工作流程Lua脚本语法校验准备一个Lua Gramm
阅读更多...
Java字符串操作技巧之语法、示例与应用场景分析

Java字符串操作技巧之语法、示例与应用场景分析

《Java字符串操作技巧之语法、示例与应用场景分析》在Java算法题和日常开发中,字符串处理是必备的核心技能,本文全面梳理Java中字符串的常用操作语法,结合代码示例、应用场景和避坑指南,可快速掌握字... 目录引言1. 基础操作1.1 创建字符串1.2 获取长度1.3 访问字符2. 字符串处理2.1 子字
阅读更多...
Java Optional的使用技巧与最佳实践

Java Optional的使用技巧与最佳实践

《JavaOptional的使用技巧与最佳实践》在Java中,Optional是用于优雅处理null的容器类,其核心目标是显式提醒开发者处理空值场景,避免NullPointerExce... 目录一、Optional 的核心用途二、使用技巧与最佳实践三、常见误区与反模式四、替代方案与扩展五、总结在 Java
阅读更多...
基于Java实现回调监听工具类

基于Java实现回调监听工具类

《基于Java实现回调监听工具类》这篇文章主要为大家详细介绍了如何基于Java实现一个回调监听工具类,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录监听接口类 Listenable实际用法打印结果首先，会用到 函数式接口 Consumer, 通过这个可以解耦回调方法，下面先写一个
阅读更多...
使用Java将DOCX文档解析为Markdown文档的代码实现

使用Java将DOCX文档解析为Markdown文档的代码实现

《使用Java将DOCX文档解析为Markdown文档的代码实现》在现代文档处理中,Markdown（MD）因其简洁的语法和良好的可读性,逐渐成为开发者、技术写作者和内容创作者的首选格式,然而,许多文... 目录引言1. 工具和库介绍2. 安装依赖库3. 使用Apache POI解析DOCX文档4. 将解析
阅读更多...
Java字符串处理全解析(String、StringBuilder与StringBuffer)

Java字符串处理全解析(String、StringBuilder与StringBuffer)

《Java字符串处理全解析(String、StringBuilder与StringBuffer)》：本文主要介绍Java字符串处理全解析(String、StringBuilder与StringBu... 目录Java字符串处理全解析：String、StringBuilder与StringBuffer一、St
阅读更多...
springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法

springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法

《springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法》：本文主要介绍springboot整合阿里云百炼DeepSeek实现sse流式打印,本文给大家介绍的非常详细,对大... 目录1.开通阿里云百炼,获取到key2.新建SpringBoot项目3.工具类4.启动类5.测试类6.测
阅读更多...
Python列表去重的4种核心方法与实战指南详解

Python列表去重的4种核心方法与实战指南详解

《Python列表去重的4种核心方法与实战指南详解》在Python开发中,处理列表数据时经常需要去除重复元素,本文将详细介绍4种最实用的列表去重方法,有需要的小伙伴可以根据自己的需要进行选择... 目录方法1：集合(set)去重法（最快速）方法2：顺序遍历法（保持顺序）方法3：副本删除法（原地修改）方法4：
阅读更多...
Spring Boot循环依赖原理、解决方案与最佳实践(全解析)

Spring Boot循环依赖原理、解决方案与最佳实践(全解析)

《SpringBoot循环依赖原理、解决方案与最佳实践(全解析)》循环依赖指两个或多个Bean相互直接或间接引用,形成闭环依赖关系,：本文主要介绍SpringBoot循环依赖原理、解决方案与最... 目录一、循环依赖的本质与危害1.1 什么是循环依赖？1.2 核心危害二、Spring的三级缓存机制2.1 三
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2