基于 Spring Aop 环绕通知实现 Redis 缓存双删功能(示例代码)

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个数据库开发实战，手把手教大家学习《基于 Spring Aop 环绕通知实现 Redis 缓存双删功能(示例代码)》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

基于 spring aop 常规应用场景多是用于日志记录以及实现 redis 分布式锁，在 github 中也有项目是把它拿来当作缓存的异常捕捉。从而避免影响实际业务的开发；在某天，笔者有个业务开发是给某个服务模块增加 redis 缓存。增加缓存就会涉及 redis 删除。所以笔者就在思考是不是可以用环绕通知的方式来进行实现

代码实现

结构示意图：

自定义注解 RedisDelByDbUpdate

@Repeatable 表示允许在同一个地方上使用相同的注解，没有该注解时贴相同注解会报错

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Repeatable(RedisDelByDbUpdateList.class)
public @interface RedisDelByDbUpdate {
    /**
     * 具体操作得缓存前缀
     */
    String redisPrefix() default "";
 
    /**
     * 具体的缓存名称，为空则删除 redisPrefix 下的所有缓存
     */
    String fieldName() default "";
}

自定义注解 RedisDelByUpdateList

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RedisDelByDbUpdateList {
    
    RedisDelByDbUpdate[] value();
}

具体实现 redis 双删逻辑

@Aspect
@Component
@Slf4j
public class RedisDelAspect_bak {
    //环绕增强
    @Autowired
    private RedisUtil redis;
 
    @Pointcut("@annotation(com.cili.baseserver.aop.annotation.RedisDelByDbUpdate) " +
            "|| @annotation(com.cili.baseserver.aop.annotation.RedisDelByDbUpdateList)")
    public void pointCut() {
 
    }
 
    // 线程池定长设置：最佳线程数目 = ((线程等待时间+线程CPU时间)/线程CPU时间 )* CPU数目
    ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(26);
 
    /**
     * 环绕增强
     *
     * @param point
     * @return
     * @throws Throwable
     */
    @Around("pointCut()")
    public Object around(ProceedingJoinPoint point) throws Throwable {
        MethodSignature signature = (MethodSignature) point.getSignature();
        Method method = signature.getMethod();
 
        RedisDelByDbUpdate redisDelByDbUpdate = method.getAnnotation(RedisDelByDbUpdate.class);
        if (redisDelByDbUpdate != null) {
            return singleRedisDel(redisDelByDbUpdate, point);
        }
 
        RedisDelByDbUpdateList updateList = method.getAnnotation(RedisDelByDbUpdateList.class);
        return arraysRedisDel(updateList, point);
    }
 
    private Object singleRedisDel(RedisDelByDbUpdate redisDelByDbUpdate, ProceedingJoinPoint point) throws Throwable {
        return handle(redisDelByDbUpdate, point, new IObjectCallback

注解使用示例

public class Test {
    @Override
    @RedisDelByDbUpdate(redisPrefix = RedisConstant.BANNER, fieldName = "ids")
    @RedisDelByDbUpdate(redisPrefix = RedisConstant.BANNER_LIST)
    public void batchDeleted(List ids) throws BizException {
        if (CollectionUtils.isEmpty(ids)) {
            log.info("banner ID 不能为空");
            throw new BizException(BaseResponseCode.PARAM_IS_NOT_NULL);
        }
        try {
            bannerMapper.batchDeleted(ids);
        } catch (Exception e) {
            log.error("==>批量删除Banner错误:{}
到这里，我们也就讲完了《基于 Spring Aop 环绕通知实现 Redis 缓存双删功能(示例代码)》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于redis的知识点！