mongodb 实现数据缓存

mongodb缓存结果

private MongoOperations mongoTemplate;

public Object methodCacheHold(ProceedingJoinPoint joinPoint) throws Throwable {
        String targetName = joinPoint.getTarget().getClass().getName();
        String methodName = joinPoint.getSignature().getName();
        Object[] arguments = joinPoint.getArgs();
//        Class<?> returnType = joinPoint.getClass().getMethod(methodName).getReturnType();
        String cacheKey = getCacheKey(targetName, methodName, arguments);  
        CacheEntity cacheEntity = mongoTemplate.findById(cacheKey, CacheEntity.class);
        Object result = null;
        if (cacheEntity == null) {
            result = joinPoint.proceed();
            // if (result != null) {
            cacheEntity = new CacheEntity();
            cacheEntity.setId(cacheKey);//key为类名，方法名和参数组成字符串
            cacheEntity.setEntity(result);
            mongoTemplate.insert(cacheEntity);
            // }
        } else {
            result = cacheEntity.getEntity();
        }
        return result;
    }

    private String getCacheKey(String targetName, String methodName, Object[] arguments) {
        StringBuffer sb = new StringBuffer();
        sb.append(targetName).append(".").append(methodName);
        if ((arguments != null) && (arguments.length != 0)) {
            for (int i = 0; i < arguments.length; i++) {
                if (arguments[i] instanceof Date) {
                    sb.append(".").append(((Date) arguments[i]).getTime());
                } else {
                    sb.append(".").append(arguments[i]);
                }
            }
        }
        return sb.toString();
    }

清楚mongodb缓存结果

private MongoOperations mongoTemplate;
public Object removeCacheHold(ProceedingJoinPoint joinPoint) throws Throwable {
        String targetName = joinPoint.getTarget().getClass().getName();
        String methodName = joinPoint.getSignature().getName();
        Object[] arguments = joinPoint.getArgs();
//        Class<?> returnType = joinPoint.getClass().getMethod(methodName).getReturnType();
        String cacheKey = getCacheKey(targetName, methodName, arguments);  
        CacheEntity cacheEntity = new CacheEntity();
        cacheEntity.setId(cacheKey);
        mongoTemplate.remove(cacheEntity);
        Object result = null;
        result = joinPoint.proceed();
        return result;
    }

    private String getCacheKey(String targetName, String methodName, Object[] arguments) {
        StringBuffer sb = new StringBuffer();
        methodName = methodName.replace("CacheRemove", "Cache");//清楚的方法名规则为添加缓存的方法名后加上Remove
        sb.append(targetName).append(".").append(methodName);
        if ((arguments != null) && (arguments.length != 0)) {
            for (int i = 0; i < arguments.length; i++) {
                if (arguments[i] instanceof Date) {
                    sb.append(".").append(((Date) arguments[i]).getTime());
                } else {
                    sb.append(".").append(arguments[i]);
                }
            }
        }
        return sb.toString();
    }

通过添加在方法上的annotation触发执行缓存的保存和更新