网站建设比较好的律所,北京app网站建设价格,深圳制作网站培训机构,提供网站备案信息正常情况下的流程是#xff1a;请求来了#xff0c;先检查 Redis 有没有数据#xff0c;有返回#xff1b;没有便查询 MySQL 然后 放入 Redis。 此时#xff0c;如果 MySQL 的数据发生了变化#xff0c;所以需要同步到 Redis 中。 解决方法#xff1a;MySQL 中的数据更新…正常情况下的流程是请求来了先检查 Redis 有没有数据有返回没有便查询 MySQL 然后 放入 Redis。 此时如果 MySQL 的数据发生了变化所以需要同步到 Redis 中。 解决方法MySQL 中的数据更新的时候 在更新之前先删一次 Redis 中的数据在更新之后再删一次 Redis 中的数据。 工具类
public class RedisUtil {private final static ScheduledExecutorService DELAY_EXECUTOR new ScheduledThreadPoolExecutor(4);/*** 缓存延迟双删** param factory 目标任务* param keys 插入: 拼接成需要删除的缓存key* param T any object* return 目标任务返回结果*/public static T T doubleDeletion(SupplierT factory, Object... keys) {return RedisUtil.doubleDeletion(factory,() - RedisUtil.getRedisTemplate().delete(RedisUtil.key(keys)));}/*** 缓存延迟双删** param task 目标任务* param keys 插入: 拼接成需要删除的缓存key*/public static void doubleDeletion(Runnable task, Object... keys) {RedisUtil.doubleDeletion(task,() - RedisUtil.getRedisTemplate().delete(RedisUtil.key(keys)));}/*** 缓存延迟双删** param factory 目标任务* param key 需要删除的缓存key* param T any object* return 目标任务返回结果*/public static T T doubleDeletion(SupplierT factory, String key) {return RedisUtil.doubleDeletion(factory,() - RedisUtil.getRedisTemplate().delete(key));}/*** 缓存延迟双删** param task 目标任务* param key 需要删除的缓存key*/public static void doubleDeletion(Runnable task, String key) {RedisUtil.doubleDeletion(task,() - RedisUtil.getRedisTemplate().delete(key));}/*** 缓存延迟双删** param factory 执行的目标任务* param deleteCacheTask 清除缓存的任务* param T any object* return 执行目标任务的返回结果*/public static T T doubleDeletion(SupplierT factory, Runnable deleteCacheTask) {deleteCacheTask.run();T data factory.get();//延迟800毫秒秒再删一次DelayExecutor.DELAY_EXECUTOR.schedule(deleteCacheTask, 800, TimeUnit.MILLISECONDS);return data;}/*** 缓存延迟双删** param task 目标任务* param deleteCacheTask 清除缓存任务*/public static void doubleDeletion(Runnable task, Runnable deleteCacheTask) {RedisUtil.doubleDeletion(() - {task.run();return null;},deleteCacheTask);}} 用法 1
RedisUtil.doubleDeletion(// 定义数据库更新操作() - updateProcudt(product),// 定义 删除 redis 操作() - RedisUtil.delete(product: id));
