jdk动态代理的使用
1.创建实现InvocationHandler接口的类，实现invoke(Object proxy, Method method, Object[] args)接口，其中invoke（）执行的方法就为代理实例对象执行的方法。
其中proxy为代理对象，method为方法，args为方法的参数。
要想在原类方法上在进行再处理（如记录日志等），需要用构造方法把接口子类的实例传入，用method.invoke(原对象,args),则执行invoke里的函数原函数。
2.创建代理实例对象
public static <T> T getProxy(Class<T> inf){
return (T) Proxy.newProxyInstance(inf.getClassLoader(),new Class[]{inf},new ProxyInvocationHandler());
}
其中inf为借口,第一个参数为借口的类加载器,第二个参数为接口的Class数组,第三个为代理的执行体。
最后根据返回的接口代理实例对象执行相应的方法即可。
/** * 被代理接口 */ public interface Myinterface { public List<Object> queryList(); public String getName(); } /** * 代理方法,Mybatis中接口无实例类, * 所以此处理并不是在方法执行前后加日志等处理 * 而是生成数据库操作执行体 */ public class MapperProxy implements InvocationHandler { @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { //当方法名为queryList时 if (method.getName().equals("queryList")) { List list = new ArrayList(); list.add("方法名为queryList()的代理执行结果"); list.add(2); list.add("autumn"); return list; } //当放回类型为String时 if (method.getReturnType().toString().equals(String.class.toString())){ return "查询数据库返回的字符串"; } return null; } } /** * 根据接口名称获取代理实例 */ public class SqlSession { /** * 获取接口代理对象实例 * @param inf 接口 * @param <T> 该接口的代理对象实例 * @return */ public static <T> T getMapper(Class<T> inf){ return (T)Proxy.newProxyInstance(inf.getClassLoader(),new Class[]{inf},new MapperProxy()); } } /** * 测试接口无子类代理对象 */ public class Demo { public static void main(String[] args) { Myinterface inf = SqlSession.getMapper(Myinterface.class); List<Object> result = inf.queryList(); System.out.println("返回结果："+result); System.out.println("----------------------------------------"); System.out.println("返回结果："+inf.getName()); System.out.println("----------------------------------------"); } }
还有一种用法是传递接口的子类实例对象，在子类的实例对象方法执行前后加上其他操作（如日志处理等），传送门。
jdk动态代理原理
jdk动态代理主要是一个构造函数newProxyInstance(ClassLoader loader, Class<?>[] interfaces, InvocationHandler h)的原理
/** * 车类接口 */ public interface Moveable { public void move(); } /** * 车类接口具体实现类 */ public class Car implements Moveable { @Override public void move() { try { Thread.sleep(new Random().nextInt(3*1000)); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("car is running..."); } } /** * 模拟jdk中的InvocationHandler接口 */ public interface InvocationHandler { public void invoke(Object o, Method m); } /** * 代理实例的处理方法 * 在原本的实例基础上进行增加功能 * 接口也可以无子类,直接通过接口方法名调用代理的invoke方法 */ public class TimeHandler implements InvocationHandler { private Object target; public TimeHandler(Object target) { super(); this.target = target; } @Override public void invoke(Object o, Method m) { try { long starttime = System.currentTimeMillis(); System.out.println("开始计时...."); m.invoke(target); long endtime = System.currentTimeMillis(); System.out.println("计时结束,用时" + (endtime - starttime) + "毫秒"); } catch (Exception e) { e.printStackTrace(); } } } public class Proxy { /** * 根据接口动态生成接口的子类对象并实现方法体,执行方法为h的invoke * @param infce 被代理接口 * @param h 被代理类的方法执行体 * @return * @throws Exception */ @SuppressWarnings("unchecked") public static Object newProxyInstance(Class infce,InvocationHandler h) throws Exception{ String rt = "\r\n"; String methodStr = ""; for(Method m : infce.getMethods()){ methodStr += " @Override" + rt + " public void " + m.getName() + "() {" + rt + " try{" + rt + " Method md = " + infce.getName() + ".class.getMethod(\"" + m.getName() + "\");" + rt + " h.invoke(this,md);" +rt+ " }catch(Exception e){ e.printStackTrace();}" + rt + " }" ; } String str = "package com.qy.dymanic.jdkproxycode;" + rt + "import java.lang.reflect.Method;" + rt + "import com.qy.dymanic.jdkproxycode.InvocationHandler;" + rt+ "public class $Proxy0 implements " + infce.getName() + " {" + rt + " public $Proxy0(InvocationHandler h) {" + rt + " this.h = h;" + rt + " }" + rt + " private InvocationHandler h;" + rt+ methodStr + rt + "}" ; //产生代理类的java文件 String filename = System.getProperty("user.dir") +"/bin/com/qy/dymanic/jdkproxycode/$Proxy0.java"; File file = new File(filename); FileUtils.writeStringToFile(file, str); //编译 //拿到编译器 JavaCompiler complier = ToolProvider.getSystemJavaCompiler(); //文件管理者 StandardJavaFileManager fileMgr = complier.getStandardFileManager(null, null, null); //获取文件 Iterable units = fileMgr.getJavaFileObjects(filename); //编译任务 CompilationTask t = complier.getTask(null, fileMgr, null, null, null, units); //进行编译 t.call(); fileMgr.close(); //load 到内存 ClassLoader cl = ClassLoader.getSystemClassLoader(); Class c = cl.loadClass("com.qy.dymanic.jdkproxycode.$Proxy0"); Constructor ctr = c.getConstructor(InvocationHandler.class); return ctr.newInstance(h); } } /** * 模拟jdk动态代理源码 * @throws Exception */ public static void main(String[] args) throws Exception { Car car = new Car(); InvocationHandler h = new TimeHandler(car); Moveable m = (Moveable)Proxy.newProxyInstance(Moveable.class,h); m.move(); }
会在bin目录下生成两个文件
其中生成的$Proxy0.java代码如下，此类为动态生成的接口的代理实例类。
package com.qy.dymanic.jdkproxycode; import java.lang.reflect.Method; import com.qy.dymanic.jdkproxycode.InvocationHandler; public class $Proxy0 implements com.qy.dymanic.jdkproxycode.Moveable { public $Proxy0(InvocationHandler h) { this.h = h; } private InvocationHandler h; @Override public void move() { try{ Method md = com.qy.dymanic.jdkproxycode.Moveable.class.getMethod("move"); h.invoke(this,md); //这个是重点！！！InvocationHandler调用它的invoke（代理类，方法名）
}catch(Exception e){ e.printStackTrace();} } }
源码