重温java代理模式

2024-05-15 03:48
文章标签 java 模式 代理 重温

本文主要是介绍重温java代理模式,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

文章关键词:java代理,jdk动态代理,cglib代理,AOP,切面编程

今天,逛技术博客时,无意间发现了一篇有关动态代理模式的文章,感觉写的不错,自己正好也在巩固下基础知识,虽然实际工作中用代理的模式的不是特别多,那是因为你使用的框架,已经帮你封装好了,所以,你可能感觉不到,但是感觉不到不但表不存在,了解下它的原理和使用场景还是能提高下逼格的。于是散仙总结了下文,还有一个实战小例子,用来帮助理解。下面开始:

一:什么是代理?
代理模式的作用是:为其他对象提供一种代理以控制对这个对象的访问。在某些情况下,一个客户不想或者不能直接引用另一个对象,而代理对象可以在客户端和目标对象之间起到中介的作用。
代理模式一般涉及到的角色有:
抽象角色:声明真实对象和代理对象的共同接口;
代理角色:代理对象角色内部含有对真实对象的引用,从而可以操作真实对象,同时代理对象提供与真实对象相同的接口以便在任何时刻都能代替真实对象。同时,代理对象可以在执行真实对象操作时,附加其他的操作,相当于对真实对象进行封装。
真实角色:代理角色所代表的真实对象,是我们最终要引用的对象。

说白了,代理模式其实就相当于找房子时的中介,你无须找到真实的房东,就可以把租房子这件事给办了,而且因为中介,所以便有了一些额外增强的功能,所以少数中介会提高房价或黑你一下,当然咱们的程序肯定不是跟中介一个德行的。


二:java中代理的种类
(1)静态代理: 只能提供固定的类的代理,局限性比较大
(2)JDK动态代理:只能代理接口,通过反射,提高了灵活性,但性能稍慢
(3)CGLIB代理:Spring AOP的默认实现,可以代理类,无须提供对应接口,通过ASM(asm是Java字节码操控框架,ASM是一套java字节码生成架构,它可以动态生成二进制格式的stub类或其它代理类,或者在类被java虚拟机装入内存之前,动态修改类)字节码增强,速度要快于JDK的默认的动态代理。


三:使用代理的应用场景

这个问题,其实就跟问Spring AOP切面编程的好处,就非常类似了,通过代理模式,我们可以无侵入式的,很方便的实现日志记录功能,方法权限拦截功能,事务控制等功能。


四:实战例子
项目结构:




百度云盘下载: http://pan.baidu.com/s/1eQ0h5YE
1,JDK动态代理,模拟事务控制功能,已经记录方法的耗时功能 

Java代码 复制代码  收藏代码
  1. package com.easy.model;   
  2. /***  
  3.  *   
  4.  * @author qindongliang  
  5.  *  
  6.  */  
  7. public class Person {   
  8.        
  9.     //用户名   
  10.     private String name;   
  11.   
  12.     public String getName() {   
  13.         return name;   
  14.     }   
  15.   
  16.     public void setName(String name) {   
  17.         this.name = name;   
  18.     }   
  19.        
  20.        
  21.        
  22.     public Person(String name) {   
  23.         super();   
  24.         this.name = name;   
  25.     }   
  26.   
  27.     public Person() {   
  28.         // TODO Auto-generated constructor stub   
  29.     }   
  30.   
  31. }  
package com.easy.model;
/**** * @author qindongliang**/
public class Person {//用户名private String name;public String getName() {return name;}public void setName(String name) {this.name = name;}public Person(String name) {super();this.name = name;}public Person() {// TODO Auto-generated constructor stub}}

Dao接口已经实现类,里面含有测试的方法:
Java代码 复制代码  收藏代码
  1. package com.easy.dao;   
  2.   
  3. import com.easy.model.Person;   
  4. /***  
  5.  * 动态代理测试dao  
  6.  * @author qindongliang  
  7.  *  
  8.  */  
  9. public interface PersonDao {   
  10.     //add user   
  11.     public void addUser(Person user);   
  12.     //delete user   
  13.     public void deleteUser(String name);   
  14.     //update user   
  15.     public void updateUser(String name);   
  16.   
  17. }  
package com.easy.dao;import com.easy.model.Person;
/**** 动态代理测试dao* @author qindongliang**/
public interface PersonDao {//add userpublic void addUser(Person user);//delete userpublic void deleteUser(String name);//update userpublic void updateUser(String name);}

实现类:
Java代码 复制代码  收藏代码
  1. package com.easy.dao.impl;   
  2.   
  3. import com.easy.dao.PersonDao;   
  4. import com.easy.model.Person;   
  5. /***  
  6.  * Dao的实现类  
  7.  * @author qindongliang  
  8.  *  
  9.  */  
  10. public class PersonDaoImpl implements PersonDao {   
  11.   
  12.     @Override  
  13.     public void addUser(Person user) {   
  14.         // TODO Auto-generated method stub   
  15. //      System.out.println("add user name: "+user.getName());   
  16.         try{   
  17.             Thread.sleep(1000);//sleep 1 second   
  18.         }catch(Exception e){   
  19.             e.printStackTrace();   
  20.         }   
  21.     }   
  22.   
  23.     @Override  
  24.     public void deleteUser(String name) {   
  25. //      System.out.println("delete user name: "+name);   
  26.         try{   
  27.             Thread.sleep(1500);//sleep 1.5 second   
  28.         }catch(Exception e){   
  29.             e.printStackTrace();   
  30.         }   
  31.            
  32.     }   
  33.   
  34.     @Override  
  35.     public void updateUser(String name) {   
  36. //      System.out.println("update user name: "+name);   
  37.         try{   
  38.             Thread.sleep(2000);//sleep 2 second   
  39.         }catch(Exception e){   
  40.             e.printStackTrace();   
  41.         }   
  42.     }   
  43.        
  44.   
  45. }  
package com.easy.dao.impl;import com.easy.dao.PersonDao;
import com.easy.model.Person;
/**** Dao的实现类* @author qindongliang**/
public class PersonDaoImpl implements PersonDao {@Overridepublic void addUser(Person user) {// TODO Auto-generated method stub
//		System.out.println("add user name: "+user.getName());try{Thread.sleep(1000);//sleep 1 second}catch(Exception e){e.printStackTrace();}}@Overridepublic void deleteUser(String name) {
//		System.out.println("delete user name: "+name);try{Thread.sleep(1500);//sleep 1.5 second}catch(Exception e){e.printStackTrace();}}@Overridepublic void updateUser(String name) {
//		System.out.println("update user name: "+name);try{Thread.sleep(2000);//sleep 2 second}catch(Exception e){e.printStackTrace();}}}

JDK动态代理实现:
Java代码 复制代码  收藏代码
  1. package com.easy.proxy;   
  2.   
  3. import java.lang.reflect.InvocationHandler;   
  4. import java.lang.reflect.Method;   
  5. import java.text.SimpleDateFormat;   
  6. import java.util.Date;   
  7. /***  
  8.  * JDK动态代理例子  
  9.  * @author qindongliang  
  10.  *  
  11.  */  
  12. public class JDK_Proxy implements InvocationHandler {   
  13.        
  14.     //代理实例   
  15.     private Object proxy;   
  16.     //通过构造参数赋值   
  17.     public JDK_Proxy(Object proxy) {   
  18.         this.proxy = proxy;   
  19.     }   
  20.   
  21.     //格式化时间   
  22.     private static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS");   
  23.        
  24.        
  25.   
  26.   
  27.   
  28.     @Override  
  29.     public Object invoke(Object proxy, Method method, Object[] args)   
  30.             throws Throwable {   
  31.         Object obj=null;   
  32.         //开始时间   
  33.         long start=System.currentTimeMillis();   
  34.         //以add开头的方法,加入事务控制   
  35.         if(method.getName().startsWith("add")){   
  36.             //开启事务   
  37.             startTransaction(method);   
  38.             obj=method.invoke(this.proxy, args);   
  39.             //关闭事务   
  40.             closeTransaction(method);   
  41.         }else{   
  42.             obj=method.invoke(this.proxy, args);   
  43.         }   
  44.            
  45.         //调用结束时间   
  46.         long end=System.currentTimeMillis();   
  47.         System.out.println(sdf.format(new Date())+"  "+method.getName()+"调用方法执行时间为:"+(end-start)/1000+"秒!");   
  48.         System.out.println();   
  49.         return obj;   
  50.     }   
  51.        
  52.     //模拟开启事务   
  53.     public void startTransaction(Method method){   
  54.         System.out.println("请注意:"+method.getName()+"开启了 commit 事务操作 !");   
  55.     }   
  56.        
  57.     //模拟关闭事务   
  58.     public void closeTransaction(Method method){   
  59.         System.out.println("请注意:"+method.getName()+"关闭了 commit 事务操作 !");   
  60.     }   
  61.        
  62.        
  63.        
  64.        
  65.        
  66.        
  67.        
  68.        
  69.   
  70. }  
package com.easy.proxy;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.text.SimpleDateFormat;
import java.util.Date;
/**** JDK动态代理例子* @author qindongliang**/
public class JDK_Proxy implements InvocationHandler {//代理实例private Object proxy;//通过构造参数赋值public JDK_Proxy(Object proxy) {this.proxy = proxy;}//格式化时间private static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS");@Overridepublic Object invoke(Object proxy, Method method, Object[] args)throws Throwable {Object obj=null;//开始时间long start=System.currentTimeMillis();//以add开头的方法,加入事务控制if(method.getName().startsWith("add")){//开启事务startTransaction(method);obj=method.invoke(this.proxy, args);//关闭事务closeTransaction(method);}else{obj=method.invoke(this.proxy, args);}//调用结束时间long end=System.currentTimeMillis();System.out.println(sdf.format(new Date())+"  "+method.getName()+"调用方法执行时间为:"+(end-start)/1000+"秒!");System.out.println();return obj;}//模拟开启事务public void startTransaction(Method method){System.out.println("请注意:"+method.getName()+"开启了 commit 事务操作 !");}//模拟关闭事务public void closeTransaction(Method method){System.out.println("请注意:"+method.getName()+"关闭了 commit 事务操作 !");}}

无接口的cglib代理测试类:
Java代码 复制代码  收藏代码
  1. package com.easy.dao.impl;   
  2.   
  3. /***  
  4.  * 此类没有实现任何接口,只能使用Cglib代理来调用方法  
  5.  * 必须有无参的构造方法  
  6.  * @author qindongliang  
  7.  *  
  8.  */  
  9. public class CarManager {   
  10.        
  11.     private String name;   
  12.        
  13.        
  14.     public CarManager() {   
  15.         // TODO Auto-generated constructor stub   
  16.     }   
  17.        
  18.     public CarManager(String name) {   
  19.         this.name = name;   
  20.     }   
  21.   
  22.   
  23.   
  24.     public String getName() {   
  25.         return name;   
  26.     }   
  27.   
  28.   
  29.   
  30.     public void setName(String name) {   
  31.         this.name = name;   
  32.     }   
  33.   
  34.   
  35.   
  36.     public void run()throws Exception{   
  37.         System.out.println(this.getName()+"汽车启动了!");   
  38.         Thread.sleep(3000);   
  39.     }   
  40.   
  41.        
  42.        
  43.     public void stop(){   
  44.         System.out.println(this.getName()+"汽车停止了!");   
  45.     }   
  46.        
  47.        
  48.        
  49.   
  50. }  
package com.easy.dao.impl;/**** 此类没有实现任何接口,只能使用Cglib代理来调用方法* 必须有无参的构造方法* @author qindongliang**/
public class CarManager {private String name;public CarManager() {// TODO Auto-generated constructor stub}public CarManager(String name) {this.name = name;}public String getName() {return name;}public void setName(String name) {this.name = name;}public void run()throws Exception{System.out.println(this.getName()+"汽车启动了!");Thread.sleep(3000);}public void stop(){System.out.println(this.getName()+"汽车停止了!");}}

  Cglib代理的实现:
Java代码 复制代码  收藏代码
  1. package com.easy.proxy;   
  2.   
  3. import java.lang.reflect.Method;   
  4.   
  5. import net.sf.cglib.proxy.Enhancer;   
  6. import net.sf.cglib.proxy.MethodInterceptor;   
  7. import net.sf.cglib.proxy.MethodProxy;   
  8.   
  9. /***  
  10.  * Cglib代理测试  
  11.  * @author qindongliang  
  12.  */  
  13. public class CGLIB_Proxy implements MethodInterceptor{   
  14.   
  15.     //代理对象   
  16.     private Object target;   
  17.        
  18.        
  19.        
  20.      @SuppressWarnings("unchecked")     
  21.      public static <T> T proxyTarget(T t) {     
  22.             Enhancer en = new Enhancer();     
  23.             en.setSuperclass(t.getClass());     
  24.             en.setCallback(new CGLIB_Proxy(t));     
  25.             T tt = (T) en.create();     
  26.             return tt;     
  27.      }     
  28.        
  29.         
  30.     public CGLIB_Proxy(Object target) {   
  31.         this.target = target;   
  32.     }   
  33.   
  34.   
  35.   
  36.   
  37.   
  38.     @Override  
  39.     public Object intercept(Object arg0, Method method, Object[] args,MethodProxy arg3) throws Throwable {   
  40.            
  41.         System.out.println("调用 "+method.getName()+" 开始......  ");   
  42.         //调用代理   
  43.         Object obj=method.invoke(this.target, args);   
  44.         System.out.println("调用 "+method.getName()+" 结束......  ");   
  45.         return obj;   
  46.     }   
  47.        
  48.        
  49.        
  50.        
  51.        
  52.        
  53.   
  54. }  
package com.easy.proxy;import java.lang.reflect.Method;import net.sf.cglib.proxy.Enhancer;
import net.sf.cglib.proxy.MethodInterceptor;
import net.sf.cglib.proxy.MethodProxy;/**** Cglib代理测试* @author qindongliang*/
public class CGLIB_Proxy implements MethodInterceptor{//代理对象private Object target;@SuppressWarnings("unchecked")  public static <T> T proxyTarget(T t) {  Enhancer en = new Enhancer();  en.setSuperclass(t.getClass());  en.setCallback(new CGLIB_Proxy(t));  T tt = (T) en.create();  return tt;  }  public CGLIB_Proxy(Object target) {this.target = target;}@Overridepublic Object intercept(Object arg0, Method method, Object[] args,MethodProxy arg3) throws Throwable {System.out.println("调用 "+method.getName()+" 开始......  ");//调用代理Object obj=method.invoke(this.target, args);System.out.println("调用 "+method.getName()+" 结束......  ");return obj;}}

测试的代码:
Java代码 复制代码  收藏代码
  1. package com.easy.main;   
  2.   
  3. import java.lang.reflect.InvocationHandler;   
  4. import java.lang.reflect.Proxy;   
  5.   
  6. import com.easy.dao.PersonDao;   
  7. import com.easy.dao.impl.CarManager;   
  8. import com.easy.dao.impl.PersonDaoImpl;   
  9. import com.easy.model.Person;   
  10. import com.easy.proxy.CGLIB_Proxy;   
  11. import com.easy.proxy.JDK_Proxy;   
  12.   
  13. /**  
  14.  * 包含jdk动态代理和cglib代理的测试  
  15.  * @author qindongliang  
  16.  *  
  17.  */  
  18. public class MethodTest {   
  19.        
  20.     public static void main(String[] args) throws Exception {   
  21.         //cglibProxyTest();   
  22.         jdkProxyTest();   
  23.     }   
  24.   
  25.        
  26.     /****  
  27.      * cglib代理测试  
  28.      */  
  29.     public static void cglibProxyTest()throws Exception{   
  30.            
  31.            
  32.         CarManager car=new CarManager("大众");   
  33. //         
  34. //      car.run();   
  35. //      car.stop();   
  36.         //得到代理类对象   
  37.         CarManager carManager=CGLIB_Proxy.proxyTarget(car);   
  38.         carManager.run();   
  39.            
  40.            
  41.            
  42.            
  43.            
  44.     }   
  45.        
  46.        
  47.     /***  
  48.      * jdk动态代理  
  49.      */  
  50.     public static void jdkProxyTest() {   
  51.         PersonDao user=new PersonDaoImpl();   
  52.            
  53.         Class<?> cls=user.getClass();   
  54.            
  55.         InvocationHandler handler=new JDK_Proxy(user);   
  56.            
  57.         //转换得来的代理对象   
  58.         PersonDao proxy=(PersonDao)Proxy.newProxyInstance(cls.getClassLoader(), cls.getInterfaces(), handler);   
  59.            
  60.         proxy.addUser(new Person("hadoop"));   
  61.         proxy.deleteUser("lucene");   
  62.         proxy.updateUser("solr and elasticsearch");   
  63.     }   
  64.        
  65.        
  66.     
  67.        
  68.        
  69.   
  70. }  
package com.easy.main;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Proxy;import com.easy.dao.PersonDao;
import com.easy.dao.impl.CarManager;
import com.easy.dao.impl.PersonDaoImpl;
import com.easy.model.Person;
import com.easy.proxy.CGLIB_Proxy;
import com.easy.proxy.JDK_Proxy;/*** 包含jdk动态代理和cglib代理的测试* @author qindongliang**/
public class MethodTest {public static void main(String[] args) throws Exception {//cglibProxyTest();jdkProxyTest();}/***** cglib代理测试*/public static void cglibProxyTest()throws Exception{CarManager car=new CarManager("大众");
//		
//		car.run();
//		car.stop();//得到代理类对象CarManager carManager=CGLIB_Proxy.proxyTarget(car);carManager.run();}/**** jdk动态代理*/public static void jdkProxyTest() {PersonDao user=new PersonDaoImpl();Class<?> cls=user.getClass();InvocationHandler handler=new JDK_Proxy(user);//转换得来的代理对象PersonDao proxy=(PersonDao)Proxy.newProxyInstance(cls.getClassLoader(), cls.getInterfaces(), handler);proxy.addUser(new Person("hadoop"));proxy.deleteUser("lucene");proxy.updateUser("solr and elasticsearch");}}



测试JDK动态代理结果:





测试cglib代理结果:



总结:使用代理模式,在一些场景,非常灵活,而且无侵入式的发挥巨大的作用,这就是面向切面编程的核心思想。



最后欢迎大家扫码关注微信公众号:我是攻城师(woshigcs),我们一起学习,进步和交流!(woshigcs)
本公众号的内容是有关搜索和大数据技术和互联网等方面内容的分享,也是一个温馨的技术互动交流的小家园,有什么问题随时都可以留言,欢迎大家来访!


参考文章:

http://andy136566.iteye.com/blog/967952
http://www.cnblogs.com/coderworld/p/java-reflect.html
http://blog.csdn.net/leon709/article/details/9529307
http://www.cnblogs.com/coderworld/p/java-dynamic-proxy.htm

这篇关于重温java代理模式的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/990726

相关文章

Java NoClassDefFoundError运行时错误分析解决

《JavaNoClassDefFoundError运行时错误分析解决》在Java开发中,NoClassDefFoundError是一种常见的运行时错误,它通常表明Java虚拟机在尝试加载一个类时未能... 目录前言一、问题分析二、报错原因三、解决思路检查类路径配置检查依赖库检查类文件调试类加载器问题四、常见

Java注解之超越Javadoc的元数据利器详解

《Java注解之超越Javadoc的元数据利器详解》本文将深入探讨Java注解的定义、类型、内置注解、自定义注解、保留策略、实际应用场景及最佳实践,无论是初学者还是资深开发者,都能通过本文了解如何利用... 目录什么是注解?注解的类型内置注编程解自定义注解注解的保留策略实际用例最佳实践总结在 Java 编程

Java 实用工具类Spring 的 AnnotationUtils详解

《Java实用工具类Spring的AnnotationUtils详解》Spring框架提供了一个强大的注解工具类org.springframework.core.annotation.Annot... 目录前言一、AnnotationUtils 的常用方法二、常见应用场景三、与 JDK 原生注解 API 的

Java controller接口出入参时间序列化转换操作方法(两种)

《Javacontroller接口出入参时间序列化转换操作方法(两种)》:本文主要介绍Javacontroller接口出入参时间序列化转换操作方法,本文给大家列举两种简单方法,感兴趣的朋友一起看... 目录方式一、使用注解方式二、统一配置场景:在controller编写的接口,在前后端交互过程中一般都会涉及

Java中的StringBuilder之如何高效构建字符串

《Java中的StringBuilder之如何高效构建字符串》本文将深入浅出地介绍StringBuilder的使用方法、性能优势以及相关字符串处理技术,结合代码示例帮助读者更好地理解和应用,希望对大家... 目录关键点什么是 StringBuilder?为什么需要 StringBuilder?如何使用 St

使用Java将各种数据写入Excel表格的操作示例

《使用Java将各种数据写入Excel表格的操作示例》在数据处理与管理领域,Excel凭借其强大的功能和广泛的应用,成为了数据存储与展示的重要工具,在Java开发过程中,常常需要将不同类型的数据,本文... 目录前言安装免费Java库1. 写入文本、或数值到 Excel单元格2. 写入数组到 Excel表格

Java并发编程之如何优雅关闭钩子Shutdown Hook

《Java并发编程之如何优雅关闭钩子ShutdownHook》这篇文章主要为大家详细介绍了Java如何实现优雅关闭钩子ShutdownHook,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起... 目录关闭钩子简介关闭钩子应用场景数据库连接实战演示使用关闭钩子的注意事项开源框架中的关闭钩子机制1.

Maven中引入 springboot 相关依赖的方式(最新推荐)

《Maven中引入springboot相关依赖的方式(最新推荐)》:本文主要介绍Maven中引入springboot相关依赖的方式(最新推荐),本文给大家介绍的非常详细,对大家的学习或工作具有... 目录Maven中引入 springboot 相关依赖的方式1. 不使用版本管理(不推荐)2、使用版本管理(推

Java 中的 @SneakyThrows 注解使用方法(简化异常处理的利与弊)

《Java中的@SneakyThrows注解使用方法(简化异常处理的利与弊)》为了简化异常处理,Lombok提供了一个强大的注解@SneakyThrows,本文将详细介绍@SneakyThro... 目录1. @SneakyThrows 简介 1.1 什么是 Lombok?2. @SneakyThrows

在 Spring Boot 中实现异常处理最佳实践

《在SpringBoot中实现异常处理最佳实践》本文介绍如何在SpringBoot中实现异常处理,涵盖核心概念、实现方法、与先前查询的集成、性能分析、常见问题和最佳实践,感兴趣的朋友一起看看吧... 目录一、Spring Boot 异常处理的背景与核心概念1.1 为什么需要异常处理?1.2 Spring B