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触发执行缓存的保存和更新