Java動(dòng)態(tài)代理的應(yīng)用詳解
動(dòng)態(tài)代理其實(shí)就是java.lang.reflect.Proxy類(lèi)動(dòng)態(tài)的根據(jù)您指定的所有接口生成一個(gè)class byte,該class會(huì)繼承Proxy類(lèi),并實(shí)現(xiàn)所有你指定的接口(您在參數(shù)中傳入的接口數(shù)組);然后再利用您指定的classloader將 class byte加載進(jìn)系統(tǒng),最后生成這樣一個(gè)類(lèi)的對(duì)象,并初始化該對(duì)象的一些值,如invocationHandler,以即所有的接口對(duì)應(yīng)的Method成員。 初始化之后將對(duì)象返回給調(diào)用的客戶(hù)端。這樣客戶(hù)端拿到的就是一個(gè)實(shí)現(xiàn)你所有的接口的Proxy對(duì)象。請(qǐng)看實(shí)例分析:
package com.fans.common.proxy;
public interface BusinessProcessor {
public void processBusiness();
}
package com.fans.common.proxy;
/**
* 業(yè)務(wù)處理類(lèi)
* @author fanshadoop
*
*/
public class BusinessProcessorImpl implements BusinessProcessor {
@Override
public void processBusiness() {
System.out.println("processing business.....");
}
}
package com.fans.common.proxy;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
/**
* 業(yè)務(wù)代理類(lèi)
* @author fanshadoop
*
*/
public class BusinessProcessorHandler implements InvocationHandler {
private Object target = null;
BusinessProcessorHandler(Object target) {
this.target = target;
}
public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
System.out
.println("You can do something here before process your business");
Object result = method.invoke(target, args);
System.out
.println("You can do something here after process your business");
return result;
}
}
package com.fans.common.proxy;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.lang.reflect.Modifier;
import java.lang.reflect.Proxy;
public class Test {
/**
* @param args
*/
public static void main(String[] args) {
BusinessProcessorImpl bpimpl = new BusinessProcessorImpl();
BusinessProcessorHandler handler = new BusinessProcessorHandler(bpimpl);
BusinessProcessor bp = (BusinessProcessor) Proxy.newProxyInstance(
bpimpl.getClass().getClassLoader(), bpimpl.getClass()
.getInterfaces(), handler);
bp.processBusiness();
System.out.println(bp.getClass().getName());
printClassDefinition(bp.getClass());
}
public static String getModifier(int modifier) {
String result = "";
switch (modifier) {
case Modifier.PRIVATE:
result = "private";
case Modifier.PUBLIC:
result = "public";
case Modifier.PROTECTED:
result = "protected";
case Modifier.ABSTRACT:
result = "abstract";
case Modifier.FINAL:
result = "final";
case Modifier.NATIVE:
result = "native";
case Modifier.STATIC:
result = "static";
case Modifier.SYNCHRONIZED:
result = "synchronized";
case Modifier.STRICT:
result = "strict";
case Modifier.TRANSIENT:
result = "transient";
case Modifier.VOLATILE:
result = "volatile";
case Modifier.INTERFACE:
result = "interface";
}
return result;
}
public static void printClassDefinition(Class clz) {
String clzModifier = getModifier(clz.getModifiers());
if (clzModifier != null && !clzModifier.equals("")) {
clzModifier = clzModifier + " ";
}
String superClz = clz.getSuperclass().getName();
if (superClz != null && !superClz.equals("")) {
superClz = "extends " + superClz;
}
Class[] interfaces = clz.getInterfaces();
String inters = "";
for (int i = 0; i < interfaces.length; i++) {
if (i == 0) {
inters += "implements ";
}
inters += interfaces[i].getName();
}
System.out.println(clzModifier + clz.getName() + " " + superClz + " "
+ inters);
System.out.println("{");
Field[] fields = clz.getDeclaredFields();
for (int i = 0; i < fields.length; i++) {
String modifier = getModifier(fields[i].getModifiers());
if (modifier != null && !modifier.equals("")) {
modifier = modifier + " ";
}
String fieldName = fields[i].getName();
String fieldType = fields[i].getType().getName();
System.out.println(" " + modifier + fieldType + " " + fieldName
+ ";");
}
System.out.println();
Method[] methods = clz.getDeclaredMethods();
for (int i = 0; i < methods.length; i++) {
Method method = methods[i];
String modifier = getModifier(method.getModifiers());
if (modifier != null && !modifier.equals("")) {
modifier = modifier + " ";
}
String methodName = method.getName();
Class returnClz = method.getReturnType();
String retrunType = returnClz.getName();
Class[] clzs = method.getParameterTypes();
String paraList = "(";
for (int j = 0; j < clzs.length; j++) {
paraList += clzs[j].getName();
if (j != clzs.length - 1) {
paraList += ", ";
}
}
paraList += ")";
clzs = method.getExceptionTypes();
String exceptions = "";
for (int j = 0; j < clzs.length; j++) {
if (j == 0) {
exceptions += "throws ";
}
exceptions += clzs[j].getName();
if (j != clzs.length - 1) {
exceptions += ", ";
}
}
exceptions += ";";
String methodPrototype = modifier + retrunType + " " + methodName
+ paraList + exceptions;
System.out.println(" " + methodPrototype);
}
System.out.println("}");
}
}
運(yùn)行結(jié)果:
You can do something here before process your business
processing business.....
You can do something here after process your business
$Proxy0
$Proxy0 extends java.lang.reflect.Proxy implements com.fans.common.proxy.BusinessProcessor
{
java.lang.reflect.Method m1;
java.lang.reflect.Method m3;
java.lang.reflect.Method m0;
java.lang.reflect.Method m2;
boolean equals(java.lang.Object);
java.lang.String toString();
int hashCode();
void processBusiness();
}
類(lèi)BusinessProcessorHandler實(shí)現(xiàn)了InvocationHandler接口的invoke方法,這個(gè)類(lèi)就是Proxy最終調(diào)用固定接口方法。
很明顯,Proxy.newProxyInstance方法會(huì)做如下幾件事:
1,根據(jù)傳入的第二個(gè)參數(shù)interfaces動(dòng)態(tài)生成一個(gè)類(lèi),實(shí)現(xiàn)interfaces中的接口,該例中即BusinessProcessor接口的processBusiness方法。并且繼承了Proxy類(lèi),重寫(xiě)了hashcode,toString,equals等三個(gè)方法。具體實(shí)現(xiàn)可參看 ProxyGenerator.generateProxyClass(...); 該例中生成了$Proxy0類(lèi)
2,通過(guò)傳入的第一個(gè)參數(shù)classloder將剛生成的類(lèi)加載到j(luò)vm中。即將$Proxy0類(lèi)load
3,利用第三個(gè)參數(shù),調(diào)用$Proxy0的$Proxy0(InvocationHandler)構(gòu)造函數(shù) 創(chuàng)建$Proxy0的對(duì)象,并且用interfaces參數(shù)遍歷其所有接口的方法,并生成Method對(duì)象初始化對(duì)象的幾個(gè)Method成員變量
4,將$Proxy0的實(shí)例返回給客戶(hù)端。
現(xiàn)在好了。我們?cè)倏纯蛻?hù)端怎么調(diào)就清楚了。
1,客戶(hù)端拿到的是$Proxy0的實(shí)例對(duì)象,由于$Proxy0繼承了BusinessProcessor,因此轉(zhuǎn)化為BusinessProcessor沒(méi)任何問(wèn)題。
BusinessProcessor bp = (BusinessProcessor)Proxy.newProxyInstance(....);
2,bp.processBusiness();
實(shí)際上調(diào)用的是$Proxy0.processBusiness();那么$Proxy0.processBusiness()的實(shí)現(xiàn)就是通過(guò)InvocationHandler去調(diào)用invoke方法啦!
- 十分鐘理解Java中的動(dòng)態(tài)代理
- 代理模式之Java動(dòng)態(tài)代理實(shí)現(xiàn)方法
- java代理模式與動(dòng)態(tài)代理模式詳解
- Java中反射動(dòng)態(tài)代理接口的詳解及實(shí)例
- 基于接口實(shí)現(xiàn)java動(dòng)態(tài)代理示例
- java動(dòng)態(tài)代理和cglib動(dòng)態(tài)代理示例分享
- 詳解java中動(dòng)態(tài)代理實(shí)現(xiàn)機(jī)制
- java實(shí)現(xiàn)動(dòng)態(tài)代理方法淺析
- 詳解java動(dòng)態(tài)代理的2種實(shí)現(xiàn)方式
- Java實(shí)現(xiàn)動(dòng)態(tài)代理的實(shí)例代碼
相關(guān)文章
Java?stream?sorted使用?Comparator?進(jìn)行多字段排序的方法
這篇文章主要介紹了Java?stream?sorted使用?Comparator?進(jìn)行多字段排序,主要講解使用Java?Stream流排序器Comparator對(duì)List集合進(jìn)行多字段排序的方法,包括復(fù)雜實(shí)體對(duì)象多字段升降序排序方法,需要的朋友可以參考下2023-03-03
java gui實(shí)現(xiàn)計(jì)算器小程序
這篇文章主要為大家詳細(xì)介紹了java gui實(shí)現(xiàn)計(jì)算器小程序,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-07-07
java8 stream中Collectors.toMap空指針問(wèn)題及解決
這篇文章主要介紹了java8 stream中Collectors.toMap空指針問(wèn)題及解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-05-05
Spring中使用atomikos+druid實(shí)現(xiàn)經(jīng)典分布式事務(wù)的方法
這篇文章主要介紹了Spring中使用atomikos+druid實(shí)現(xiàn)經(jīng)典分布式事務(wù)的方法,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2019-06-06
Java遞歸來(lái)實(shí)現(xiàn)漢諾塔游戲,注釋詳細(xì)
這篇文章介紹了Java遞歸來(lái)實(shí)現(xiàn)漢諾塔游戲的方法,文中的代碼注釋介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-11-11
使用LambdaQueryWrapper動(dòng)態(tài)加過(guò)濾條件?動(dòng)態(tài)Lambda
這篇文章主要介紹了使用LambdaQueryWrapper動(dòng)態(tài)加過(guò)濾條件?動(dòng)態(tài)Lambda,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。2022-01-01

