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

用多少眼泪才能让你相信 · 2022-8-25 14:10:08

结构包：

使用案例：

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

package com.*.server.live.core.hybridCache;
import com.*.server.live.core.hybridCache.impl.DepthLocal;
import com.*.server.live.core.hybridCache.impl.DepthRedis;
import java.lang.annotation.*;
/**
* 功能描述：多重缓存
* 作者：唐泽齐
* @case @HybridCache(scope = ScopeGlobal.class)
*/
@Documented
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
public @interface HybridCache {
/*缓存深度*/
Class<? extends HybridLevel> depth() default DepthRedis.class;
/*缓存广度*/
Class<? extends HybridType> scope();
}

复制代码

@HybridChange

package com.*.server.live.core.hybridCache;
import com.*.server.live.core.hybridCache.impl.DepthRedis;
import java.lang.annotation.*;
/**
* 功能描述：多重缓存更新
* 作者：唐泽齐
* @case @HybridChange(clazz = LiveStudioController.class,method = "getStudio",args = {Long.class})
* @case @HybridChange(clazz = LiveStudioController.class,method = "getStudio",args = {})
*/
@Documented
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
public @interface HybridChange {
/*关联类*/
Class<? extends Object> clazz();
/*关联方法*/
String method();
/*关联方法入参类型*/
Class<?>[] args();
}

复制代码

HybridLevel

package com.*.server.live.core.hybridCache;
import org.aspectj.lang.ProceedingJoinPoint;
import javax.validation.constraints.NotNull;
/**
* 功能描述：多重缓存级别
* 作者：唐泽齐
*/
public interface HybridLevel {
/**
* 缓存
* @param key 缓存key
* @param id 混村ID
* @param o 缓存值
* @param self 是否执行节点
* @param joinPoint 节点
* @return
* @throws Throwable
*/
Object cache(@NotNull String key,@NotNull String id, Object o,@NotNull boolean self,@NotNull ProceedingJoinPoint joinPoint) throws Throwable;
/**
* 清缓存
* @param key 缓存key
* @param self 是否执行节点
* @param joinPoint 节点
* @return
* @throws Throwable
*/
Object del(@NotNull String key,@NotNull boolean self,@NotNull ProceedingJoinPoint joinPoint) throws Throwable;
}

复制代码

HybridType

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

复制代码

HybridCacheInterceptor 扩展代码包：

package com.*.server.live.core.hybridCache;
import com.alibaba.fastjson.JSON;
import com.alibaba.nacos.common.util.Md5Utils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Configuration;
import javax.annotation.Resource;
import java.lang.reflect.Method;
/**
* 功能描述：多重缓存接口
* 作者：唐泽齐
*/
@Aspect
@Configuration
public class HybridCacheInterceptor {
@Resource
ApplicationContext applicationContext;
final static String cache = "hybridCache:";
@Around(value = "@annotation(com.*.server.live.core.hybridCache.HybridCache)")
public Object cache(ProceedingJoinPoint joinPoint) throws Throwable {
MethodSignature ms = (MethodSignature) joinPoint.getSignature();
Method method = ms.getMethod();
HybridCache cacheAnnotation = method.getAnnotation(HybridCache.class);
String key = getCacheKey(method);
String id = getCacheId(method,joinPoint.getArgs());
HybridLevel hybridLevel = applicationContext.getBean(cacheAnnotation.depth());
return hybridLevel.cache(key, id, null, true, joinPoint);
}
@Around(value = "@annotation(com.*.server.live.core.hybridCache.HybridChange)")
public Object del(ProceedingJoinPoint joinPoint) throws Throwable {
MethodSignature ms = (MethodSignature) joinPoint.getSignature();
Method method = ms.getMethod();
HybridChange cacheAnnotation = method.getAnnotation(HybridChange.class);
try {
Method method1 = cacheAnnotation.clazz().getMethod(cacheAnnotation.method(),cacheAnnotation.args());
HybridCache cache = method1.getAnnotation(HybridCache.class);
String key = getCacheKey(method1);
HybridLevel hybridLevel = applicationContext.getBean(cache.depth());
return hybridLevel.del(key,true, joinPoint);
} catch (Exception e) {
return joinPoint.proceed();
}
}
/*获取缓存key*/
private String getCacheKey(Method method) {
return cache + method.getDeclaringClass().getSimpleName() + ":" + method.getName();
}
;
/*获取缓存id*/
private String getCacheId(Method method,Object[] args) {
HybridCache cacheAnnotation = method.getAnnotation(HybridCache.class);
HybridType hybridType = applicationContext.getBean(cacheAnnotation.scope());
return Md5Utils.getMD5((hybridType.token() + JSON.toJSONString(args)).getBytes());
}
;
}

复制代码

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)

		自动登录	找回密码
密码			立即注册

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

本帖子中包含更多资源

0 个回复

快速回复

楼主热帖

标签云