Spring-AOP代理模式

2017-07-19  本文已影响0人  yzw12138

一、代理模式分类

二、静态代理

public class Car implements Moveable {
    
    @Override
    public void move() {
    
        try {
            Thread.sleep(new Random().nextInt(1000));
            System.out.println("汽车行驶中。。。");
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
public class Car2 extends Car {

    @Override
    public void move() {
        long starttime=System.currentTimeMillis();
        System.out.println("汽车开始行驶。。。");
        super.move();
        long endtime=System.currentTimeMillis();
        System.out.println("汽车结束行驶。。。"+"用时:"+
        (endtime-starttime)+"毫秒");
    }   
}

聚合:一个类中调用另一个类的对象(两者实现相同接口)。在代理类中声明被代理类的对象,并通过构造方法将对象传进来(初始化)。在代理类的接口方法中调用被代理类对象的方法,并在方法前后增加相应代理业务逻辑。

public class Car3 implements Moveable {

    private Car car;
    
    public Car3(Car car) {
        super();
        this.car = car;
    }

    @Override
    public void move() {
        long starttime=System.currentTimeMillis();
        System.out.println("汽车开始行驶。。。");
        car.move();
        long endtime=System.currentTimeMillis();
        System.out.println("汽车结束行驶。。。"+"用时:"+
        (endtime-starttime)+"毫秒");
    }
}

在创建一个日志代理,

public class CarLogProxy implements Moveable {

    private Moveable m;
    
    public CarLogProxy(Moveable m) {
        super();
        this.m = m;
    }

    @Override
    public void move() {
        System.out.println("日志开始");
        m.move();
        System.out.println("日志结束");
    }
}
        Car car=new Car();
        CarTimeProxy ctp=new CarTimeProxy(car);
        CarLogProxy clp=new CarLogProxy(ctp);
        clp.move();
                /*
                *日志开始
                *汽车开始行驶。。。
                *汽车行驶中。。。
                *汽车结束行驶。。。用时:137毫秒
                *日志结束
                */

当想要先输出汽车行驶代理,在输出日志代理,只需要更改main方法中代理的顺序即可。

三、动态代理

Paste_Image.png Paste_Image.png
public class TimeHandler implements InvocationHandler {

    private Object target;
    
    public TimeHandler(Object target) {
        super();
        this.target = target;
    }
    /*
     * proxy:被代理的对象
     * method:被代理对象的方法
     * args:方法的参数
     * 返回值:调用方法的返回值
     */
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        long starttime=System.currentTimeMillis();
        System.out.println("汽车开始行驶。。。");
        method.invoke(target);
        long endtime=System.currentTimeMillis();
        System.out.println("汽车结束行驶。。。"+"用时:"+
        (endtime-starttime)+"毫秒");
        return null;
    }
}

创建接口

public interface Moveable {
    public void move(); 
}

实现接口类

public class Car implements Moveable {
    
    @Override
    public void move() {
    
        try {
            Thread.sleep(new Random().nextInt(1000));
            System.out.println("汽车行驶中。。。");
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

调用Proxy的静态方法

public class Test {
    /*
     * 动态代理测试类
     */
    public static void main(String[] args) {
        Car car=new Car();
        InvocationHandler h=new TimeHandler(car);
        ClassLoader loader=car.getClass().getClassLoader();
        Class[] interfaces=car.getClass().getInterfaces();
        /*
         * loader:被代理类的类加载器
         * interfaces:实现的接口
         * h:InvocationHandler实现
         */
        Moveable m=(Moveable) Proxy.newProxyInstance(loader, interfaces, h);
        m.move();
    }
}

四、CGLIB代理

public class CglibProxy implements MethodInterceptor {
    //创建代理类属性
    private Enhancer enhance=new Enhancer();
    //传递需要代理的类
    public Object getProxy(Class clazz){
        //设置创建子类的类
        enhance.setSuperclass(clazz);
        enhance.setCallback(this);
        
        return enhance.create();
    }

    /*
     * 拦截所有目标类方法的调用
     * obj:目标类的实例
     * m:目标方法的返回对象
     * args:方法的参数
     * proxy:代理类实例
     */
    @Override
    public Object intercept(Object obj, Method m, Object[] args, MethodProxy proxy) throws Throwable {
        System.out.println("日志开始。。。");
        //代理类调用父类方法
        proxy.invokeSuper(obj, args);
        System.out.println("日直结束。。。");
        return null;
    }
}
        CglibProxy proxy=new CglibProxy();
        Train t=(Train) proxy.getProxy(Train.class);
        t.move();
上一篇 下一篇

猜你喜欢

热点阅读