首页｜我的编程技术分享 | Spring项目给Service加缓存功能

Spring项目给Service加缓存功能

758 次阅读，发布于 : 2024-03-15

项目中遇到service中某一个方法经常访问，因为查询sql比较多，比较慢，每次返回基本都是一样的结果，所以想通过增加给service指定方法增加缓存功能来优化查询速度。

###一、首先定义注解类
```
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME)
@Target(value={ElementType.METHOD})
public  @interface RedisCache {
    String name() default "";

/** 缓存有效期（秒） **/
    int expire() default 1800;
}

```
###二、定义拦截器
```

@Aspect
@Component
@EnableAspectJAutoProxy
public class RedisCacheAdvice {
    private static final Logger logger = LoggerFactory.getLogger(RedisCacheAdvice.class);
    @Autowired
    @Qualifier("redisTemplate")
    private RedisTemplate<String, Object> redisTemplate;

private final static String redis_service_cache = "redis_service_cache:";

@Pointcut("execution(* com.cod141soap..*.service.*Service.*(..))")
    public void servicePointcut() {

}
    @Pointcut("@annotation(redisCache)")
    public void hasAnnotation(RedisCache redisCache) {

}

@Around("servicePointcut() && hasAnnotation(redisCache)")
    public Object doAroundCacheService(ProceedingJoinPoint joinpoint,RedisCache redisCache) throws Throwable{
        MethodSignature signature = (MethodSignature) joinpoint.getSignature();
        Method method = signature.getMethod();
        //请求的方法名
        String methodName = method.getName();
        //获取操作的类
        String targetName = joinpoint.getTarget().getClass().getName();
        //返回类型名称
        String returnTypeName = method.getReturnType().getName();
        //获取参数
        Object[] args = joinpoint.getArgs();
        StringBuffer argBuffer = new StringBuffer();
        for(Object arg : args){
            if(arg==null){
                argBuffer.append("null");
            }else{
                argBuffer.append(JSONObject.toJSONString(arg));
            }
            argBuffer.append("::");
        }
        String nameSha1 = StringUtil.sha1Hex(returnTypeName + "/" + targetName + "." + methodName + argBuffer);
        if(redisTemplate.hasKey(redis_service_cache + nameSha1)){
            //存在结果，直接取出返回
            Object result = redisTemplate.opsForValue().get(redis_service_cache+nameSha1);
            return result;
        }
        //不存在，建立缓存
        Object result = joinpoint.proceed();
        long expireTime = 1800;
        if(redisCache.expire()>0){
            expireTime = redisCache.expire();
        }
        redisTemplate.opsForValue().set(redis_service_cache+nameSha1,result,expireTime, TimeUnit.SECONDS);
        return result;
    }
}

```

###三、使用示例
```
@Service
public class TestService{

@RedisCache(expire = 7200)
	public String methodA(){
		...
	}
}
```

全网最详细的Oracle10g/11g的官方下载地址集合