快捷導(dǎo)航

基于?Spring?Aop?環(huán)繞通知實(shí)現(xiàn)?Redis?緩存雙刪功能(示例代碼)

更新時(shí)間：2022年08月16日 08:44:26 作者：風(fēng)起風(fēng)落丶

基于 spring aop 常規(guī)應(yīng)用場(chǎng)景多是用于日志記錄以及實(shí)現(xiàn) redis 分布式鎖，在 github 中也有項(xiàng)目是把它拿來(lái)當(dāng)作緩存的異常捕捉，這篇文章主要介紹了基于?Spring?Aop?環(huán)繞通知實(shí)現(xiàn)?Redis?緩存雙刪,需要的朋友可以參考下

基于 spring aop 常規(guī)應(yīng)用場(chǎng)景多是用于日志記錄以及實(shí)現(xiàn) redis 分布式鎖，在 github 中也有項(xiàng)目是把它拿來(lái)當(dāng)作緩存的異常捕捉。從而避免影響實(shí)際業(yè)務(wù)的開發(fā)；在某天，筆者有個(gè)業(yè)務(wù)開發(fā)是給某個(gè)服務(wù)模塊增加 redis 緩存。增加緩存就會(huì)涉及 redis 刪除。所以筆者就在思考是不是可以用環(huán)繞通知的方式來(lái)進(jìn)行實(shí)現(xiàn)

代碼實(shí)現(xiàn)

結(jié)構(gòu)示意圖：

自定義注解 RedisDelByDbUpdate

@Repeatable 表示允許在同一個(gè)地方上使用相同的注解，沒(méi)有該注解時(shí)貼相同注解會(huì)報(bào)錯(cuò)

@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();
}

具體實(shí)現(xiàn) redis 雙刪邏輯

@Aspect
@Component
@Slf4j
public class RedisDelAspect_bak {
    //環(huán)繞增強(qiáng)
    @Autowired
    private RedisUtil redis;
 
    @Pointcut("@annotation(com.cili.baseserver.aop.annotation.RedisDelByDbUpdate) " +
            "|| @annotation(com.cili.baseserver.aop.annotation.RedisDelByDbUpdateList)")
    public void pointCut() {
 
    }
 
    // 線程池定長(zhǎng)設(shè)置：最佳線程數(shù)目 = ((線程等待時(shí)間+線程CPU時(shí)間)/線程CPU時(shí)間 )* CPU數(shù)目
    ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(26);
 
    /**
     * 環(huán)繞增強(qiáng)
     *
     * @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<Object>() {
            public <T> T callback() throws Throwable {
                return (T) point.proceed();
            }
        });
    }
 
    private Object arraysRedisDel(RedisDelByDbUpdateList updateList, ProceedingJoinPoint point) throws Throwable {
        RedisDelByDbUpdate[] redisDelByDbUpdates = updateList.value();
        for (int i = 0; i < redisDelByDbUpdates.length; i++) {
            boolean flag = i == redisDelByDbUpdates.length - 1 ? true : false;
 
            Object obj = handle(redisDelByDbUpdates[i], point, new IObjectCallback<Object>() {
                public <T> T callback() throws Throwable {
                    return flag ? (T) point.proceed() : null;
                }
            });
            if (flag) return obj;
        }
        return null;
    }
 
    private Object handle(RedisDelByDbUpdate redisDelByDbUpdate, ProceedingJoinPoint point,
                          IObjectCallback<Object> object) throws Throwable {
 
        String prefix = redisDelByDbUpdate.redisPrefix();
        String fieldName = redisDelByDbUpdate.fieldName();
 
        if (ValueUtil.isEmpty(prefix)) {
            log.info("redis緩存前綴不能為空");
            throw new BizException(BaseResponseCode.SYSTEM_BUSY);
        }
 
        Object arg = point.getArgs()[0];
        String key = "";
        String[] redisKeys = null;
 
        if (ValueUtil.isNotEmpty(fieldName)) {
            if (arg instanceof ArrayList) {
                redisKeys = ((ArrayList<?>) arg).stream().map(item -> prefix + item).toArray(String[]::new);
            } else {
                Map<String, Object> map = (Map<String, Object>) JsonUtil.toMap(JsonUtil.toJSON(point.getArgs()[0]));
                key = map.get(fieldName).toString();
            }
        } else {
            // 獲取所有該前綴下緩存
            Set<String> keys = redis.keys(prefix + "*");
            redisKeys = keys.stream().toArray(String[]::new);
        }
 
        // 刪除緩存
        String redisKey = prefix + key;
        delete(redisKey, redisKeys);
        Object result = object.callback();
 
        // 延時(shí)刪除
        try {
            String[] finalRedisKeys = redisKeys;
            threadPool.schedule(new Runnable() {
                @Override
                public void run() {
                    delete(redisKey, finalRedisKeys);
                }
            }, 500, TimeUnit.MILLISECONDS);
        } catch (Exception e) {
            log.error("線程池延時(shí)刪除緩存失敗:{}", redisKey);
        }
        return result;
    }
 
    private void delete(String redisKey, String[] redisKeys) {
        if (ValueUtil.isEmpty(redisKeys)) {
            redis.delete(redisKey);
            return;
        }
        redis.del(redisKeys);
    }
}

注解使用示例

public class Test {
    @Override
    @RedisDelByDbUpdate(redisPrefix = RedisConstant.BANNER, fieldName = "ids")
    @RedisDelByDbUpdate(redisPrefix = RedisConstant.BANNER_LIST)
    public void batchDeleted(List<String> 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錯(cuò)誤:{}<==", e);
            throw new BizException(BaseResponseCode.SYSTEM_BUSY);
        }
    }
}

到此這篇關(guān)于基于 Spring Aop 環(huán)繞通知實(shí)現(xiàn) Redis 緩存雙刪的文章就介紹到這了,更多相關(guān)Spring Aop Redis 緩存雙刪內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: