使用Jdk实现动态代理

Posted 2022-11-29 auge

一）、创建动态代理的步骤

1、主题接口

2、代理类

3、真实类

4、使用类

1）主体接口中定义了代理类和真实类的的公共接口方法，代理类和真实类分别实现主体接口，真实类实现了接口方法的具体逻辑，代理类也实现了同样的接口方法，在方法中调用真实类的逻辑，相当于拿到了被代理人的授权，执行被代理人拥有的功能。

2）在实用类中，利用java的多态特性，使用公共接口，接收代理类，接收代理类对象，使用代理类调用公共方法，实现真实类的具体逻辑。

二）、使用jdk实现动态代理

一、为什么要使用动态代理？

1）、原有的静态代理一个接口对应一个代理类，当真实主题很多时，要写多个代理类

2）、当接口有变动时，真实类和代理类都要变动。使用了动态代理，代理类是动态的生成的，代理类动态的实现公共接口的方法

二、步骤

1、主题接口

2、真实类

3、InvocationHanlder接口的实现类

Proxy.newInstance(ClassLoader loader, class<?>[] inteface,          InvocationHander hanlder)   //创建一个代理实例

    invoke(Object proxy, Method method, args)//代理类的实现逻辑

4、使用类

三）、使用动态代理实现数据库查询的延迟加载

主题接口：

/**
 * 数据库查询的公共接口
 */
public interface DBQueryInterface 
    public String request();

真实类：

public class DBQuery implements DBQueryInterface
    /**
     * 模拟重量级对象，对象初始化时需要进行数据库连接
     */
    DBQuery()
        try 
            Thread.sleep(10000);
         catch (InterruptedException e) 
            e.printStackTrace();
        
    
    /**
     * 数据库查询的具体逻辑实现
     * @return
     */
    @Override
    public String request() 
        return "我正在执行数据库查询操作";
    

动态代理类：

public class DBQueryJdkProxy implements InvocationHandler 
    DBQuery dbQuery = null;
    /**
     * 获取代理对象
     */
    public Object bind()
        return Proxy.newProxyInstance(ClassLoader.getSystemClassLoader(), new Class[]DBQueryInterface.class, new DBQueryJdkProxy());
    

    /**
     * invoke方法是代理逻辑的具体实现
     */
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable 
        if(dbQuery == null)
            //延迟加载，当使用到时才创建重量级对象
            dbQuery = new DBQuery();
        
       return dbQuery.request();
    

使用类：

public class Client 
    public static void main(String[] args) 
        //初始化时先加载代理对象
        DBQueryInterface JdkProxy= (DBQueryInterface) new DBQueryJdkProxy().bind();
        //使用时才创建真实的对象
        String result = JdkProxy.request();
        System.out.println(result);
    

结果：

我正在执行数据库查询操作

改进： 使用动态代理实现延迟加载同时增强原有类的功能

主题接口：

/**
 * 数据库查询的公共接口
 */
public interface DBQueryInterface 
    public String request();

真实类：

public class DBQuery implements DBQueryInterface
    /**
     * 模拟重量级对象，对象初始化时需要进行数据库连接
     */
    DBQuery()
        try 
            Thread.sleep(10000);
         catch (InterruptedException e) 
            e.printStackTrace();
        
    
    /**
     * 数据库查询的具体逻辑实现
     * @return
     */
    @Override
    public String request() 
        return "我正在执行数据库查询操作";
    

动态代理类：

/**
 * 使用动态代理创建数据库查询的代理对象
 * 1、实现InvocationHandler接口
 * 2、调用Proxy.newInstance()动态的创建代理对象
 */
public class DBQueryJdkProxy implements InvocationHandler 
    Object target;
    /**
     * 获取代理对象
     */
    public Object bind(Object target)//target是真实类对象，给给定的真实类对象创建一个代理，由代理去完成真实类的工作
        this.target = target;
        return Proxy.newProxyInstance(target.getClass().getClassLoader(), target.getClass().getInterfaces(), this);
    

    /**
     * 增强原有类的功能
     */
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable 
        System.out.println("事物开始");
        System.out.println(method.invoke(target, args));
        System.out.println("事物结束");
        return null;
    

使用类：

public class Client 
    public static void main(String[] args) 
        //加载数据库查询代理工厂
        DBQueryJdkProxy dbQueryJdkProxy = new DBQueryJdkProxy();
        //给指定的对象创建代理工厂
        DBQueryInterface proxy = (DBQueryInterface) dbQueryJdkProxy.bind(new DBQuery());
        proxy.request();