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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/115691.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

谷歌真的不喜欢 Node.js ?

有人在 Quora 上提问&#xff0c;为什么谷歌不喜欢 Node.js 呢&#xff0c;Google 的 UX 工程师和来自 Node.js 团队的开发者分别回答了他们对这个问题的看法&#xff0c;对于编程语言来说&#xff0c;每一门语言都有它自己的优势&#xff0c;重要的是如何用它去解决问题。 谷…

VUE父组件向子组件传递数据和方法

文章目录 1 父组件写法2 子组件写法 1 父组件写法 父组件参数和方法 data() {return {// 遮罩层loading: true,// 表格数据yfeList: []}}导入组件 import yfTable from "/views/yf/yfTable.vue";组件 components: {yfTabTable},传值使用 <yfTabTable :loadin…

拥有自己的服务器是一件很不错的事情

在不同的语境中&#xff0c;“服务器”一词的含义也不尽相同。本文中谈到的服务器&#xff0c;指的是具体的物理机器&#xff08;而非服务器程序&#xff09;。与普通的个人计算机不同&#xff0c;服务器通常保持在线状态&#xff0c;通常用来执行一些不间断的程序或任务&#…

驱动开发LED灯绑定设备文件

头文件 #ifndef __HEAD_H__ #define __HEAD_H__typedef struct {unsigned int MODER;unsigned int OTYPER;unsigned int OSPEEDR;unsigned int PUPDR;unsigned int IDR;unsigned int ODR; }gpio_t;#define PHY_LED1_ADDR 0x50006000 #define PHY_LED2_ADDR 0x50007000 #defin…

【软考-中级】系统集成项目管理工程师-项目收尾管理历年案例

持续更新。。。。。。。。。。。。。。。 目录 2017 下 试题三(17分)背诵整理1. 项目总结会议一般讨论的内容2. 系统文档验收所涉及的文档都有哪些 系列文章 2017 下 试题三(17分) 阅读下列说明&#xff0c;回答问题 1至问题 4&#xff0c;将解答填入答题纸的对应栏内     …

大二第三周总结(算法+生活)

算法&#xff1a; 题目&#xff1a;有效的括号 这个题目也是做过很多回了。主要就是数据结构中”栈“的应用&#xff0c;先进后出。 解题思路&#xff1a; 1.创建 Map 哈希表形成键值对映射 2.进行遍历字符串 在遍历过程中 如果 遍历到的字符c 是左括号&#xff0c;则入栈 pu…

基于PHP的宠物爱好者交流平台管理系统设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09; 代码参考数据库参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作者&am…

Mysql第三篇---响应太慢?数据库卡顿?如何优化?

Mysql第三篇—响应太慢&#xff1f;数据库卡顿&#xff1f;如何优化&#xff1f; 统计SQL的查询成本&#xff1a;last_query_cost 一条SQL查询语句在执行前需要确定查询执行计划&#xff0c;如果存在多种执行计划的话&#xff0c;MySQL会计算每个执行计划所需要的成本&#x…

CDN+Nginx反向代理来隐藏c2地址

思路&#xff1a;通过借助CDN和Nginx反向代理和HTTPS来隐藏真实c2服务器Nginx反向代理&#xff1a;通过Nginx对外部流量转发到本地&#xff0c;再设置防火墙只允许localhost访问cs端口达到IP白名单的效果 准备 在这个实验环境中&#xff0c;我们需要准备服务器两台(一台服务端…

day4驱动开发

目的&#xff1a;通过字符设备驱动的分步实现编写LED驱动&#xff0c;另外实现特备文件和设备的绑定 驱动文件 &#xff1a; #include <linux/init.h> #include <linux/module.h> #include <linux/fs.h> #include <linux/device.h> #include <lin…

day40

今日内容概要 针对记录的SQL语句 配置文件的介绍 存储引擎的使用(存储的方式) 数据类型(重点) 整型 浮点型 字符串 日期 枚举 针对记录的sql语句 针对库的增删改查&#xff08;文件夹&#xff09; 1.创建库 create databases db1; # 设置库的默认编码 create databa…

illuminate/database 使用 一

illuminate/database 是完整的php数据库工具包&#xff0c;即ORM&#xff08;Object-Relational Mapping&#xff09;类库。 提供丰富的查询构造器&#xff0c;和多个驱动的服务。作为Laravel的数据库层使用&#xff0c;也可以单独使用。 一 使用 加载composer之后&#xff…

自然语言处理---迁移学习

fasttext介绍 作为NLP工程领域常用的工具包&#xff0c;fasttext有两大作用&#xff1a;进行文本分类、训练词向量。在保持较高精度的情况下&#xff0c;快速的进行训练和预测是fasttext的最大优势。fasttext优势的原因: fasttext工具包中内含的fasttext模型具有十分简单的网络…

01-React入门

React概述 react是什么&#xff1f; React用于构建用户界面的JS库。是一个将数据渲染为HTML视图的开源JS库。 为什么学&#xff1f; 1.原生JS操作DOM繁琐&#xff0c;效率低 2.使用JS直接操作DOM,浏览器会进行大量的重绘重排 3.原生JS没有组件化编码方案&#xff0c;代码…

2024 王道考研-数据结构

第二章 线性表算法题(线性表的顺序表示) 二、综合应用题 01.从顺序表中删除具有最小值的元素(假设唯一)并由函数返回被删元素的值。空出的位 置由最后一个元素填补&#xff0c;若顺序表为空&#xff0c;则显示出错信息并退出运行。 算法思想&#xff1a;搜索整个顺序表&#xf…

Python之PyMySQL操作详解

一、PyMysql简介 PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库&#xff0c;Python2中则使用mysqldb。 Django中也可以使用PyMySQL连接MySQL数据库。 二、PyMySQL操作详解 2.1 PyMySQL安装 pip install pymysql2.2 PyMySQL应用 2.2.1 基本使用 # codingut…

【Leetcode】 213. 打家劫舍 II ?

你是一个专业的小偷&#xff0c;计划偷窃沿街的房屋&#xff0c;每间房内都藏有一定的现金。这个地方所有的房屋都围成一圈&#xff0c;这意味着第一个房屋和最后一个房屋是紧挨着的。同时&#xff0c;相邻的房屋装有相互连通的防盗系统&#xff0c;如果两间相邻的房屋在同一晚…

sql server2014如何添加多个实例 | 以及如何删除多个实例中的单个实例

标题sql server2014如何添加多个实例 前提&#xff08;已安装sql server2014 且已有默认实例MSSQLSERVER&#xff09; 添加新的实例 其实就是根据安装步骤再安装一次&#xff08;区别在过程中说明&#xff09; 双击安装 选择“全新独立安装或添加现有功能” 然后下一步下一…

Apache Shiro 1.2.4反序列化漏洞(CVE-2016-4437)

介绍 Apache Shiro是一款开源安全框架&#xff0c;提供身份验证、授权、密码学和会话管理。Shiro框架直观、易用&#xff0c;同时也能提供健壮的安全性。 版本 Apache Shiro 1.2.4及以前版本中 原理 不安全的配置 默认账户在里面 Apache Shiro 1.2.4及以前版本中&#x…

C++学习之强制类型转换

强制类型转换运算符 带着三个疑问阅读&#xff1a; 出现的背景是什么&#xff1f;何时使用&#xff1f;如何使用&#xff1f; MSDN . 强制转换运算符 C中的四种强制类型转换符详解 static_cast (1) 使用场景 在基本数据类型之间转换&#xff0c;如把 int 转换为 char&#…