vlambda博客
学习文章列表

import java.lang.annotation.*;/** * @author Wanghs * @create 2022/2/22 * @description AOP实现延迟双删 */@Documented@Retention(RetentionPolicy.RUNTIME)@Target(ElementType.METHOD)public @interface DelayedDoubleDeletion { String name() default "";}

import com.bdsecurity.entity.dttm.constant.DatabaseGatewayConstant;import com.bdsecurity.utils.AspectMethodParamUtil;import com.sjtm.util.RedisUtil;import lombok.extern.slf4j.Slf4j;import org.aspectj.lang.ProceedingJoinPoint;import org.aspectj.lang.annotation.Around;import org.aspectj.lang.annotation.Aspect;import org.aspectj.lang.annotation.Pointcut;import org.springframework.stereotype.Component;import javax.annotation.Resource;import java.util.*;/** * @author Wanghs * @create 2022/2/22 * @description 切面类 */@Aspect@Component@Slf4jpublic class DelayedDoubleDeletionAspect { @Resource    private RedisUtil redisUtil; /** * 切入点 */ @Pointcut("@annotation(com.bdsecurity.annotation.DelayedDoubleDeletion)") public void pointCut() {    } /** * 环绕通知 * 环绕通知非常强大，可以决定目标方法是否执行，什么时候执行，执行时是否需要替换方法参数，执行完毕是否需要替换返回值。 * 环绕通知第一个参数必须是org.aspectj.lang.ProceedingJoinPoint类型 * * @param proceedingJoinPoint */ @Around("pointCut()") public Object aroundAdvice(ProceedingJoinPoint proceedingJoinPoint) { log.info("----------- start delayed double deletion ~ ~ -----------"); // 获取到方法参数，从而得到key，进行删除缓存操作 Map<String, Object> params = AspectMethodParamUtil.getNameAndValue(proceedingJoinPoint); String[] key = (String[]) params.get("key"); redisUtil.del(key); //执行加入双删注解的改动数据库的业务 即service中的方法业务 Object proceed = null; try { proceed = proceedingJoinPoint.proceed(); } catch (Throwable throwable) { log.error("原本更新数据库数据业务报错：{}", throwable); } /** * 使用 Timer 工具类延迟3秒（此处是3秒举例，可以根据自己的业务来改动） * 在Timer任务中中删除，之后将业务代码的结果返回 这样不影响业务代码的执行 */ Timer timer = new Timer(); timer.schedule(new TimerJob(timer, key, redisUtil), DatabaseGatewayConstant.THREE_SECOND_DELAYED_DOUBLE_DELETION_TIME); return proceed;//返回业务代码的值 }}@Slf4jclass TimerJob extends TimerTask { Timer timer = null; String[] key = null;    RedisUtil redisUtil = null; public TimerJob() {    } public TimerJob(Timer timer, String[] key, RedisUtil redisUtil) { this.timer = timer; this.key = key; this.redisUtil = redisUtil;    } @Override public void run() { log.info("----------- start timer job to del key ~ ~ -----------"); try { redisUtil.del(key); } catch (Exception e) { log.error("Timer job 执行异常：{}", e); } }}

import org.aspectj.lang.ProceedingJoinPoint;import org.aspectj.lang.reflect.CodeSignature;import java.util.HashMap;import java.util.Map;/** * @author Wanghs * @create 2022/2/22 * @description 工具类，获取方法的参数 */public class AspectMethodParamUtil { /** * 获取某个Method的参数名称及对应的值 * * @param joinPoint * @return Map<参数名称, 参数值></参数名称,参数值> */ public static Map<String, Object> getNameAndValue(ProceedingJoinPoint joinPoint) { Map<String, Object> param = new HashMap<>(); Object[] paramValues = joinPoint.getArgs(); String[] paramNames = ((CodeSignature) joinPoint.getSignature()).getParameterNames(); for (int i = 0; i < paramNames.length; i++) { param.put(paramNames[i], paramValues[i]); } return param; }}

@DelayedDoubleDeletionpublic Result exampleMethod(String[] key) { // 处理原本的逻辑，更新数据库操作}