08设计模式之代理模式

用处:aop,日志,程序用时...

分类:

静态代理

动态代理:JDK动态代理,Cglib动态代理等(底层都是用asm实现,直接操作class文件码)

先上类图


代理模式.jpg

案例代码

静态代理

类似装饰者模式,将被代理接口聚合在代理中。

package com.wwj.proxymode;

public class StaticProxy {
    public static void main(String[] args) {
        //new Car().run();
        new StaticLogProxy(new Car()).run();

    }
}

/**
 * 定义交通工具接口
 */
interface Vehicle{
    void run();
}

/**
 * 定义被代理对象
 */
class Car implements Vehicle{
    @Override
    public void run(){
        System.out.println("10m/s的速度前进!!!!!");
    }
}

/**
 * 以打印日志为例
 */
class StaticLogProxy implements Vehicle{
    Vehicle vehicle;

    public StaticLogProxy(Vehicle vehicle) {
        this.vehicle = vehicle;
    }

    @Override
    public void run() {
        System.out.println("日志打印开始===========");
        vehicle.run();
        System.out.println("日志打印结束===========");
    }
}

JDK动态代理

  • spring AOP 被代理对象是接口默认使用JDK的动态代理
  • JDK的动态代理
  • 代理类自动生成,且实现指定的接口
  • 利用asm生成
  • 局限性:被代理对象必须实现接口
package com.wwj.proxymode;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;

/**
 * spring AOP 被代理对象是接口默认使用JDK的动态代理
 * JDK的动态代理
 * 代理类自动生成,且实现指定的接口
 * 利用asm生成
 * 局限性:被代理对象必须实现接口
 */
public class JDKDynamicProxy {
    public static void main(String[] args) {
        JDKCar jdkCar = new JDKCar();
        
        //配置自动生成的反射对象保留在代码中,方便理解
        System.getProperties().put("sun.misc.ProxyGenerator.saveGeneratedFiles","true");

        //利用JDK自动生成代理对象
        JDKVehicle JDKVehicle = (JDKVehicle)Proxy.newProxyInstance(
                JDKCar.class.getClassLoader(),
                new Class[]{JDKVehicle.class},
                new MyInvocationHandler(jdkCar));
        JDKVehicle.run();
    }
}

class MyInvocationHandler implements InvocationHandler{

    /**
     * 聚合被代理接口
     */
    JDKVehicle jdkVehicle;

    public MyInvocationHandler(JDKVehicle jdkVehicle) {
        this.jdkVehicle = jdkVehicle;
    }

    /**
     * 自动生成的代理对象会调用invoke方法
     * @param proxy
     * @param method
     * @param args
     * @return
     * @throws Throwable
     */
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        System.out.println("日志打印开始===========");
        Object invoke = method.invoke(jdkVehicle, args);
        System.out.println("日志打印结束===========");
        return invoke;
    }
}

/**
 * 定义交通工具接口
 */
interface JDKVehicle{
    void run();
}

/**
 * 定义被代理对象
 */
class JDKCar implements JDKVehicle{

    @Override
    public void run(){
        System.out.println("10m/s的速度前进!!!!!");
    }
}

这里可以看到内存中自动生成的代理对象(正常在源码中是看不到的):

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package com.wwj.proxymode;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.lang.reflect.UndeclaredThrowableException;

final class $Proxy0 extends Proxy implements JDKVehicle {
    private static Method m1;
    private static Method m3;
    private static Method m2;
    private static Method m0;

    public $Proxy0(InvocationHandler var1) throws  {
        super(var1);
    }

    public final boolean equals(Object var1) throws  {
        try {
            return (Boolean)super.h.invoke(this, m1, new Object[]{var1});
        } catch (RuntimeException | Error var3) {
            throw var3;
        } catch (Throwable var4) {
            throw new UndeclaredThrowableException(var4);
        }
    }

    public final void run() throws  {
        try {
            super.h.invoke(this, m3, (Object[])null);
        } catch (RuntimeException | Error var2) {
            throw var2;
        } catch (Throwable var3) {
            throw new UndeclaredThrowableException(var3);
        }
    }

    public final String toString() throws  {
        try {
            return (String)super.h.invoke(this, m2, (Object[])null);
        } catch (RuntimeException | Error var2) {
            throw var2;
        } catch (Throwable var3) {
            throw new UndeclaredThrowableException(var3);
        }
    }

    public final int hashCode() throws  {
        try {
            return (Integer)super.h.invoke(this, m0, (Object[])null);
        } catch (RuntimeException | Error var2) {
            throw var2;
        } catch (Throwable var3) {
            throw new UndeclaredThrowableException(var3);
        }
    }

    static {
        try {
            m1 = Class.forName("java.lang.Object").getMethod("equals", Class.forName("java.lang.Object"));
            m3 = Class.forName("com.wwj.proxymode.JDKVehicle").getMethod("run");
            m2 = Class.forName("java.lang.Object").getMethod("toString");
            m0 = Class.forName("java.lang.Object").getMethod("hashCode");
        } catch (NoSuchMethodException var2) {
            throw new NoSuchMethodError(var2.getMessage());
        } catch (ClassNotFoundException var3) {
            throw new NoClassDefFoundError(var3.getMessage());
        }
    }
}

Cglib动态代理

  • spring AOP 被代理对象不是接口默认使用Cglib的动态代理
  • Cglib的动态代理
  • 代理类自动生成,且继承被代理类指定的接口
  • 利用asm生成
package com.wwj.proxymode;

import net.sf.cglib.proxy.Enhancer;
import net.sf.cglib.proxy.MethodInterceptor;
import net.sf.cglib.proxy.MethodProxy;

import java.lang.reflect.Method;

/**
 * spring AOP 被代理对象不是接口默认使用Cglib的动态代理
 *  * Cglib的动态代理
 *  * 代理类自动生成,且继承被代理类指定的接口
 *  * 利用asm生成
 */
public class CglibDynamicProxy {
    public static void main(String[] args) {
        Enhancer enhancer = new Enhancer();
        enhancer.setSuperclass(CglibCar.class);
        enhancer.setCallback(new MyMethodInterceptor());
        CglibCar cglibCar = (CglibCar)enhancer.create();
        cglibCar.run();
    }
}

/**
 * 自定义回调接口
 */
class MyMethodInterceptor implements MethodInterceptor {

    @Override
    public Object intercept(Object o, Method method, Object[] objects, MethodProxy methodProxy) throws Throwable {
        System.out.println("日志打印开始===========");
        Object invoke = methodProxy.invokeSuper(o, objects);
        System.out.println("日志打印结束===========");
        return invoke;
    }
}

/**
 * 定义被代理对象
 */
class CglibCar{
    public void run(){
        System.out.println("10m/s的速度前进!!!!!");
    }
}
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容