SpringBoot AOP Redis가 지연된 이중 삭제 기능을 구현하는 방법

1. 비즈니스 시나리오

다중 스레드 동시성의 경우 데이터베이스와 Redis 간의 데이터 일관성을 보장하기 위해 두 개의 데이터베이스 수정 요청이 있다고 가정합니다.
수정 요청 구현에는 계단식이 필요합니다. Redis의 데이터 수정 후 수정.
요청 1: A는 데이터베이스 데이터를 수정합니다. B는 Redis 데이터를 수정합니다.
요청 2: C는 데이터베이스 데이터를 수정합니다. D는 Redis 데이터를 수정합니다.
동시 상황에서는 A —>C —> ;> B
(스레드에서 동시에 실행되는 여러 세트의 원자 연산의 실행 순서가 겹칠 수 있음을 이해하십시오.)

1. 이때 문제

A가 데이터베이스 데이터를 수정하여 최종적으로 Redis에 저장했습니다. C도 A 데이터 이후에 데이터베이스를 수정했습니다.

이때, Redis의 데이터와 데이터베이스 데이터 사이에 불일치가 발생하여 후속 쿼리 과정에서 Redis를 오랜 시간 동안 먼저 확인하게 되어 쿼리된 데이터가 실제 데이터가 아닌 심각한 문제가 발생하게 됩니다. 데이터베이스에서.

2. 솔루션

Redis를 사용할 때 가장 인기 있는 솔루션 중 하나는 지연 이중 삭제 전략입니다.
참고: 이중 삭제 전략의 결과로 Redis에 저장된 데이터가 삭제되고 후속 쿼리가 데이터베이스에 쿼리되므로 자주 수정되는 데이터 테이블은 Redis 사용에 적합하지 않다는 점을 알아야 합니다. 따라서 Redis는 변경 사항보다 훨씬 더 많은 것을 읽는 데이터 캐시를 사용합니다.
지연된 이중 삭제 계획의 실행 단계

1> 캐시 삭제
2> 데이터베이스 업데이트
3> 지연 500밀리초(특정 비즈니스에 따라 지연 실행 시간 설정)
4> 지연 이유는 무엇입니까? 500밀리초?

  org.springframework.boot spring-boot-starter-data-redis    org.springframework.boot spring-boot-starter-aop 

로그인 후 복사

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

로그인 후 복사

@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 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 keys1 = stringRedisTemplate.keys("*" + name + "*");//模糊删除 stringRedisTemplate.delete(keys1); System.out.println("-----------1秒钟后，在线程中延迟删除完毕 -----------"); } catch (InterruptedException e) { e.printStackTrace(); } }).start(); return proceed;//返回业务代码的值 } }

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

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, '李三');

로그인 후 복사

/** * 用户控制层 */ @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); } }

/** * service层 */ @Service public class UserService { @Resource private UserMapper userMapper; public Result get(Integer id){ LambdaQueryWrapper 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 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,"操作数据库失败"); } }

로그인 후 복사

3 테스트 검증

중단점 만들기, 시뮬레이션 첫 번째 실행 스레드 삭제 후 A가 데이터베이스 업데이트를 완료하기 전에 다른 스레드 B가 ID=10에 액세스하여 이전 데이터를 읽습니다.

위 내용은 SpringBoot AOP Redis가 지연된 이중 삭제 기능을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!