SpringBoot AOP Redis が遅延二重削除機能を実装する方法-Redis-php.cn

1. ビジネスシナリオ

マルチスレッド同時実行の場合、データベース変更リクエストが 2 つあると仮定し、それらの間のデータの整合性を確保します。データベースと Redis、
変更リクエストの実装では、データベースを変更した後、Redis 内のデータをカスケード変更する必要があります。
リクエスト 1: A はデータベースデータを変更します B は Redis データを変更します
リクエスト 2: C はデータベースデータを変更します D は Redis データを変更します
同時状況では、A —> C &mdash が発生します;> D — > 状況 B
(スレッドによる複数のアトミック操作の同時実行の順序は重複する可能性があることを必ず理解してください)

1. 現時点での問題点

A データベースを変更する最終的にデータは Redis に保存され、A の後に C もデータベースのデータを変更しました。

現時点では、Redis 内のデータとデータベースのデータの間に不整合が発生しています。その後のクエリ処理では、最初に Redis が長時間チェックされることになり、その結果、クエリされたデータは、データベースのデータと一致しません。データベース内の実際のデータについての質問です。

2. 解決策

Redis を使用する場合、Redis とデータベースデータの一貫性を維持する必要があります。最も一般的な解決策の 1 つは、遅延二重削除戦略です。
注: 頻繁に変更されるデータテーブルは Redis の使用には適していないことを知っておく必要があります。これは、二重削除戦略の結果、Redis に保存されているデータが削除され、後続のクエリでデータベースがクエリされるためです。したがって、Redis は、変更よりもはるかに読み取りの多いデータキャッシュを使用します。
遅延二重削除スキームの実行手順

1> キャッシュの削除
2> データベースの更新
3> 500 ミリ秒の遅延 (特定のビジネスに応じて遅延実行時間を設定します)
4> キャッシュの削除

3. 500 ミリ秒の遅延があるのはなぜですか?

2 回目の Redis 削除の前に、データベースの更新操作を完了する必要があります。 3 番目のステップがない場合、Redis の 2 つの削除操作が完了した後、データベース内のデータが更新されていない可能性が高いと仮定します。この時点でデータへのアクセス要求がある場合、問題は発生します。冒頭で述べたような質問が表示されます。

4. キャッシュを 2 回削除する必要があるのはなぜですか?

2 回目の削除操作がなく、この時点でデータへのアクセス要求がある場合、それは以前に変更されていない Redis データである可能性があります。削除操作の実行後、Redis はリクエストが来るとデータベースにアクセスしますが、このときデータベース内のデータは更新されたデータとなり、データの整合性が保たれます。

2. コードの練習

1. Redis と SpringBoot AOP の依存関係を導入する

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

ログイン後にコピー

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 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;//返回业务代码的值 } }

ログイン後にコピー

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 script

は運用テストデータに使用されます

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 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,"操作数据库失败"); } }

ログイン後にコピー