1 接口缓存

第一 什么是cache

Cache通常意义上是指高速缓存，它与数据库最大的区别是“更快”，可能会快上100倍，而且Cache是全部运行在内存中，而数据库中的数据一般都是存在硬盘中，而IO一直都是网站等大规模系统的瓶颈，如果不使用Cache，完全用数据库，当访问量过大时将导致数据丢失，更严重时会导致系统崩溃，特别是遇到恶意攻击的情况，所以缓存构成了网络的第一道防线。

当用户请求网络资源时，会先访问缓存中的数据，如果缓存中没有，再去访问数据库，请求返回给用户的同时，更新到缓存中。而由于网络请求的定律，80%的请求会集中在20%的数据上，所以缓存会极大的提高服务的响应能力。

第二 应用场景

针对数据库的增、删、查、改，数据库缓存技术应用场景绝大部分针对的是“查”的场景。比如，一篇经常访问的帖子/文章/新闻、热门商品的描述信息、好友评论/留言等。因为在常见的应用中，数据库层次的压力有80%的是查询，20%的才是数据的变更操作。所以绝大部分的应用场景的还是“查”缓存。当然，“增、删、改”的场景也是有的。比如，一篇文章访问的次数，不可能每访问一次，我们就去数据库里面加一次吧？这种时候，我们一般“增”场景的缓存就必不可少。否则，一篇文章被访问了十万次，代码层次不会还去做十万次的数据库操作吧

第三 应用举例

读操作流程

数据库和缓存；存放数据之后（uid->data），每当需要读取相关数据时（data），操作流程一般是这样的：

（1）读取缓存中是否有相关数据，uid->data

（2）如果缓存中有相关数据data，则返回【这就是所谓的数据命中“hit”】

（3）如果缓存中没有相关数据data，则从数据库读取相关数据data【数据未命中“miss”】，放入缓存中uid→data，再返回 DB击穿

第四 实现

//项目中存在这样的问题，有的对象有30+字段，但需要缓存的只有3个，查如果全部都存到redis中，无疑将加大redis的负担 ; 下面的names 字段可以指定你需要缓存那几个字段，如果不填；则默认你的对象所有的字段都缓存

/**
 * @author 
 */
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
@Documented
public @interface RedisCacheAble {
String value() default ""; //key名称、前缀--redis中key = value+请求参数；如果不想key污染；需要key 需要加个业务标识；
 String[] names() default {}; //所需要包含的键值 names 需要缓存你实体中哪些字段值； 如果names 不填 则 缓存实体对象全部字段值
 long timeout() default 30; //过期时间
}



//切面

/**
 */ 
@Component // 注册到Spring容器，必须加入这个注解
@Aspect // 该注解标示该类为切面类，切面是由通知和切点组成的。
public class CacheApiAspect {

Logger logger = LoggerFactory.getLogger(com.ijovo.billionbottle.activity.cache.CacheAble .class);

@Autowired
 private RedisTemplate redisTemplate;


@Pointcut("@annotation(com.ijovo.billionbottle.activity.cache.CacheAble)")// 定义注解类型的切点，只要方法上有该注解，都会匹配
 public void annotationAble(){ 
} 

@Around("annotationAble()&& @annotation(rd)")
public Object redisCacheAble(ProceedingJoinPoint joinPoint, CacheAble rd) throws Throwable {
String preKey = rd.value();

String arg0 = joinPoint.getArgs()[0].toString();

Class returnClassType = ((MethodSignature)joinPoint.getSignature()).getMethod().getReturnType();

String key = preKey + ":" +arg0;

//如果redis中已經有值，直接返回
 String rtObject = (String) redisTemplate.opsForValue().get(key);
if (rtObject != null) {
Object obj = JSON.parseObject(rtObject,returnClassType);
return obj;
}
// 执行函数,如果返回值為空,返回
 Object sourceObject = joinPoint.proceed();
if (sourceObject == null) {
return null;
}

String path = getMethodPath(joinPoint);
// 根据values获取object里的值，并生成用于redis存储的对象
 Class<? extends Object> cl = sourceObject.getClass();

// 插入数据库成功
 // 如果values没有值，那么redis对应的value为输入对象；否则根据输入参数重新生成对象
 if (rd.names() == null ||rd.names().length==0) {
// 存入目标对象
 final String jsonStr = JSON.toJSONString(sourceObject);
redisTemplate.opsForValue().set(key, jsonStr,rd.expireTime(),TimeUnit.MINUTES);

} else {
// 将目标对象特定字段存入redis
 // 不用反射，而用jsonobject；并且只存储需要的字段，而不存整个对象
 //Object targetObject = cl.newInstance();
 Map jsonMap = new HashMap<String,Object>();
for (String name : rd.names()) {
try {
// 生成值到新的对象中
 String upChar = name.substring(0, 1).toUpperCase();
String getterStr = "get" + upChar + name.substring(1);
Method getMethod = cl.getMethod(getterStr, new Class[] {});
Object objValue = getMethod.invoke(sourceObject, new Object[] {});
jsonMap.put(name, objValue);

} catch (Exception e) {
logger.error(e.getMessage(), e);
}
}
// 存入目标对象,key=类名:keyvalue
 String jsonString = JSON.toJSONString(jsonMap);
redisTemplate.opsForValue().set(key, jsonString,rd.expireTime(),TimeUnit.MINUTES);

}
return sourceObject;
}

private String getMethodPath(ProceedingJoinPoint joinPoint) {
String methodName = ((MethodSignature)joinPoint.getSignature()).getMethod().getName();
String classFullName = ((MethodSignature)joinPoint.getSignature()).getMethod().getDeclaringClass().getName();
String path = classFullName.substring(classFullName.lastIndexOf(".")+1) + "." + methodName;
return path;
}

} 

项目中的应用
方法上的注解使用

Springboot 天然的有这些注解；项目中也可使用这些注解

@Cache 注解