首页 > 数据库 >SpringBoot AOP + Redis 延时双删功能实战

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

时间：2023-11-09 09:44:05浏览次数：40  
标签：SpringBoot 双删 数据库 Redis id Result public user

一、业务场景

在多线程并发情况下，假设有两个数据库修改请求，为保证数据库与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操作执行完毕之后，数据库的数据还没有更新，此时若有请求访问数据，便会出现我们一开始提到的那个问题。

插播一条：如果你近期准备面试跳槽，建议在ddkk.com在线刷题，涵盖 一万+ 道 Java 面试题，几乎覆盖了所有主流技术面试题，还有市面上最全的技术五百套，精品系列教程，免费提供。

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();//获取自定义注解的方法对象的参数即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

# 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，新增一条数据

image

2、第一次查询数据库，Redis会保存查询结果![图片]

image

3、第一次访问ID为10

image

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

image

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

image

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

插播一条：如果你近期准备面试跳槽，建议在ddkk.com在线刷题，涵盖 一万+ 道 Java 面试题，几乎覆盖了所有主流技术面试题，还有市面上最全的技术五百套，精品系列教程，免费提供。
image

image

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

image

四、代码工程及地址

核心代码红色方框所示
下载地址
image

标签：SpringBoot,双删,数据库,Redis,id,Result,public,user
From： https://www.cnblogs.com/hefeng2014/p/17819030.html

相关文章

  • Redis 哨兵模式的原理及其搭建
    1.Redis哨兵Redis提供了哨兵（Sentinel）机制来实现主从集群的自动故障恢复。1.1.哨兵原理1.1.1.集群结构和作用哨兵的结构如图：哨兵的作用如下：监控：Sentinel会不断检查您的master和slave是否按预期工作。自动故障恢复：如果master故障，Sentinel会将一个slave提升为master。当......
  • Redis系列之常见数据类型应用场景
    目录String简单介绍常见命令应用场景Hash简单介绍常见命令应用场景List简单介绍常见命令应用场景Set简单介绍常见命令应用场景SortedSet(Zset)简单介绍常见命令应用场景Bitmap简单介绍常见命令应用场景附录Redis支持多种数据类型，比如String、hash、list、Set、SortedSet、Stream......
  • Redis哨兵集群
    ●slave节点宕机恢复后可以找master节点同步数据,那master节点宕机怎么办?哨兵的作用Redis提供了哨兵(Sentinel)机制来实现主从集群的自动故障恢复。哨兵的结构和作用如下:●监控:Sentinel会不断检查您的master和slave是否按预期工作自动故障恢复:如果master故障，Sentinel会将一个......
  • Spring Data Redis使用方式
    SpringBoot提供了对应的Starter，maven坐标：<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>SpringDataRedis中提供了一个高度封装的类：RedisTemplate，对相关api进行了......
  • springboot2 springboot 的引导类
    SpringBoot工程提供引导类用来启动程序，SpringBoot工程启动后创建并初始化Spring容器 packagecom.itheima;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.context......
  • springboot中部分数据的封装方法
    //响应字符串格式数据@RequestMapping("/hello")publicResulthello(){System.out.println("HelloWorld");//returnnewResult(1,"success","HelloWorld");returnResult.success("HelloWorl......
  • springboot的数据统一返回类Result
    /***统一响应结果封装类*/publicclassResult{privateIntegercode;//1成功,0失败privateStringmsg;//提示信息privateObjectdata;//数据datepublicResult(){}publicResult(Integercode,Stringmsg,Objectdata){......
  • springboot“共享书角”图书借还管理系统-计算机毕业设计源码+LW文档
    摘 要随着社会的发展，图书借还的管理形势越来越严峻。越来越多的借阅者利用互联网获得信息，但图书借还信息量大。为了方便借阅者更好的获得本图书借还信息，因此，设计一种安全高效的“共享书角”图书借还管理系统极为重要。为设计一个安全便捷，并且使借阅者更好获取本图书借还信息，本......
  • Springboot整合RabbitMQ值Direct交换机
    常用的交换机有以下三种，因为消费者是从队列获取信息的，队列是绑定交换机的（一般），所以对应的消息推送/接收模式也会有以下几种：DirectExchange 直连型交换机，根据消息携带的路由键将消息投递给对应队列。大致流程，有一个队列绑定到一个直连交换机上，同时赋予一个路由键routingkey......
  • Redis使用场景
    核心知识点：1.Redis可以做什么：缓存、排行榜、消息队列、计数器和社交网络。2.Redis不适合做什么：不适合大数据规模的存储和冷数据的存储。 一、Redis可以做什么1.缓存缓存机制几乎在所有的大型网站都有使用，合理地使用缓存不仅可以加快数据的访问速度，而且能够有效地降低后端数据源地......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99