導(dǎo)入redis的jar包
雙鴨山ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景,ssl證書(shū)未來(lái)市場(chǎng)廣闊!成為成都創(chuàng)新互聯(lián)的ssl證書(shū)銷(xiāo)售渠道,可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠!如果有意向歡迎電話聯(lián)系或者加微信:028-86922220(備注:SSL證書(shū)合作)期待與您的合作!
<!-- redis --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> <version>2.0.4.RELEASE</version> </dependency>
編寫(xiě)自定義緩存注解
/** * @Description: redis緩存注解 編寫(xiě)在需要緩存的類(lèi)上 **/ @Documented @Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) public @interface RedisCache { }
編寫(xiě)切面類(lèi)
package com.ys.edu.aop; import com.ys.edu.utils.ResultUtils; import org.apache.log4j.Logger; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; import org.aspectj.lang.annotation.Aspect; import org.aspectj.lang.annotation.Pointcut; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.ValueOperations; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.RedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; import org.springframework.stereotype.Service; import org.aspectj.lang.reflect.MethodSignature; import javax.annotation.Resource; import java.util.Arrays; import java.util.Set; import java.util.concurrent.TimeUnit; /** * @ClassName RedisAOP * @description: redis 切面緩存 **/ @Aspect @Service public class RedisAOP { private static final Logger logger = Logger.getLogger(RedisAOP.class); private static final Integer TIME_OUT = 30 ; //redis 存活時(shí)長(zhǎng) 分鐘 @Resource private RedisTemplate redisTemplate; /** * @Title: queryCachePointcut * @Description: 定義切點(diǎn)為緩存注解 * @return void **/ @Pointcut("@within(com.ys.edu.annotation.RedisCache)") public void queryCachePointcut(){ } @Around("queryCachePointcut()") public Object Interceptor(ProceedingJoinPoint joinPoint) throws Throwable{ long beginTime = System.currentTimeMillis(); MethodSignature signature = (MethodSignature) joinPoint.getSignature(); //類(lèi)路徑名 String classPathName = joinPoint.getTarget().getClass().getName(); //類(lèi)名 String className = classPathName.substring(classPathName.lastIndexOf(".")+1,classPathName.length()); //獲取方法名 String methodName = signature.getMethod().getName(); String[] strings = signature.getParameterNames(); String key = className+"_"+methodName+"_"+Arrays.toString(strings); if((methodName.indexOf("select") != -1 && methodName.substring(0,6).equalsIgnoreCase("select")) || (methodName.indexOf("query") != -1 && methodName.substring(0,5).equalsIgnoreCase("query")) || (methodName.indexOf("get") != -1 && methodName.substring(0,3).equalsIgnoreCase("get"))){ Object data = getObject(beginTime,joinPoint,key); if(data != null){ return ResultUtils.success(data); } return joinPoint.proceed(); }else if((methodName.indexOf("add") != -1 && methodName.substring(0,3).equalsIgnoreCase("add")) || (methodName.indexOf("insert") != -1 && methodName.substring(0,6).equalsIgnoreCase("insert")) || (methodName.indexOf("update") != -1 && methodName.substring(0,6).equalsIgnoreCase("update"))){ Set<String> keys = redisTemplate.keys(className+"*"); redisTemplate.delete(keys); logger.warn("執(zhí)行方法 : [ "+methodName+" ] : 清除 key 包含 [ "+className+" ] 的緩存數(shù)據(jù)"); logger.warn("AOP 緩存切面處理 >>>> end 耗時(shí):" + (System.currentTimeMillis() - beginTime)); } // 調(diào)用原始方法 return joinPoint.proceed(); } /** * @Title: getObject * @Description: 使用key獲取數(shù)據(jù) 不存在則查詢(xún)添加 * @param beginTime : 切面開(kāi)始時(shí)間 * @param joinPoint : 切面對(duì)象 * @param key : 獲取redis數(shù)據(jù)的key值 * @return java.lang.Object **/ private Object getObject(long beginTime,ProceedingJoinPoint joinPoint,String key) throws Throwable { ValueOperations<String, Object> operations = redisTemplate.opsForValue(); boolean hasKey = redisTemplate.hasKey(key); Object object = null; if(hasKey){ // 緩存中獲取到數(shù)據(jù),直接返回。 object = operations.get(key); logger.warn("從緩存中獲取到 key 為 ["+key+" ] : 的數(shù)據(jù) >>>> " + object.toString()); logger.warn("AOP 緩存切面處理 >>>> end 耗時(shí):" + (System.currentTimeMillis() - beginTime)); return object; } if(object == null) { // 緩存中沒(méi)有數(shù)據(jù),調(diào)用原始方法查詢(xún)數(shù)據(jù)庫(kù) object = joinPoint.proceed(); operations.set(key, object, TIME_OUT, TimeUnit.MINUTES); // 設(shè)置超時(shí)時(shí)間30分鐘 logger.warn("向 Redis 添加 key 為 ["+key+" ] , 存活時(shí)長(zhǎng)為 "+TIME_OUT+" min 的數(shù)據(jù) >>>> " + object.toString()); logger.warn("AOP 緩存切面處理 >>>> end 耗時(shí):" + (System.currentTimeMillis() - beginTime)); } return object; } @Autowired(required = false) public void setRedisTemplate(RedisTemplate redisTemplate) { RedisSerializer stringSerializer = new StringRedisSerializer();//序列化為String Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);//序列化為Json redisTemplate.setKeySerializer(stringSerializer); redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); redisTemplate.setHashKeySerializer(stringSerializer); redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer); this.redisTemplate = redisTemplate; } }
在想要使用redis緩存的controller類(lèi)上添加 @RedisCache 注解.
切面方法則會(huì)切以select/get/query 開(kāi)頭的查詢(xún)方法,獲取方法名和參數(shù)拼接為key,存到redis.
在執(zhí)行add/insert/update 開(kāi)頭的方法時(shí),則清空該類(lèi)下的所有緩存.
方法返回值格式統(tǒng)一實(shí)體類(lèi):
package com.ys.edu.bean; import java.io.Serializable; /** * @ClassName ResultBody * @description: RestFul API 方法返回值格式統(tǒng)一實(shí)體類(lèi) **/ public class ResultBody<T> implements Serializable { private static final long serialVersionUID = 694858559908048578L; private Integer code; private String msg; private Integer count = 0; private T data; public ResultBody(){} public ResultBody(Integer code, String msg,Integer count,T data) { this.code = code; this.msg = msg; this.count = count; this.data = data; } public ResultBody(Integer code, String msg,T data) { this.code = code; this.msg = msg; this.data = data; } /** * @Title: success * @Description: 成功 (無(wú)參) 默認(rèn) code : " 0 " msg : "請(qǐng)求成功" , count : 0 , data: null * @date 2018/11/29 10:28 **/ public ResultBody success(){ return success((T) null); } /** * @Title: success * @Description: 成功 默認(rèn) code : " 0 " msg : "請(qǐng)求成功" * @param count : 數(shù)據(jù)條數(shù) * @param data : 數(shù)據(jù) * @date 2018/11/29 11:46 **/ public ResultBody success(Integer count,T data){ return new ResultBody(0,"請(qǐng)求成功!",count,data); } /** * @Title: success * @Description: 成功 默認(rèn) code : " 0 " * @param msg : 提示信息 * @param count : 數(shù)據(jù)條數(shù) * @param data : 數(shù)據(jù) **/ public ResultBody success(String msg,Integer count,T data){ return new ResultBody(0,msg,count,data); } /** * @Title: success * @Description: 成功 默認(rèn) code : " 0 " , msg : "請(qǐng)求成功" * @param data : 數(shù)據(jù) **/ public ResultBody success(T data){ return new ResultBody(0,"請(qǐng)求成功!",data); } /** * @Title: success * @Description: 成功 默認(rèn) code : " 0 " * @param msg : 提示信息 * @param data : 數(shù)據(jù) * @date 2018/11/29 11:47 **/ public ResultBody success(String msg,T data){ return new ResultBody(0,msg,data); } /** * @Title: success * @Description: 成功 默認(rèn) code : " 0 " * @param code : 枚舉類(lèi)代碼 * @param data : 數(shù)據(jù) **/ public ResultBody success(Code code,T data){ return new ResultBody(code.getCode(),code.getMsg(),data); } /** * @Title: success * @Description: 成功 默認(rèn) code : " 0 " * @param code : 枚舉類(lèi)代碼 **/ public ResultBody success(Code code){ return new ResultBody(code.getCode(),code.getMsg(),null); } /** * @Title: error * @Description: 錯(cuò)誤 默認(rèn) data : null * @param code : 錯(cuò)誤代碼 * @param msg : 錯(cuò)誤信息 **/ public ResultBody error(Integer code,String msg){ return new ResultBody(code,msg,null); } /** * @Title: error * @Description: 錯(cuò)誤 默認(rèn) data : null * @param code : 枚舉類(lèi)錯(cuò)誤代碼 **/ public ResultBody error(Code code){ return new ResultBody(code.getCode(),code.getMsg(),null); } public Integer getCode() { return code; } public void setCode(Integer code) { this.code = code; } public String getMsg() { return msg; } public void setMsg(String msg) { this.msg = msg; } public Integer getCount() { return count; } public void setCount(Integer count) { this.count = count; } public T getData() { return data; } public void setData(T data) { this.data = data; } }
自定義提示枚舉類(lèi):
package com.ys.edu.bean; /** * @ClassName Code * @description: 自定義提示枚舉類(lèi) **/ public enum Code { /** * @Description: 請(qǐng)求狀態(tài)碼 **/ SUCCESS(0,"請(qǐng)求成功"), ERROR(-1,"請(qǐng)求錯(cuò)誤"); private Integer code; private String msg; public Integer getCode() { return code; } public void setCode(Integer code) { this.code = code; } public String getMsg() { return msg; } public void setMsg(String msg) { this.msg = msg; } Code(Integer code, String msg){ this.code = code; this.msg = msg; } }
返回結(jié)果工具類(lèi):
package com.ys.edu.utils; import com.ys.edu.bean.Code; import com.ys.edu.bean.ResultBody; import com.ys.edu.entity.Page; import java.util.HashMap; import java.util.Map; /** * @ClassName ResultUtils * @description: 返回結(jié)果工具類(lèi) **/ public class ResultUtils { /** * @Title: success * @Description: 無(wú)參成功返回 默認(rèn)值 code : "0" , msg : "請(qǐng)求成功" , count : 0 , data : null **/ public static ResultBody success(){ return success((Object)null); } public static ResultBody success(Object object){ return success(0,object); } /** * @Title: success * @Description: 有參成功返回 默認(rèn)值 code : "0" , msg : "請(qǐng)求成功" * @param count : 數(shù)據(jù)條數(shù) * @param object : 數(shù)據(jù) **/ public static ResultBody success(Integer count,Object object){ return new ResultBody().success(count,object); } /** * @Title: success * @Description: 有參成功返回 默認(rèn)值 code : "0" * @param msg : 提示信息 * @param count : 數(shù)據(jù)條數(shù) * @param object : 數(shù)據(jù) **/ public static ResultBody success(String msg,Integer count,Object object){ return new ResultBody().success(msg,count,object); } /** * @Title: error * @Description: 有參成功返回 默認(rèn)值 code : "0" * @param code : * @param object : 數(shù)據(jù) **/ public static ResultBody success(Code code,Object object){ return new ResultBody().success(code,object); } /** * @Title: error * @Description: 有參成功返回 默認(rèn)值 code : "0" data : null * @param code : 枚舉類(lèi)代碼 **/ public static ResultBody success(Code code){ return new ResultBody().success(code); } /** * @Title: error * @Description: 錯(cuò)誤返回格式 默認(rèn)值 data : null * @param code : 錯(cuò)誤代碼 **/ public static ResultBody error(Integer code,String msg){ return new ResultBody().error(code,msg); } /** * @Title: error * @Description: 錯(cuò)誤返回格式 默認(rèn)值 data : null * @param code : 枚舉類(lèi)錯(cuò)誤代碼 **/ public static ResultBody error(Code code){ return new ResultBody().error(code); } /** * @Title: successByLimit * @Description: 分頁(yè)返回?cái)?shù)據(jù)格式 * @param page : 查詢(xún)的頁(yè)數(shù) * @param limit : 查詢(xún)的條數(shù) * @param totalNum : 數(shù)據(jù)總條數(shù) * @param curCount : 當(dāng)前頁(yè)條數(shù) * @param object : 查詢(xún)結(jié)果數(shù)據(jù) **/ public static ResultBody successByLimit(Integer page,Integer limit,Integer totalNum,Integer curCount,Object object){ Map<String,Object> map = new HashMap<>(); Page pageInfo = new Page(); pageInfo.setPage(page); pageInfo.setLimit(limit); pageInfo.setTotalNum(totalNum); pageInfo.setTotalPages((totalNum + limit - 1)/limit); map.put("page",pageInfo); map.put("data",object); return success(curCount,map); } }
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了,希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,謝謝大家對(duì)創(chuàng)新互聯(lián)的支持。如果你想了解更多相關(guān)內(nèi)容請(qǐng)查看下面相關(guān)鏈接
當(dāng)前文章:SpringBootAOP控制Redis自動(dòng)緩存和更新的示例
文章出自:http://bm7419.com/article34/jceope.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供品牌網(wǎng)站建設(shè)、網(wǎng)站制作、網(wǎng)站改版、微信公眾號(hào)、響應(yīng)式網(wǎng)站、做網(wǎng)站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)