1. 创建自定义注解
首先，创建一个自定义注解，用于标记需要被缓存的方法，并指定缓存的有效时间。
import org.springframework.cache.Cache.ValueWrapper;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.core.annotation.AliasFor;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Cacheable(value = "secondLevelCache", key = "#root.methodName")
public @interface SecondLevelCacheable {
@AliasFor(annotation = Cacheable.class, attribute = "value")
String cacheName() default "secondLevelCache";
@AliasFor(annotation = Cacheable.class, attribute = "key")
String key() default "#root.methodName";
int expireInSeconds() default 60;
}这里我们定义了一个名为SecondLevelCacheable的注解，并使用@Cacheable作为元注解。cacheName属性指定了缓存的名字，默认为secondLevelCache；key属性定义了缓存的键，默认使用方法名作为键；expireInSeconds属性定义了缓存的有效时间（秒）。
2. 配置Spring Cache
确保Spring Boot项目已经配置了Spring Cache，并且启用了Redis作为缓存存储。
application.properties
spring.cache.type=redis
spring.redis.host=localhost
spring.redis.port=6379spring:
cache:
type: redis
redis:
host: localhost
port: 63793. 实现自定义注解处理器
接下来，实现一个AOP切面来处理这个自定义注解。这涉及到使用Spring AOP来拦截带有SecondLevelCacheable注解的方法调用。
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.Cache;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Component;
@Aspect
@Component
public class SecondLevelCacheAspect {
@Autowired
private CacheManager cacheManager;
@Around("@annotation(secondLevelCacheable)")
public Object handleSecondLevelCacheable(ProceedingJoinPoint joinPoint, SecondLevelCacheable secondLevelCacheable) throws Throwable {
String cacheName = secondLevelCacheable.cacheName();
String cacheKey = generateCacheKey(joinPoint, secondLevelCacheable.key());
// Check if the result is in cache
Cache cache = cacheManager.getCache(cacheName);
ValueWrapper valueWrapper = cache.get(cacheKey);
if (valueWrapper != null) {
return valueWrapper.get();
}
// Not in cache, proceed with method execution
Object result = joinPoint.proceed();
// Put result into cache with expiration time
cache.put(cacheKey, result, secondLevelCacheable.expireInSeconds(), java.util.concurrent.TimeUnit.SECONDS);
return result;
}
private String generateCacheKey(ProceedingJoinPoint joinPoint, String keyExpression) {
StringBuilder keyBuilder = new StringBuilder(keyExpression);
for (Object arg : joinPoint.getArgs()) {
keyBuilder.append(":").append(arg.toString());
}
return keyBuilder.toString();
}
}在这个例子中，我们定义了一个切面SecondLevelCacheAspect，它包含一个环绕通知handleSecondLevelCacheable，该通知处理所有带有SecondLevelCacheable注解的方法调用。它首先检查缓存中是否存在结果，如果存在则直接返回；否则执行方法并将结果存储到缓存中，并设置过期时间为expireInSeconds秒。
4. 应用自定义注解
现在你可以在任何需要缓存结果的方法上应用SecondLevelCacheable注解了。
public class SomeService {
@SecondLevelCacheable(expireInSeconds = 30)
public Object someMethod(Object... args) {
// 方法逻辑
}
}这样，每次调用someMethod时，都会根据定义的时间检查缓存并决定是否从缓存中获取数据或执行实际的方法逻辑。
以上步骤展示了如何使用自定义注解和AOP来实现Spring Boot中的秒级Redis缓存功能。可以根据具体需求调整注解参数和AOP逻辑。
