文章目錄
1.什么是反射、反射優(yōu)缺點(diǎn)
2.反射的用途/反射應(yīng)用場景
3.反射調(diào)用方法/給屬性賦值
4.反射如何越過泛型檢查
5.什么是注解/注解生效的原理
6.自定義注解實(shí)現(xiàn)API接口限流框架
一、反射
1. 反射概念
使用反射機(jī)制可以動(dòng)態(tài)獲取當(dāng)前class的信息 比如方法的信息、注解信息、方法的參數(shù)、屬性等。
.java 源代碼 編譯.class 類加載器 jvm 字節(jié)碼
2. 反射機(jī)制的優(yōu)缺點(diǎn)
優(yōu)點(diǎn):提供開發(fā)者能夠更好封裝框架實(shí)現(xiàn)擴(kuò)展功能。
缺點(diǎn):
(1)反射會(huì)消耗一定的系統(tǒng)資源,因此如果不需要?jiǎng)討B(tài)地創(chuàng)建一個(gè)對(duì)象,那么就不需要用反射;
(2)反射調(diào)用方法時(shí)可以忽略權(quán)限檢查,因此可能會(huì)破壞封裝性而導(dǎo)致安全問題。
3. 反射的用途
反編譯:.class–>.java
1.通過反射機(jī)制訪問java對(duì)象的屬性,方法,構(gòu)造方法等
2. JDBC加載驅(qū)動(dòng)連接 class.forname
Class.forName(“com.mysql.jdbc.Driver”); // 動(dòng)態(tài)加載mysql驅(qū)動(dòng)
3. Spring容器框架IOC實(shí)例化對(duì)象
<bean id="mayikt" class="com.mayikt.UserEntity" />
4.自定義注解生效(反射+Aop)
5.第三方核心的框架 mybatis orm
4. 反射技術(shù)的使用
Class類 代表類的實(shí)體,在運(yùn)行的Java應(yīng)用程序中表示類和接口
Field類 代表類的成員變量(成員變量也稱為類的屬性)
Method類 代表類的方法
Constructor類 代表類的構(gòu)造方法
1.getField、getMethod和getCostructor方法可以獲得指定名字的域、方法和構(gòu)造器。
2.getFields、getMethods和getCostructors方法可以獲得類提供的public域、方法和構(gòu)造器數(shù)組,其中包括超類的共有成員。
3.getDeclatedFields、getDeclatedMethods和getDeclaredConstructors方法可以獲得類中聲明的全部域、方法和構(gòu)造器,其中包括私有和受保護(hù)的成員,但不包括超類的成員。
5. 反射常用的Api
(1)Object–>getClass
(2)任何數(shù)據(jù)類型(包括基本的數(shù)據(jù)類型)都有一個(gè)“靜態(tài)”的class屬性
(3)通過class類的靜態(tài)方法:forName(String className)(最常用)
Class<?> aClass = Class.forName(“com.mayikt.entity.UserEntity”);
<p>
* 第1種:獲取class UserEntity.class
* 第2種:獲取class Class.forName("類的全路徑");
* 第3種:new UserEntity().getClass()
*/
@Test
public void objCreateTest() throws InstantiationException, IllegalAccessException, ClassNotFoundException {
Class<UserEntity> userClass1 = UserEntity.class;
//默認(rèn)執(zhí)行無參構(gòu)造函數(shù)
UserEntity userEntity1 = userClass1.newInstance();
System.out.println(userEntity1);
//2.類的的完成路徑 報(bào)名+類名
Class<?> userClass2 = Class.forName("com.gblfy.elk.entity.UserEntity");
System.out.println(userClass1 == userClass2);
//3.new UserEntity().getClass()
UserEntity userEntity2 = new UserEntity();
Class userClass3 = userEntity2.getClass();
System.out.println(userClass1 == userClass3);//true
System.out.println(userEntity1 == userEntity2);//false
}
運(yùn)行期間,一個(gè)類,只有一個(gè)Class對(duì)象產(chǎn)生
6. 反射執(zhí)行構(gòu)造函數(shù)
執(zhí)行無參數(shù)構(gòu)造函數(shù)和執(zhí)行有參數(shù)構(gòu)造函數(shù)
() throws InstantiationException, IllegalAccessException, ClassNotFoundException, InvocationTargetException, NoSuchMethodException {
// //2.類的的完成路徑 報(bào)名+類名
Class<?> userClass2 = Class.forName("com.gblfy.elk.entity.UserEntity");
// //默認(rèn)執(zhí)行無參構(gòu)造函數(shù)
UserEntity userEntity = (UserEntity) userClass2.newInstance();
System.out.println(userEntity);
//執(zhí)行有參構(gòu)造函數(shù)
Constructor<?> declaredConstructor = userClass2.getDeclaredConstructor(String.class, Integer.class);
UserEntity userEntity2 = (UserEntity) declaredConstructor.newInstance("mayikt", 22);
System.out.println(userEntity2);
}
7. 反射執(zhí)行給屬性賦值
反射執(zhí)行給公有屬性賦值和反射執(zhí)行給私有屬性賦值
/**
* 反射如何給屬性賦值
*/
@Test
public void evaluationTest() throws ClassNotFoundException, InstantiationException, IllegalAccessException, NoSuchFieldException {
Class<?> userClass2 = Class.forName("com.gblfy.elk.entity.UserEntity");
UserEntity userEntity2 = (UserEntity) userClass2.newInstance();
//給公有屬性賦值
Field publicName = userClass2.getDeclaredField("publicName");
publicName.set(userEntity2, "mayikt");
System.out.println(userEntity2.getPublicName());
//給私有屬性賦值
Field userName = userClass2.getDeclaredField("userName");
//設(shè)置訪問私有屬性權(quán)限
userName.setAccessible(true);
userName.set(userEntity2, "mayikt2");
System.out.println(userEntity2.getUserName());
}
注意:
xception in thread "main" java.lang.IllegalAccessException: Class com.mayikt.test.Test03 can not access a member of class com.mayikt.entity.UserEntity with modifiers "private"
at sun.reflect.Reflection.ensureMemberAccess(Reflection.java:102)
at java.lang.reflect.AccessibleObject.slowCheckMemberAccess(AccessibleObject.java:296)
at java.lang.reflect.AccessibleObject.checkAccess(AccessibleObject.java:288)
at java.lang.reflect.Field.set(Field.java:761)
at com.mayikt.test.Test03.main(Test03.java:28)
解決辦法:
// 設(shè)置允許訪問私有屬性
userName.setAccessible(true);
8. 反射執(zhí)行調(diào)用方法
反射調(diào)用公有方法
() throws ClassNotFoundException, InstantiationException, IllegalAccessException, NoSuchFieldException, InvocationTargetException, NoSuchMethodException {
Class<?> userClass2 = Class.forName("com.gblfy.elk.entity.UserEntity");
//創(chuàng)建類實(shí)例
Object o = userClass2.newInstance();
//獲取公有和私有方法
Method method = userClass2.getDeclaredMethod("mayikt");
//設(shè)置訪問私有方法權(quán)限
method.setAccessible(true);
method.invoke(o);
}
反射調(diào)用私有方法和反射調(diào)用方法傳遞參數(shù)
//使用反射機(jī)制調(diào)用私有有參方法
@Test
public void methodCarryParamTest() throws ClassNotFoundException, InstantiationException, IllegalAccessException, NoSuchFieldException, InvocationTargetException, NoSuchMethodException {
Class<?> userClass2 = Class.forName("com.gblfy.elk.entity.UserEntity");
//創(chuàng)建類實(shí)例
Object o = userClass2.newInstance();
//獲取公有和私有方法
Method method = userClass2.getDeclaredMethod("sum", Integer.class, Integer.class);
//設(shè)置訪問私有方法權(quán)限
method.setAccessible(true);
Integer result = (Integer) method.invoke(o, 1, 5);
System.out.println(result);
}
二、注解
2.1. 注解概念
什么是注解
注解用來給類聲明附加額外信息,可以標(biāo)注在類、字段、方法等上面,編譯器、JVM以及開發(fā)人員等都可以通過反射拿到注解信息,進(jìn)而做一些相關(guān)處理
SpringBoot 全部都是采用注解化
2.2. 常用注解
@Override 只能標(biāo)注在子類覆蓋父類的方法上面,有提示的作用
@Deprecated 標(biāo)注在過時(shí)的方法或類上面,有提示的作用
@SuppressWarnings("unchecked")
2.3. 元注解
元注解用來在聲明新注解時(shí)指定新注解的一些特性
@Target 指定新注解標(biāo)注的位置,比如類、字段、方法等,取值有ElementType.Method等
@Retention 指定新注解的信息保留到什么時(shí)候,取值有RetentionPolicy.RUNTIME等
@Inherited 指定新注解標(biāo)注在父類上時(shí)可被子類繼承
2.4. 常用注解
(ElementType.METHOD) // 指定新注解可以標(biāo)注在方法上
@Retention(RetentionPolicy.RUNTIME) // 指定新注解保留到程序運(yùn)行時(shí)期
@Inherited // 指定新注解標(biāo)注在父類上時(shí)可被子類繼承
public @interface MayiktName {
public String name();
}
2.5. 注解的Target
TYPE:類、接口(包括注解類型)和枚舉的聲明
FIELD:字段聲明(包括枚舉常量)
METHOD:方法聲明
PARAMETER:參數(shù)聲明
CONSTRUCTOR:構(gòu)造函數(shù)聲明
LOCAL_VARIABLE:本地變量聲明
ANNOTATION_TYPE:注解類型聲明
PACKAGE:包聲明
TYPE_PARAMETER:類型參數(shù)聲明,JavaSE8引進(jìn),可以應(yīng)用于類的泛型聲明之處
TYPE_USE:JavaSE8引進(jìn),此類型包括類型聲明和類型參數(shù)聲明
2.6. 獲取注解信息
package com.gblfy.elk.annotate;
import java.lang.annotation.*;
/**
* ElementType.TYPE 注解在類上生效
* ElementType.METHOD 注解在方法上生效
* ElementType.FIELD 注解在屬性上生效
* Retention 加此注解,反射才可以獲取
* Inherited 子類可以繼承
*/
@Target({ElementType.METHOD, ElementType.TYPE, ElementType.FIELD,ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
public @interface MayiktName {
}
package com.gblfy.elk.entity;
import com.gblfy.elk.annotate.MayiktName;
@MayiktName
public class UserEntity {
private String userName;
private Integer userAge;
@MayiktName
public String publicName;
public UserEntity() {
System.out.println("執(zhí)行無參構(gòu)造函數(shù)");
}
public UserEntity(String userName, Integer userAge) {
System.out.println("執(zhí)行有參構(gòu)造函數(shù)");
this.userName = userName;
this.userAge = userAge;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public Integer getUserAge() {
return userAge;
}
public void setUserAge(Integer userAge) {
this.userAge = userAge;
}
public String getPublicName() {
return publicName;
}
public void setPublicName(String publicName) {
this.publicName = publicName;
}
@Override
public String toString() {
final StringBuffer sb = new StringBuffer("UserEntity{");
sb.append("userName='").append(userName).append(''');
sb.append(", userAge=").append(userAge);
sb.append('}');
return sb.toString();
}
@MayiktName
private void mayikt() {
System.out.println("mayikt");
}
@MayiktName
private Integer sum(Integer a, Integer b) {
return a + b;
}
}
/**
* 注解聯(lián)練習(xí)
*
* @author gblfy
* @date 2022-03-13
*/
public class AnnotateCase {
//判斷某類上是否加上@MayiktName注解
@Test
public void classAnnotateTest() throws ClassNotFoundException, InstantiationException, IllegalAccessException, NoSuchMethodException {
//加載類
Class<?> userClass = Class.forName("com.gblfy.elk.entity.UserEntity");
// 1.獲取當(dāng)前類上的注解
MayiktName declaredAnnotation = userClass.getDeclaredAnnotation(MayiktName.class);
System.out.println(declaredAnnotation);
}
//判斷指定方法上是否加上@MayiktName注解
@Test
public void methodAnnotateTest() throws ClassNotFoundException, InstantiationException, IllegalAccessException, NoSuchMethodException {
//加載類
Class<?> userClass = Class.forName("com.gblfy.elk.entity.UserEntity");
//創(chuàng)建類實(shí)例
Object o = userClass.newInstance();
//獲取指定mayikt方法
Method method = userClass.getDeclaredMethod("mayikt");
//獲取該方法上的注解,有則返回,無則返回null
MayiktName mayiktName = method.getDeclaredAnnotation(MayiktName.class);
System.out.println(mayiktName);
}
//判斷某屬性上是否加上@MayiktName注解
@Test
public void fieldAnnotateTest() throws ClassNotFoundException, InstantiationException, IllegalAccessException, NoSuchMethodException, NoSuchFieldException {
//加載類
Class<?> userClass = Class.forName("com.gblfy.elk.entity.UserEntity");
// 1.獲取屬性上的注解
Field publicName = userClass.getDeclaredField("publicName");
MayiktName mayiktName = publicName.getDeclaredAnnotation(MayiktName.class);
System.out.println(mayiktName);
}
}
2.7. 注解如何生效
實(shí)際項(xiàng)目中 注解想生效通過反射+aop機(jī)制
2.8. 注解實(shí)現(xiàn)案例
自定義限流注解
對(duì)我們接口實(shí)現(xiàn) 限流 比如 每s 只能訪問1次 或者每s 訪問兩次。
Maven
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.79</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>22.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.12.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
使用谷歌的guava例子
package com.gblfy.elk.controller;
import com.gblfy.elk.annotate.GblfyStreamLimit;
import com.google.common.util.concurrent.RateLimiter;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class SreamLimitController {
/**
* 每秒生成1.0個(gè)令牌
* 滑動(dòng)窗口、令牌桶、漏桶算法實(shí)現(xiàn)
*/
private RateLimiter rateLimiter = RateLimiter.create(1.0);
@GetMapping("/get")
public String get() {
System.out.println("-----------------執(zhí)行目標(biāo)方法-----------------");
boolean result = rateLimiter.tryAcquire();
if (!result) {
return "當(dāng)前訪問人數(shù)過多,請稍后重試!";
}
return "my is get";
}
@GetMapping("/add")
public String add() {
return "my is add";
}
}
2.09. 封裝自定義注解限流框架
整合自定義注解
package com.gblfy.elk.annotate;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* 自定義請求限流注解
*
* @author gblfy
* @date 2022-03-13
*/
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface GblfyStreamLimit {
/**
* 限流名稱
*
* @return
*/
String name() default "";
/**
* 限流次數(shù),默認(rèn)限流頻次 1秒/20次
*
* @return
*/
double limitNum() default 20.0;
}
2.10. 整合Aop實(shí)現(xiàn)接口限流
package com.gblfy.elk.aop;
import com.gblfy.elk.annotate.GblfyStreamLimit;
import com.google.common.util.concurrent.RateLimiter;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.*;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;
import java.util.concurrent.ConcurrentHashMap;
@Aspect
@Component
public class StreamLimitAop {
//并發(fā)map儲(chǔ)存
private ConcurrentHashMap<String, RateLimiter> rateLimiterStrategy = new ConcurrentHashMap();
/**
* 只要在方法上添加該自定義限流注解,就會(huì)被AOP環(huán)繞通知攔截
*
* @param joinPoint
* @return
*/
@Around(value = "@annotation(com.gblfy.elk.annotate.GblfyStreamLimit)")
public Object around(ProceedingJoinPoint joinPoint) {
try {
//獲取攔截的方法名
Signature sig = joinPoint.getSignature();
//獲取攔截的方法名
MethodSignature methodSignature = (MethodSignature) sig;
// 判斷方法上是否有加上該注解,如果有加上注解則限流
GblfyStreamLimit gblfyStreamLimit =
methodSignature.getMethod().getDeclaredAnnotation(GblfyStreamLimit.class);
if (gblfyStreamLimit == null) {
// 執(zhí)行目標(biāo)方法
return joinPoint.proceed();
}
// 1.獲取注解上的限流名稱(name)
String name = gblfyStreamLimit.name();
// 2.獲取注解上的limitNum(限流次數(shù)),實(shí)現(xiàn)對(duì)不同的方法限流策略不一樣的效果
double limitNum = gblfyStreamLimit.limitNum();
RateLimiter rateLimiter = rateLimiterStrategy.get(name);
if (rateLimiter == null) {
//3.動(dòng)態(tài)匹配并創(chuàng)建不同的限流策略
rateLimiter = RateLimiter.create(limitNum);
rateLimiterStrategy.put(name, rateLimiter);
}
// 開始限流
boolean result = rateLimiter.tryAcquire();
if (!result) {
return "當(dāng)前訪問人數(shù)過多,請稍后重試!";
}
return joinPoint.proceed();
} catch (Throwable throwable) {
return "系統(tǒng)出現(xiàn)了錯(cuò)誤!";
}
}
/**
* 前置通知
*/
@Before(value = "@annotation(com.gblfy.elk.annotate.GblfyStreamLimit)")
public void before() {
System.out.println("----------------------前置通知----------------------");
}
/**
* 后置通知
*/
@AfterReturning(value = "@annotation(com.gblfy.elk.annotate.GblfyStreamLimit)")
public void AfterReturning() {
System.out.println("----------------------后置通知----------------------");
}
/**
* 異常通知
*
* @param point
*/
@AfterThrowing(value = "@annotation(com.gblfy.elk.annotate.GblfyStreamLimit)", throwing = "e")
public void serviceAspect(JoinPoint point, Exception e) {
System.out.println("----------------------異常通知----------------------");
}
}
2.11. 案例
package com.gblfy.elk.controller;
import com.gblfy.elk.annotate.GblfyStreamLimit;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class SreamLimitController {
@GetMapping("/get2")
@GblfyStreamLimit(name = "get2", limitNum = 1.0)
public String get2() {
System.out.println("-----------------執(zhí)行目標(biāo)方法-----------------");
return "my is get";
}
@GetMapping("/add")
public String add() {
return "my is add";
}
}
??http://127.0.0.1:8080/get?? http://127.0.0.1:8080/my