分布式多级缓存（本地缓存，redis缓存）

结构包：

 
 
 使用案例：

 
 
 实现效果：
1、基本并发的本地缓存，基于分布式轻量级锁的redis缓存
2、热缓存（高频访问持续缓存）+快速过期（本地缓存2秒，redis缓存10秒）
3、方法级别缓存清理 （@HybridCache 与@HybridChange 绑定管理缓存 ）
4、基于HybridType接口的可扩展式作用域，目前已实现：全局、token
5、基于HybridLevel接口的可扩展式缓存处理，目前已实现：本地缓存、redis缓存
核心代码包：

1. package com.*.server.live.core.hybridCache;
3. import com.*.server.live.core.hybridCache.impl.DepthLocal;
4. import com.*.server.live.core.hybridCache.impl.DepthRedis;
6. import java.lang.annotation.*;
8. /**
9. * 功能描述：多重缓存
10. * 作者：唐泽齐
11. * @case @HybridCache(scope = ScopeGlobal.class)
12. */
13. @Documented
14. @Retention(RetentionPolicy.RUNTIME)
15. @Target({ElementType.METHOD})
16. public @interface HybridCache {
18.     /*缓存深度*/
19.     Class<? extends HybridLevel> depth() default DepthRedis.class;
21.     /*缓存广度*/
22.     Class<? extends HybridType> scope();
24. }

复制代码

@HybridChange

1. package com.*.server.live.core.hybridCache;
3. import com.*.server.live.core.hybridCache.impl.DepthRedis;
5. import java.lang.annotation.*;
7. /**
8. * 功能描述：多重缓存更新
9. * 作者：唐泽齐
10. * @case @HybridChange(clazz = LiveStudioController.class,method = "getStudio",args = {Long.class})
11. * @case @HybridChange(clazz = LiveStudioController.class,method = "getStudio",args = {})
12. */
13. @Documented
14. @Retention(RetentionPolicy.RUNTIME)
15. @Target({ElementType.METHOD})
16. public @interface HybridChange {
18.     /*关联类*/
19.     Class<? extends Object> clazz();
21.     /*关联方法*/
22.     String method();
24.     /*关联方法入参类型*/
25.     Class<?>[] args();
26. }

复制代码

HybridLevel

1. package com.*.server.live.core.hybridCache;
3. import org.aspectj.lang.ProceedingJoinPoint;
5. import javax.validation.constraints.NotNull;
7. /**
8. * 功能描述：多重缓存级别
9. * 作者：唐泽齐
10. */
11. public interface HybridLevel {
12.     /**
13.      * 缓存
14.      * @param key 缓存key
15.      * @param id 混村ID
16.      * @param o 缓存值
17.      * @param self 是否执行节点
18.      * @param joinPoint 节点
19.      * @return
20.      * @throws Throwable
21.      */
22.     Object cache(@NotNull String key,@NotNull String id, Object o,@NotNull boolean self,@NotNull ProceedingJoinPoint joinPoint) throws Throwable;
24.     /**
25.      * 清缓存
26.      * @param key 缓存key
27.      * @param self 是否执行节点
28.      * @param joinPoint 节点
29.      * @return
30.      * @throws Throwable
31.      */
32.     Object del(@NotNull String key,@NotNull boolean self,@NotNull ProceedingJoinPoint joinPoint) throws Throwable;
33. }

复制代码

HybridType

1. package com.*.server.live.core.hybridCache;
3. /**
4. * 功能描述：多重缓存级别
5. * 作者：唐泽齐
6. */
7. public interface HybridType {
8.     String token();
9. }

复制代码

HybridCacheInterceptor 扩展代码包：

1. package com.*.server.live.core.hybridCache;
3. import com.alibaba.fastjson.JSON;
4. import com.alibaba.nacos.common.util.Md5Utils;
5. import org.aspectj.lang.ProceedingJoinPoint;
6. import org.aspectj.lang.annotation.Around;
7. import org.aspectj.lang.annotation.Aspect;
8. import org.aspectj.lang.reflect.MethodSignature;
9. import org.springframework.context.ApplicationContext;
10. import org.springframework.context.annotation.Configuration;
12. import javax.annotation.Resource;
13. import java.lang.reflect.Method;
15. /**
16. * 功能描述：多重缓存接口
17. * 作者：唐泽齐
18. */
19. @Aspect
20. @Configuration
21. public class HybridCacheInterceptor {
22.     @Resource
23.     ApplicationContext applicationContext;
24.     final static String cache = "hybridCache:";
26.     @Around(value = "@annotation(com.*.server.live.core.hybridCache.HybridCache)")
27.     public Object cache(ProceedingJoinPoint joinPoint) throws Throwable {
28.         MethodSignature ms = (MethodSignature) joinPoint.getSignature();
29.         Method method = ms.getMethod();
30.         HybridCache cacheAnnotation = method.getAnnotation(HybridCache.class);
31.         String key = getCacheKey(method);
32.         String id = getCacheId(method,joinPoint.getArgs());
33.         HybridLevel hybridLevel = applicationContext.getBean(cacheAnnotation.depth());
34.         return hybridLevel.cache(key, id, null, true, joinPoint);
35.     }
37.     @Around(value = "@annotation(com.*.server.live.core.hybridCache.HybridChange)")
38.     public Object del(ProceedingJoinPoint joinPoint) throws Throwable {
39.         MethodSignature ms = (MethodSignature) joinPoint.getSignature();
40.         Method method = ms.getMethod();
41.         HybridChange cacheAnnotation = method.getAnnotation(HybridChange.class);
42.         try {
43.             Method method1 = cacheAnnotation.clazz().getMethod(cacheAnnotation.method(),cacheAnnotation.args());
44.             HybridCache cache = method1.getAnnotation(HybridCache.class);
45.             String key = getCacheKey(method1);
46.             HybridLevel hybridLevel = applicationContext.getBean(cache.depth());
47.             return hybridLevel.del(key,true, joinPoint);
48.         } catch (Exception e) {
49.             return joinPoint.proceed();
50.         }
51.     }
53.     /*获取缓存key*/
54.     private String getCacheKey(Method method) {
55.         return cache + method.getDeclaringClass().getSimpleName() + ":" + method.getName();
56.     }
58.     ;
60.     /*获取缓存id*/
61.     private String getCacheId(Method method,Object[] args) {
62.         HybridCache cacheAnnotation = method.getAnnotation(HybridCache.class);
63.         HybridType hybridType = applicationContext.getBean(cacheAnnotation.scope());
64.         return Md5Utils.getMD5((hybridType.token() + JSON.toJSONString(args)).getBytes());
65.     }
67.     ;
69. }

复制代码

DepthLocal [code]package com.*.server.live.core.hybridCache.impl;import cn.hutool.core.util.RandomUtil;import com.*.common.redis.service.RedisService;import com.*.server.live.core.hybridCache.HybridLevel;import org.aspectj.lang.ProceedingJoinPoint;import org.springframework.stereotype.Component;import javax.annotation.Resource;/** * 功能描述：redis缓存 * 作者：唐泽齐 */@Componentpublic class DepthRedis implements HybridLevel {    @Resource    private RedisService redisService;    @Resource    private HybridLevel depthLocal;    @Override    public synchronized Object cache(String key, String id, Object o,boolean search, ProceedingJoinPoint joinPoint) throws Throwable {        o = depthLocal.cache(key, id, o,false,joinPoint);        String lock = getLock(key, id);        if(search && o== null && (o=redisService.hget(key , id)) == null ) {            for (;;) {                if(redisService.incr(lock,1l)