当前位置：首页 > news >正文

Java中的代理模式

news 2025/7/20 16:49:33

Java中的代理模式

- 1. 静态代理
- 2. JDK动态代理
- 3. CGLib动态代理

1. 静态代理

接口

public interface ICeo {void meeting(String name) throws InterruptedException;
}

目标类

public class Ceo implements ICeo{public void meeting(String name) throws InterruptedException {Thread.sleep(2000);System.out.println("和"+name+"谈成了34亿的项目");}
}

代理类

public class CeoProxy implements ICeo{private Ceo ceo;public CeoProxy(Ceo ceo) {this.ceo = ceo;}@Overridepublic void meeting(String name) throws InterruptedException {System.out.println("秘书登记来访: "+name);StopWatch stopWatch = new StopWatch();stopWatch.start();ceo.meeting(name);stopWatch.stop();double totalTimeMillis = stopWatch.getTotalTimeSeconds();System.out.println("耗时: "+totalTimeMillis);}
}

测试

public class CeoTest {public static void main(String[] args) throws InterruptedException {Ceo ceo = new Ceo();CeoProxy ceoProxy = new CeoProxy(ceo);ceoProxy.meeting("XXX");}
}

2. JDK动态代理

接口

public interface IDao {void select();
}

目标类

public class UserDao implements IDao{@Overridepublic void select() {try {Thread.sleep(2000);System.out.println("select ----");} catch (InterruptedException e) {throw new RuntimeException(e);}}
}

动态代理类
在这里插入图片描述

public class JdkProxy implements InvocationHandler {private Object target;public JdkProxy(Object target) {this.target = target;}@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {StopWatch stopWatch = new StopWatch();System.out.println("前置方法");stopWatch.start();Object obj = method.invoke(target, args);stopWatch.stop();System.out.println("后置方法");System.out.println("耗时: "+stopWatch.getTotalTimeSeconds());return obj;}
}

测试

public class DaoTest {public static void main(String[] args) {UserDao userDao = new UserDao();IDao dao = (IDao) Proxy.newProxyInstance(UserDao.class.getClassLoader(), UserDao.class.getInterfaces(), new JdkProxy(new UserDao()));dao.select();}
}

总结:

动态生成代理类
通过实现接口生成代理类(目标接口必须实现接口)
代理类是实现接口的方式
调用目标类使用反射调用
目标类调用本类方法只会代理一次

3. CGLib动态代理

在这里插入图片描述

目标类

public class ZlmDao {public void select(){try {Thread.sleep(2000);System.out.println("select ---");} catch (InterruptedException e) {throw new RuntimeException(e);}}
}

代理类

public class CglibProxy implements MethodInterceptor {@Overridepublic Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable {StopWatch stopWatch = new StopWatch();stopWatch.start();System.out.println("前置增强");Object result = proxy.invokeSuper(obj, args);stopWatch.stop();System.out.println("后置增强");System.out.println("耗时: "+stopWatch.getTotalTimeSeconds());return result;}
}

测试

public class ZlmDaoTest {public static void main(String[] args) {//实例化增强器Enhancer enhancer = new Enhancer();//设置需要代理的目标类enhancer.setSuperclass(ZlmDao.class);//设置拦截对象回调的实现类enhancer.setCallback(new CglibProxy());//生成代理类ZlmDao zlmDao = (ZlmDao) enhancer.create();zlmDao.select();}
}