在实际开发中,可能经常会有这样的需要:从MySQL中查询一条数据(比如用户信息),此时需要将用户信息保存至复述。
刚开始我们可能会在查询的业务逻辑之后再写一段复述,相关操作的代码,时间长了后发现这部分代码实际上仅仅做了复述的写入动作,跟业务逻辑没有实质的联系,那么有没有什么方法能让我们省略这些重复劳动呢?
首先想到用AOP,在查询到某些数据这一切入点(切入点)完成我们的切面相关处理(也就是写入复述)。那么,如何知道什么地方需要进行缓存呢,也就是什么地方需要用到AOP呢?参考数据库事务的实现用到了@ transactional,那我们也可以自定义一个注解@RedisCache,将此注解用在需要的方法上,方法的返回结果作为需要保存的信息,方法的查询参数(比如用户的id)可以用来作为关键。
上面的分析考虑下来貌似可行,那么接下来就动手实践吧!
<强>详细步骤
1。创建一个自定义注解@RedisCache
包复述;
进口java.lang.annotation。*;/* *
*自定义注解,结合AOP实现复述,自动缓存
*/@Retention (RetentionPolicy.RUNTIME)
@Target (ElementType.METHOD)
@Inherited
@Documented
公共@ interface RedisCache {
｝
之前
2。创建缓存写入的辅助类:RedisHelper.java,其中包含一个范型方法用于接收不同类的实例对象,以保证我们的方法能够通用。这里比较简单,直接把对象转成json,在复述中用字符串保存。而且不管什么情况统统写入,实际还可以完善下具体逻辑,比如判断缓存是否已存在,缓存信息是否最新等等。
包复述;
进口com.alibaba.fastjson.JSONObject;
进口org.springframework.beans.factory.annotation.Autowired;
进口org.springframework.data.redis.core.StringRedisTemplate;
进口org.springframework.stereotype.Component;
@ component
公开课RedisHelper {
@ autowired
私人StringRedisTemplate StringRedisTemplate;
公共& lt; T>空白saveCache(字符串键,T T) {
json字符串=JSONObject.toJSONString (t);
stringRedisTemplate.opsForValue()这里(关键、json);
｝
｝
之前
3。创建RedisCacheAspect.java,利用AOP框架AspectJ完成切面处理(用万金油环绕通知吧,按需要有取舍地使用具体某些类型的通知吧),我们这里用到了返回通知,也就是方法调用成功得到返回结果后进行切面处理动作
包复述;
进口org.aspectj.lang.ProceedingJoinPoint;
进口org.aspectj.lang.annotation.Around;
进口org.aspectj.lang.annotation.Aspect;
进口org.aspectj.lang.annotation.Pointcut;
进口org.springframework.beans.factory.annotation.Autowired;
进口org.springframework.stereotype.Component;
@Aspect
@ component
公开课RedisCacheAspect {
@ autowired
私人RedisHelper RedisHelper;
@Pointcut (“@annotation (redis.RedisCache)”)
公共空间setJoinPoint () {}//环绕通知:可以获取返回值
@Around(值=" https://www.yisu.com/zixun/setJoinPoint ()”)
公共对象aroundMethod (ProceedingJoinPoint ProceedingJoinPoint) {
对象的结果=零;
尝试{//前置通知
结果=proceedingJoinPoint.proceed ();//返回通知//缓存至复述
对象[]参数=proceedingJoinPoint.getArgs ();//关键策略:需要缓存的对象的全类名id,如:entity.User-1
redisHelper.saveCache (result.getClass () . getname () +“-”+ args[0],结果);
}捕捉(Throwable e) {//异常通知
｝//后置通知
返回结果;
｝
｝
之前
4。接下来是具体业务相关的代码
UserController.java
包控制器;
进口com.alibaba.fastjson.JSONObject;
进口org.springframework.beans.factory.annotation.Autowired;
进口org.springframework.stereotype.Controller;
进口org.springframework.web.bind.annotation.PathVariable;
进口org.springframework.web.bind.annotation.RequestMapping;
进口org.springframework.web.bind.annotation.RequestMethod;
进口org.springframework.web.bind.annotation.ResponseBody;
进口service.UserService;
@SuppressWarnings(未使用)
@ controller
公开课用户控件{
@ autowired
私人UserService UserService;
@RequestMapping(值=" https://www.yisu.com/user/{id}”,=RequestMethod方法。application/json,产生=";charset=utf - 8”)
@ResponseBody
公共字符串测试(@PathVariable长id) {
返回JSONObject.toJSONString (userService.get (id));
｝
｝
