redis缓存一致性延时双删代码实现方式详解

共计 1537 个字符，预计需要花费 4 分钟才能阅读完成。

不废话、、、如下

/**
*@author caoyue
* 延时双删
**/
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Target(ElementType.METHOD)
public @interface ClearCache {boolean open() default true;
}

/**
 * @author caoyue
 */
@Component
@Aspect
@Slf4j
public class DoubleClearCacheAop {
    @Autowired
    private UserService userService;
    // 声明一个用于延时的定时线程池代替线程 sleep
    ScheduledExecutorService task = new ScheduledThreadPoolExecutor(10, new BasicThreadFactory.
            Builder().namingPattern("clearCache-schedule-pool-%d").build());
    @Pointcut("@annotation(com.inspur.henan.uac.modules.open.util.ClearCache)")
    private void clearCachePoint() {}
    @Around("clearCachePoint()")
    public Object clearCacheAop(ProceedingJoinPoint proceeds) throws Throwable {Method method = ((MethodSignature) proceeds.getSignature()).getMethod();
        ClearCache annotation = method.getAnnotation(ClearCache.class);
        Object proceed = null;
        // 如果清除注解开启了
        if (annotation.open()) {
            // 上下文获取信息
            IPubUser user = MsySecurityContextHolder.getUser();
            if (Objects.nonNull(user)) {
                // 执行清除缓存的动作
                userService._clearCache(user);
                // 业务处理
                proceed = proceeds.proceed();
                // 延时两秒后再删
                task.schedule(() -> {userService._clearCache(user);
                    if (log.isInfoEnabled()) {log.info(Thread.currentThread().getName() + ":double delete cache completed");
                    }
                }, 2L, TimeUnit.SECONDS);
            } else {proceed = proceeds.proceed();
            }
        }
        return proceed;
    }
}

高并发场景使用 redis 作为缓存存储数据，当数据更新时，如何保证缓存一致性，

延迟双删的策略：

先删除缓存，然后更新数据库数据，休眠 sleep，最后再次删除缓存数据。

休眠的时间略微大于从数据库查询数据的时间。

当读写分离时，考虑到主从数据同步延迟，休眠时间约 1s。

休眠时间不能太大，否则会影响更新的速度。

阿里云 2 核 2G 服务器 3M 带宽 61 元 1 年，有高配

腾讯云新客低至 82 元 / 年，老客户 99 元 / 年

代金券：在阿里云专用满减优惠券