开发者

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

目录
  • Redis缓存一致性延时双删代码
    • 1、自定义注解
    • 2、刪除逻辑
  • redis缓存延迟双删问题

    redis缓存一致性延时双删代码

    不废话、、、如下

    1、自定义注解

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

    2、刪除逻辑

    /**
     * @author caoyue
     */
    @Component
    @ASPect
    @Slf4j
    public class DoubleClearCacheAop {
        @Autowired
        private UserService userService;
    	//声明一个用于延时的定时线程池代替线程sleep
        ScheduledExecutorServiceandroid 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()")
        publi开发者_Hadoopc Object clearCacheAop(ProceedingJoinPoint proceeds) throws Throwable {
            Method method = ((MethodSignature) proceeds.getpythonSignature()).getMethod();
            ClearCache annotation = method.getAnnotation(ClearCache.class);
            Object proceed = null;
            //如果清除注解开启了
            if (annotation.open()) {
            	//上下文获取信息
                IPubUser user = MsySecurityContextHolder.getUser();
                ifphp (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 procee编程客栈d;
        }
    }
    

    redis缓存延迟双删问题

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

    延迟双删的策略:

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

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

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

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

    以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。 

    0

    上一篇:

    下一篇:

    精彩评论

    暂无评论...
    验证码 换一张
    取 消

    最新数据库

    数据库排行榜