1

2

3

4

5

6

7

8

9

10

/**

*@author caoyue

*延时双删

**/

@Retention(RetentionPolicy.RUNTIME)

@Documented

@Target(ElementType.METHOD)

public @interface ClearCache {

    boolean open() default true;

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

/**

 * @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;

    }

}