cgb2007-京淘day13
2020-11-13 14:01:02
1.Redis命令
1.1 入門案例操作
@Test
public void testHash() throws InterruptedException {
Jedis jedis = new Jedis("192.168.126.129",6379);
jedis.hset("person", "id", "18");
jedis.hset("person", "name", "hash測試");
jedis.hset("person", "age", "2");
Map<String,String> map = jedis.hgetAll("person");
Set<String> set = jedis.hkeys("person"); //獲取所有的key
List<String> list = jedis.hvals("person");
}
@Test
public void testList() throws InterruptedException {
Jedis jedis = new Jedis("192.168.126.129",6379);
jedis.lpush("list", "1","2","3","4");
System.out.println(jedis.rpop("list"));
}
@Test
public void testTx(){
Jedis jedis = new Jedis("192.168.126.129",6379);
//1.開啟事務
Transaction transaction = jedis.multi();
try {
transaction.set("a", "a");
transaction.set("b", "b");
transaction.set("c", "c");
transaction.exec(); //提交事務
}catch (Exception e){
transaction.discard();
}
}
2 SpringBoot整合Redis
2.1 編輯pro組態檔
由於redis的IP地址和埠都是動態變化的,所以通過組態檔標識資料. 由於redis是公共部分,所以寫到common中.
2.2 編輯設定類
package com.jt.config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import redis.clients.jedis.Jedis;
@Configuration //標識我是設定類
@PropertySource("classpath:/properties/redis.properties")
public class RedisConfig {
@Value("${redis.host}")
private String host;
@Value("${redis.port}")
private Integer port;
@Bean
public Jedis jedis(){
return new Jedis(host, port);
}
}
3 物件與JSON串轉化
3.1 物件轉化JSON入門案例
package com.jt;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.jt.pojo.ItemDesc;
import org.junit.jupiter.api.Test;
import java.util.Date;
public class TestObjectMapper {
private static final ObjectMapper MAPPER = new ObjectMapper();
/**
* 1.物件如何轉化為JSON串的???
* 步驟:
* 1.獲取物件的所有的getXXXX()方法.
* 2.將獲取的getXXX方法的字首get去掉 形成了json的key=xxx
* 3.通過getXXX方法的呼叫獲取屬性的值,形成了json的value的值.
* 4.將獲取到的資料 利用json格式進行拼接 {key : value,key2:value2....}
* 2.JSON如何轉化為物件???
* {lyj:xxx}
* 步驟:
* 1. 根據class引數型別,利用java的反射機制,範例化物件.
* 2. 解析json格式,區分 key:value
* 3. 進行方法的拼接 setLyj()名稱.
* 4.呼叫物件的setXXX(value) 將資料進行傳遞,
* 5.最終將所有的json串中的key轉化為物件的屬性.
*
*
* @throws JsonProcessingException
*/
@Test
public void testTOJSON() throws JsonProcessingException {
ItemDesc itemDesc = new ItemDesc();
itemDesc.setItemId(100L).setItemDesc("測試資料轉化")
.setCreated(new Date()).setUpdated(new Date());
//1.將物件轉化為JSON
String json = MAPPER.writeValueAsString(itemDesc);
System.out.println(json);
//2.將json轉化為物件 src:需要轉化的JSON串, valueType:需要轉化為什麼物件
ItemDesc itemDesc2 = MAPPER.readValue(json, ItemDesc.class);
/**
* 字串轉化物件的原理:
*/
System.out.println(itemDesc2.toString());
}
}
3.2 編輯ObjectMapper工具API
package com.jt.util;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
public class ObjectMapperUtil {
private static final ObjectMapper MAPPER = new ObjectMapper();
//將物件轉化為JSON
public static String toJSON(Object target){
try {
return MAPPER.writeValueAsString(target);
} catch (JsonProcessingException e) {
e.printStackTrace();
throw new RuntimeException(e);
}
}
//將JSON轉化為物件
//需求: 如果使用者傳遞什麼型別,則返回什麼物件
public static <T> T toObject(String json,Class<T> targetClass){
try {
return MAPPER.readValue(json, targetClass);
} catch (JsonProcessingException e) {
e.printStackTrace();
throw new RuntimeException(e);
}
}
}
4 實現商品分類快取實現
4.1 編輯ItemCatController
說明: 切換業務呼叫方法,執行快取呼叫
/**
* 業務: 實現商品分類的查詢
* url地址: /item/cat/list
* 引數: id: 預設應該0 否則就是使用者的ID
* 返回值結果: List<EasyUITree>
*/
@RequestMapping("/list")
public List<EasyUITree> findItemCatList(Long id){
Long parentId = (id==null)?0:id;
//return itemCatService.findItemCatList(parentId);
return itemCatService.findItemCatCache(parentId);
}
4.2 編輯ItemCatService
package com.jt.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.jt.mapper.ItemCatMapper;
import com.jt.pojo.ItemCat;
import com.jt.util.ObjectMapperUtil;
import com.jt.vo.EasyUITree;
import org.omg.PortableInterceptor.SYSTEM_EXCEPTION;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import redis.clients.jedis.Jedis;
import java.util.ArrayList;
import java.util.List;
@Service
public class ItemCatServiceImpl implements ItemCatService{
@Autowired
private ItemCatMapper itemCatMapper;
@Autowired(required = false) //程式啟動是,如果沒有改物件 暫時不載入
private Jedis jedis;
@Override
public String findItemCatName(Long itemCatId) {
return itemCatMapper.selectById(itemCatId).getName();
}
@Override
public List<EasyUITree> findItemCatList(Long parentId) {
//1.準備返回值資料
List<EasyUITree> treeList = new ArrayList<>();
//思路.返回值的資料從哪來? VO 轉化 POJO資料
//2.實現資料庫查詢
QueryWrapper queryWrapper = new QueryWrapper();
queryWrapper.eq("parent_id",parentId);
List<ItemCat> catList = itemCatMapper.selectList(queryWrapper);
//3.實現資料的轉化 catList轉化為 treeList
for (ItemCat itemCat : catList){
long id = itemCat.getId(); //獲取ID值
String text = itemCat.getName(); //獲取商品分類名稱
//判斷:如果是父級 應該closed 如果不是父級 則open
String state = itemCat.getIsParent()?"closed":"open";
EasyUITree easyUITree = new EasyUITree(id,text,state);
treeList.add(easyUITree);
}
return treeList;
}
/**
* Redis:
* 2大要素: key: 業務標識+::+變化的引數 ITEMCAT::0
* value: String 資料的JSON串
* 實現步驟:
* 1.應該查詢Redis快取
* 有: 獲取快取資料之後轉化為物件返回
* 沒有: 應該查詢資料庫,並且將查詢的結果轉化為JSON之後儲存到redis 方便下次使用
* @param parentId
* @return
*/
@Override
public List<EasyUITree> findItemCatCache(Long parentId) {
Long startTime = System.currentTimeMillis();
List<EasyUITree> treeList = new ArrayList<>();
String key = "ITEMCAT_PARENT::"+parentId;
if(jedis.exists(key)){
//redis中有資料
String json = jedis.get(key);
treeList = ObjectMapperUtil.toObject(json,treeList.getClass());
Long endTime = System.currentTimeMillis();
System.out.println("查詢redis快取的時間:"+(endTime-startTime)+"毫秒");
}else{
//redis中沒有資料.應該查詢資料庫.
treeList = findItemCatList(parentId);
//需要把資料,轉化為JSON
String json = ObjectMapperUtil.toJSON(treeList);
jedis.set(key, json);
Long endTime = System.currentTimeMillis();
System.out.println("查詢資料庫的時間:"+(endTime-startTime)+"毫秒");
}
return treeList;
}
}
5. AOP實現Redis快取
5.1 現有程式碼存在的問題
1.如果直接將快取業務,寫到業務層中,如果將來的快取程式碼發生變化,則程式碼耦合高,必然重寫編輯程式碼.
2.如果其他的業務也需要快取,則程式碼的重複率高,開發效率低.
解決方案: 採用AOP方式實現快取.
5.2 AOP
在軟體業，AOP為Aspect Oriented Programming的縮寫，意為：面向切面程式設計，通過預編譯方式和執行期間動態代理實現程式功能的統一維護的一種技術。AOP是OOP的延續，是軟體開發中的一個熱點，也是Spring框架中的一個重要內容，是函數語言程式設計的一種衍生範型。利用AOP可以對業務邏輯的各個部分進行隔離，從而使得業務邏輯各部分之間的耦合度降低，提高程式的可重用性，同時提高了開發的效率。
5.3 AOP實現步驟
公式: AOP(切面) = 通知方法(5種) + 切入點表示式(4種)
5.3.1 通知複習
1.before通知 在執行目標方法之前執行
2.afterReturning通知 在目標方法執行之後執行
3.afterThrowing通知 在目標方法執行之後報錯時執行
4.after通知 無論什麼時候程式執行完成都要執行的通知
上述的4大通知型別,不能控制目標方法是否執行.一般用來記錄程式的執行的狀態.
一般應用與監控的操作.
5.around通知(功能最為強大的) 在目標方法執行前後執行.
因為環繞通知可以控制目標方法是否執行.控制程式的執行的軌跡.
5.3.2 切入點表示式
1.bean(「bean的ID」) 粒度: 粗粒度 按bean匹配 當前bean中的方法都會執行通知.
2.within(「包名.類名」) 粒度: 粗粒度 可以匹配多個類
3.execution(「返回值型別 包名.類名.方法名(參數列)」) 粒度: 細粒度 方法引數級別
4.@annotation(「包名.類名」) 粒度:細粒度 按照註解匹配
5.3.3 AOP入門案例
package com.jt.aop;
import lombok.extern.apachecommons.CommonsLog;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Controller;
import org.springframework.stereotype.Service;
import java.util.Arrays;
@Aspect //標識我是一個切面
@Component //交給Spring容器管理
public class CacheAOP {
//切面 = 切入點表示式 + 通知方法
//@Pointcut("bean(itemCatServiceImpl)")
//@Pointcut("within(com.jt.service.ItemCatServiceImpl)")
//@Pointcut("within(com.jt.service.*)") // .* 一級包路徑 ..* 所有子孫後代包
//@Pointcut("execution(返回值型別 包名.類名.方法名(參數列))")
@Pointcut("execution(* com.jt.service..*.*(..))")
//註釋: 返回值型別任意型別 在com.jt.service下的所有子孫類 以add開頭的方法,任意引數型別
public void pointCut(){
}
/**
* 需求:
* 1.獲取目標方法的路徑
* 2.獲取目標方法的引數.
* 3.獲取目標方法的名稱
*/
@Before("pointCut()")
public void before(JoinPoint joinPoint){
String classNamePath = joinPoint.getSignature().getDeclaringTypeName();
String methodName = joinPoint.getSignature().getName();
Object[] args = joinPoint.getArgs();
System.out.println("方法路徑:"+classNamePath);
System.out.println("方法引數:"+ Arrays.toString(args));
System.out.println("方法名稱:"+methodName);
}
@Around("pointCut()")
public Object around(ProceedingJoinPoint joinPoint){
try {
System.out.println("環繞通知開始");
Object obj = joinPoint.proceed();
//如果有下一個通知,就執行下一個通知,如果沒有就執行目標方法(業務方法)
System.out.println("環繞通知結束");
return null;
} catch (Throwable throwable) {
throwable.printStackTrace();
throw new RuntimeException(throwable);
}
}
}
5.4 AOP實現Redis快取
5.4.1 業務實現策略
1).需要自定義註解CacheFind
2).設定註解的引數 key的字首,資料的超時時間.
3).在方法中標識註解.
4).利用AOP 攔截指定的註解.
5).應該使用Around通知實現快取業務.
5.4.2 編輯自定義註解
@Target(ElementType.METHOD) //註解對方法有效
@Retention(RetentionPolicy.RUNTIME) //執行期有效
public @interface CacheFind {
public String preKey(); //定義key的字首
public int seconds() default 0; //定義資料的超時時間.
}
5.4.3 方法中標識註解
5.4.4 編輯CacheAOP
package com.jt.aop;
import com.jt.anno.CacheFind;
import com.jt.util.ObjectMapperUtil;
import lombok.extern.apachecommons.CommonsLog;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Controller;
import org.springframework.stereotype.Service;
import redis.clients.jedis.Jedis;
import java.lang.reflect.Method;
import java.util.Arrays;
@Aspect //標識我是一個切面
@Component //交給Spring容器管理
public class CacheAOP {
@Autowired
private Jedis jedis;
/**
* 注意事項: 當有多個引數時,joinPoint必須位於第一位.
* 需求:
* 1.準備key= 註解的字首 + 使用者的引數
* 2.從redis中獲取資料
* 有: 從快取中獲取資料之後,直接返回值
* 沒有: 查詢資料庫之後再次儲存到快取中即可.
*
* 方法:
* 動態獲取註解的型別,看上去是註解的名稱,但是實質是註解的型別. 只要切入點表示式滿足條件
* 則會傳遞註解物件型別.
* @param joinPoint
* @return
* @throws Throwable
*/
@Around("@annotation(cacheFind)")
public Object around(ProceedingJoinPoint joinPoint,CacheFind cacheFind) throws Throwable {
Object result = null; //定義返回值物件
String preKey = cacheFind.preKey();
String key = preKey + "::" + Arrays.toString(joinPoint.getArgs());
//1.校驗redis中是否有資料
if(jedis.exists(key)){
//如果資料存在,需要從redis中獲取json資料,之後直接返回
String json = jedis.get(key);
//1.獲取方法物件, 2.獲取方法的返回值型別
MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
//2.獲取返回值型別
Class returnType = methodSignature.getReturnType();
result = ObjectMapperUtil.toObject(json,returnType);
System.out.println("AOP查詢redis快取!!!");
}else{
//代表沒有資料,需要查詢資料庫
result = joinPoint.proceed();
//將資料轉化為JSON
String json = ObjectMapperUtil.toJSON(result);
if(cacheFind.seconds() > 0){
jedis.setex(key, cacheFind.seconds(), json);
}else{
jedis.set(key,json);
}
System.out.println("AOP查詢資料庫!!!");
}
return result;
}
/* @Around("@annotation(com.jt.anno.CacheFind)")
public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
//1.獲取目標物件的Class型別
Class targetClass = joinPoint.getTarget().getClass();
//2.獲取目標方法名稱
String methodName = joinPoint.getSignature().getName();
//3.獲取引數型別
Object[] argsObj = joinPoint.getArgs();
Class[] argsClass = null;
//4.物件轉化為class型別
if(argsObj.length>0){
argsClass = new Class[argsObj.length];
for(int i=0;i<argsObj.length;i++){
argsClass[i] = argsObj[i].getClass();
}
}
//3.獲取方法物件
Method targetMethod = targetClass.getMethod(methodName,argsClass);
//4.獲取方法上的註解
if(targetMethod.isAnnotationPresent(CacheFind.class)){
CacheFind cacheFind = targetMethod.getAnnotation(CacheFind.class);
String key = cacheFind.preKey() + "::"
+Arrays.toString(joinPoint.getArgs());
System.out.println(key);
}
Object object = joinPoint.proceed();
System.out.println("環繞開始後");
return object;
}
*/
/* //切面 = 切入點表示式 + 通知方法
//@Pointcut("bean(itemCatServiceImpl)")
//@Pointcut("within(com.jt.service.ItemCatServiceImpl)")
//@Pointcut("within(com.jt.service.*)") // .* 一級包路徑 ..* 所有子孫後代包
//@Pointcut("execution(返回值型別 包名.類名.方法名(參數列))")
@Pointcut("execution(* com.jt.service..*.*(..))")
//註釋: 返回值型別任意型別 在com.jt.service下的所有子孫類 以add開頭的方法,任意引數型別
public void pointCut(){
}*/
/**
* 需求:
* 1.獲取目標方法的路徑
* 2.獲取目標方法的引數.
* 3.獲取目標方法的名稱
*/
/* @Before("pointCut()")
public void before(JoinPoint joinPoint){
String classNamePath = joinPoint.getSignature().getDeclaringTypeName();
String methodName = joinPoint.getSignature().getName();
Object[] args = joinPoint.getArgs();
System.out.println("方法路徑:"+classNamePath);
System.out.println("方法引數:"+ Arrays.toString(args));
System.out.println("方法名稱:"+methodName);
}
@Around("pointCut()")
public Object around(ProceedingJoinPoint joinPoint){
try {
System.out.println("環繞通知開始");
Object obj = joinPoint.proceed();
//如果有下一個通知,就執行下一個通知,如果沒有就執行目標方法(業務方法)
System.out.println("環繞通知結束");
return null;
} catch (Throwable throwable) {
throwable.printStackTrace();
throw new RuntimeException(throwable);
}
}*/
}