import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;
@Service
public class SomeService {
// 使用自定义的缓存注解来替换Spring的@Cacheable
@CustomCacheable(cacheNames = "someCache", key = "#id")
public SomeData getData(Long id) {
// 实现根据id获取数据的逻辑
return someRepository.findById(id).orElse(null);
}
}
// 自定义缓存注解
import java.lang.annotation.*;
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
public @interface CustomCacheable {
String[] cacheNames();
String key();
}
// 切面处理自定义缓存注解
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.cache.CacheManager;
import org.springframework.cache.interceptor.CacheOperationInvoker;
@Aspect
@Component
public class CustomCacheableAspect {
@Autowired
private CacheManager cacheManager;
@Around("@annotation(customCacheable)")
public Object cache(ProceedingJoinPoint pjp, CustomCacheable customCacheable) throws Throwable {
MethodSignature methodSignature = (MethodSignature) pjp.getSignature();
Method method = methodSignature.getMethod();
Object[] args = pjp.getArgs();
// 获取注解中定义的缓存名称和键值
String cacheName = customCacheable.cacheNames()[0];
String key = customCacheable.key();
Object cacheKey = parseKey(key, method, args);
// 执行缓存查询
Object result = cacheManager.getCache(cacheName).get(cacheKey);
if (result != null) {
return result;
}
// 执行方法并缓存结果
result = pjp.proceed();
cacheManager.getCache(cacheName).put(cacheKey, result);
return result;
}
private Object parseKey(String key, Method method, Object[] args) {
// 实现从注解中提取的key的解析逻辑
// ...
return key;
}
}这个