jdk动态代理使用及原理详解编程语言

/** 
 * 被代理接口 
 */ 
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("----------------------------------------"); 
    } 
}

/** 
 * 车类接口 
 */ 
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(); 
    }

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();} } }