A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© tuzunyu 初级黑马   /  2019-1-24 21:25  /  755 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

什么是动态代理(dynamic proxy)
动态代理(以下称代理),利用Java的反射技术(Java Reflection),在运行时创建一个实现某些给定接口的新类(也称“动态代理类”)及其实例(对象)
(Using Java Reflection to create dynamic implementations of interfaces at runtime)。
代理的是接口(Interfaces),不是类(Class),更不是抽象类。
动态代理有什么用
解决特定问题:一个接口的实现在编译时无法知道,需要在运行时才能实现
实现某些设计模式:适配器(Adapter)或修饰器(Decorator)
面向切面编程:如AOP in Spring

创建动态代理
利用Java的Proxy类,调用Proxy.newProxyInstance(),创建动态对象十分简单。

InvocationHandler handler = new MyInvocationHandler(...);Class proxyClass = Proxy.getProxyClass(Foo.class.getClassLoader(), new Class[] { Foo.class });
Foo f = (Foo) proxyClass.         getConstructor(new Class[] { InvocationHandler.class }).         newInstance(new Object[] { handler }); //或更简单
Foo f = (Foo) Proxy.newProxyInstance(Foo.class.getClassLoader(),                                     new Class[] { Foo.class },                                     handler);

Proxy.newProxyInstance()方法有三个参数:
1. 类加载器(Class Loader)
2. 需要实现的接口数组
3. InvocationHandler接口。所有动态代理类的方法调用,都会交由InvocationHandler接口实现类里的invoke()方法去处理。这是动态代理的关键所在。

InvocationHandler接口
接口里有一个invoke()方法。基本的做法是,创建一个类,实现这个方法,利用反射在invoke()方法里实现需求:

public class MyInvocationHandler implements InvocationHandler{  public Object invoke(Object proxy, Method method, Object[] args)  throws Throwable {    //do something "dynamic"  }}

invoke()方法同样有三个参数:
1. 动态代理类的引用,通常情况下不需要它。但可以使用getClass()方法,得到proxy的Class类从而取得实例的类信息,如方法列表,annotation等。
2. 方法对象的引用,代表被动态代理类调用的方法。从中可得到方法名,参数类型,返回类型等等
3. args对象数组,代表被调用方法的参数。注意基本类型(int,long)会被装箱成对象类型(Interger, Long)

动态代理例子1. 模拟AOP
public interface IVehical {    void run();    }//concrete implementationpublic class Car implements IVehical{    public void run() {    System.out.println("Car is running");    }}//proxy classpublic class VehicalProxy {    private IVehical vehical;    public VehicalProxy(IVehical vehical) {    this.vehical = vehical;    }    public IVehical create(){    final Class<?>[] interfaces = new Class[]{IVehical.class};    final VehicalInvacationHandler handler = new VehicalInvacationHandler(vehical);        return (IVehical) Proxy.newProxyInstance(IVehical.class.getClassLoader(), interfaces, handler);    }        public class VehicalInvacationHandler implements InvocationHandler{    private final IVehical vehical;        public VehicalInvacationHandler(IVehical vehical) {        this.vehical = vehical;    }    public Object invoke(Object proxy, Method method, Object[] args)        throws Throwable {        System.out.println("--before running...");        Object ret = method.invoke(vehical, args);        System.out.println("--after running...");                return ret;    }        }}public class Main {    public static void main(String[] args) {        IVehical car = new Car();    VehicalProxy proxy = new VehicalProxy(car);        IVehical proxyObj = proxy.create();    proxyObj.run();    }}/* * output: * --before running... * Car is running * --after running... * */

可以看出,对IVehical接口的调用,会交由Proxy的invoke方法处理,并在不改变run()的源代码下,新增了动态的逻辑(before running/after running),这正式AOP所做的。
深入讲,Proxy.newInstance(ClassLoader loader, Class<?>[] interfaces, InvocationHandler h)做了以下几件事.
(1)根据参数loader和interfaces调用方法 getProxyClass(loader, interfaces)创建代理类$Proxy.
$Proxy0类实现了interfaces的接口,并继承了Proxy类.
(2)实例化$Proxy0并在构造方法中把BusinessHandler传过去,接着$Proxy0调用父类Proxy的构造器,为h赋值,如下:
class Proxy{
   InvocationHandler h=null;
   protected Proxy(InvocationHandler h) {
    this.h = h;
   }
   ...
}

另外,如果将invoke()方法代码改成如下:

    public Object invoke(Object proxy, Method method, Object[] args)        throws Throwable {        System.out.println("--before running...");//        Object ret = method.invoke(vehical, args);        ((IVehical)proxy).run();        System.out.println("--after running...");                return null;    }

结果会是因为run()方法会引发invoke(),而invoke()又执行run(),如此下去变成死循环,最后栈溢出
所以invoke 接口中的proxy参数不能用于调用所实现接口的某些方法(见参考4)。

2. 利用动态代理实现设计模式,修饰器和适配器:
见参考5

3. 在项目中,可以使用动态代理,获取配置文件,非常方便且有优势:
@Target({ElementType.METHOD})@Retention(RetentionPolicy.RUNTIME)@Documentedpublic @interface Value {    /**     * The actual value expression: e.g. "#{systemProperties.myProp}".     */    String value();}/** * config interfaces, map the config properties file: * db.url =  * db.validation = true * db.pool.size = 100 */public interface IConfig {        @Value("db.url")    String dbUrl();        @Value("db.validation")    boolean isValidated();        @Value("db.pool.size")    int poolSize();    }//proxy classpublic final class ConfigFactory {    private ConfigFactory() {}    public static IConfig create(final InputStream is) throws IOException{        final Properties properties = new Properties();    properties.load(is);        return (IConfig) Proxy.newProxyInstance(IConfig.class.getClassLoader(),        new Class[] { IConfig.class }, new PropertyMapper(properties));        }    public static final class PropertyMapper implements InvocationHandler {    private final Properties properties;    public PropertyMapper(Properties properties) {        this.properties = properties;    }    public Object invoke(Object proxy, Method method, Object[] args)        throws Throwable {        final Value value = method.getAnnotation(Value.class);        if (value == null) return null;                    String property = properties.getProperty(value.value());          if (property == null) return (null);                    final Class<?> returns = method.getReturnType();          if (returns.isPrimitive())          {            if (returns.equals(int.class)) return (Integer.valueOf(property));            else if (returns.equals(long.class)) return (Long.valueOf(property));            else if (returns.equals(double.class)) return (Double.valueOf(property));            else if (returns.equals(float.class)) return (Float.valueOf(property));            else if (returns.equals(boolean.class)) return (Boolean.valueOf(property));          }                return property;    }    }}public static void main(String[] args) throws FileNotFoundException, IOException {        IConfig config = ConfigFactory.create(new FileInputStream("config/config.properties"));    String dbUrl = config.dbUrl();    boolean isLoginValidated = config.isValidated();    int dbPoolSize = config.poolSize();    }



0 个回复

您需要登录后才可以回帖 登录 | 加入黑马