jdk動態代理要對一個類別進行代理,被代理的類別必須實作至少一個接口,並且只有接口中的方法才能被代理。
jdk實現動態代理一般分為三步驟:
1.編寫介面和實作類別。
2.寫一個處理器,該處理器實現InvocationHandler接口,該接口只有一個方法,其簽名為public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable;可在該處理器的實作方法中,在方法呼叫前和呼叫後加入自己的程式碼,從而進行動態攔截。要注意的是proxy為生成的動態代理類,並不是真的我們被代理的類,所以可在處理器中加入Object類型的成員變量,指向我們真正要求被代理的類(即第1步中的實作類別)。
3.使用java.lang.reflect.Proxy類別的newProxyInstance方法產生動態代理類別。對所有要代理方法的調用,都是直接調用產生的動態代理類別的方法即可,但是要先對它進行強制類型轉換,轉換成我們要調用的方法的接口。
JDK原理分析:
透過分析Proxy的原始碼,可看到動態代理類別的詳細產生。 newProxyInstance方法先產生動態代理類別的Class實例,再呼叫它的參數類型為InvocationHandler的建構子來產生動態代理類別並傳回。
動態代理類別的Class實例是怎麼產生的呢,是透過ProxyGenerator類別來產生動態代理類別的class位元組流,把它載入方法區。
分析class位元組流產生的過程可以看到它使用Proxy為它的父類,實作所有要代理的介面的方法,每個方法的實作體裡主要都是呼叫處理器的invoke方法。
class位元組流的產生過程的主要程式碼如下:
複製代碼代碼如下:
private byte[] generateClassFile()
{
addProxyMethod(hashCodeMethod, java/lang/Object);
addProxyMethod(equalsMethod, java/lang/Object);
addProxyMethod(toStringMethod, java/lang/Object);
for(int i = 0; i < interfaces.length; i++)
{
Method amethod[] = interfaces[i].getMethods();
for(int k = 0; k < amethod.length; k++)
addProxyMethod(amethod[k], interfaces[i]);
}
List list;
for(Iterator iterator = proxyMethods.values().iterator(); iterator.hasNext(); checkReturnTypes(list))
list = (List)iterator.next();
try
{
methods.add(generateConstructor());
for(Iterator iterator1 = proxyMethods.values().iterator(); iterator1.hasNext();)
{
List list1 = (List)iterator1.next();
Iterator iterator2 = list1.iterator();
while(iterator2.hasNext())
{
ProxyMethod proxymethod = (ProxyMethod)iterator2.next();
fields.add(new FieldInfo(proxymethod.methodFieldName, "Ljava/lang/reflect/Method;", 10));
methods.add(<SPAN style="COLOR: red">proxymethod.generateMethod()</SPAN><SPAN style="COLOR: #000000">);</SPAN>
複製代碼代碼如下:
}
}
methods.add(generateStaticInitializer());
}
catch(IOException ioexception)
{
throw new InternalError("unexpected I/O Exception");
}
if(methods.size() > 65535)
throw new IllegalArgumentException("method limit exceeded");
if(fields.size() > 65535)
throw new IllegalArgumentException("field limit exceeded");
cp.getClass(dotToSlash(className));
cp.getClass("java/lang/reflect/Proxy");
for(int j = 0; j < interfaces.length; j++)
cp.getClass(dotToSlash(interfaces[j].getName()));
cp.setReadOnly();
ByteArrayOutputStream bytearrayoutputstream = new ByteArrayOutputStream();
DataOutputStream dataoutputstream = new DataOutputStream(bytearrayoutputstream);
try
{
dataoutputstream.writeInt(-889275714);
dataoutputstream.writeShort(0);
dataoutputstream.writeShort(49);
cp.write(dataoutputstream);
dataoutputstream.writeShort(49);
dataoutputstream.writeShort(cp.getClass(dotToSlash(className)));
dataoutputstream.writeShort(cp.getClass("java/lang/reflect/Proxy"));
dataoutputstream.writeShort(interfaces.length);
for(int l = 0; l < interfaces.length; l++)
dataoutputstream.writeShort(cp.getClass(dotToSlash(interfaces[l].getName())));
dataoutputstream.writeShort(fields.size());
FieldInfo fieldinfo;
複製代碼代碼如下:
//新增屬性
for(Iterator iterator3 = fields.iterator(); iterator3.hasNext(); fieldinfo.write(dataoutputstream))
fieldinfo = (FieldInfo)iterator3.next();
//新增方法
dataoutputstream.writeShort(methods.size());
MethodInfo methodinfo;
for(Iterator iterator4 = methods.iterator(); iterator4.hasNext(); methodinfo.write(dataoutputstream))
methodinfo = (MethodInfo)iterator4.next();
dataoutputstream.writeShort(0);
}
catch(IOException ioexception1)
{
throw new InternalError("unexpected I/O Exception");
}
return bytearrayoutputstream.toByteArray();
}
註:程式碼中加紅部分proxymethod.generateMethod()為每個方法產生方法體,透過查看原始碼可以看出都是在呼叫InvocationHandler介面的實作處理器的invoke方法。