CGLib代理

简介: CGLib代理

CGLib代理


代理为控制要访问的目标对象提供了一种途径。当访问对象时,它引入了一个间接的层。JDK自从1.3版本开始,就引入了动态代理,并且经常被用来动态地创建代理。JDK的动态代理用起来非常简单,当它有一个限制,就是使用动态代理的对象必须实现一个或多个接口。如果想代理没有实现接口的继承的类,我们可以使用CGLib动态代理。


动态代理的选用:


  1. 目标对象要求实现接口,使用jdk动态代理。
  2. 目标对象不需要实现接口,用CGLib代理。


CGLlb整体架构


b7a1c91b6617471681e674189c4a8795.png


我们发现,cglib字节码层面的操作技术主要依赖ASM提供的能力


代理调用过程图

ca78c9de432f4872b3f84a71ebc9cdbe.png


从图中可以看出:


  1. 客户端调用代理对象的被代理方法
  2. 代理对象将调用委派给方法拦截器统一接口intercept
  3. 方法拦截器中执行前置操作,然后调用方法代理的统一接口invokeSuper
  4. 方法代理的invokeSuper初始化代理对象的和被代理对象的fastClass
  5. 初始化后,再调用代理对象的fastClass
  6. 代理对象的fastClass能够fast的调用代理的代理对象
  7. 代理对象再调用被代理对象的被代理方法
  8. 调用栈弹出,到intercept中再执行后置操作,方法调用结束


fastClass机制


FastClass机制:将类的方法信息解析出来,然后为其建立索引。调用的时候,只要传索引,就能找到相应的方法进行调用。可分为三步:为所有的方法建立索引调用前先根据方法信息寻找到索引调用时根据索匹配相应的方法进行直接调用


CGLib运行时会生成三个class文件


  1. 代理类
  2. 代理类对应的fastClass
  3. 被代理类的fastClass


案例

使用的依赖


<dependency>
  <groupId>cglib</groupId>
  <artifactId>cglib</artifactId>
  <version>3.2.2</version>
</dependency>
<dependency>
  <groupId>asm</groupId>
  <artifactId>asm</artifactId>
  <version>3.3.1</version>
</dependency>
<dependency>
  <groupId>asm</groupId>
  <artifactId>asm-commons</artifactId>
  <version>3.3</version>
</dependency>
<dependency>
  <groupId>asm</groupId>
  <artifactId>asm-tree</artifactId>
  <version>3.3</version>
</dependency>


import com.bank.service.UserService;
import com.bank.service.impl.UserServiceImpl;
import net.sf.cglib.proxy.InvocationHandler;
import net.sf.cglib.proxy.Proxy;
import org.apache.log4j.Logger;
import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.HashMap;
/**
 * TODO jdk动态代理实现日志功能
 *
 * @author qijian.
 * @date 2021/8/19 11:01
 */
public class LogInvoHandler implements InvocationHandler {
    private Logger logger = Logger.getLogger(this.getClass().getSimpleName());
    /**
     * 代理目标
     */
    private Object target;
    /**
     * 代理对象
     */
    private Object proxy;
    private static HashMap<Class<?>, LogInvoHandler> invoHandlers = new HashMap<Class<?>, LogInvoHandler>();
    /**
     * 构造函数私有化
     */
    private LogInvoHandler(){}
    /**
     * 通过Class来生成动态代理对象Proxy
     * @param clazz
     * @return
     */
    public synchronized static<T> T getProxyInstance(Class<T> clazz){
        LogInvoHandler invoHandler = invoHandlers.get(clazz);
        if(null == invoHandler){
            invoHandler = new LogInvoHandler();
            try {
                T tar = clazz.newInstance();
                invoHandler.setTarget(tar);
                invoHandler.setProxy(Proxy.newProxyInstance(tar.getClass().getClassLoader(),
                        tar.getClass().getInterfaces(), invoHandler));
            } catch (Exception e) {
                e.printStackTrace();
            }
            invoHandlers.put(clazz, invoHandler);
        }
        return (T)invoHandler.getProxy();
    }
    /**
     * 代理方法逻辑
     * @param proxy 代理对象
     * @param method 当前调度方法
     * @param args 当前方法参数
     * @return 代理结果返回
     * @throws Throwable 异常
     */
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        Object result = method.invoke(target, args); // 执行业务处理
        // 打印日志
        logger.info("____invoke method: " + method.getName()
                + "; args: " + (null == args ? "null" : Arrays.asList(args).toString())
                + "; return: " + result);
        return result;
    }
    public Object getTarget() {
        return target;
    }
    public void setTarget(Object target) {
        this.target = target;
    }
    public Object getProxy() {
        return proxy;
    }
    public void setProxy(Object proxy) {
        this.proxy = proxy;
    }
    public static void main(String[] args) throws Exception {
        System.out.println(new LogInvoHandler().logger);
        UserService userService = LogInvoHandler.getProxyInstance(UserServiceImpl.class);
        userService.selectUser("1514509301926");
    }
}


在spring之中使用


使用依赖:


    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-core</artifactId>
      <version>5.3.6</version>
    </dependency>


创建UserManager


public interface UserManager {
    // 新增用户抽象方法
    void addUser(String userName, String password);
    // 删除用户抽象方法
    void delUser(String userName);
}


创建UserManagerImpl并继承UserManager


public class UserManagerImpl implements UserManager {
    @Override
    public void addUser(String userName, String password) {
        System.out.println("正在执行添加用户方法");
        System.out.println("用户名称: " + userName + " 密码: " + password);
    }
    @Override
    public void delUser(String userName) {
        System.out.println("正在执行删除用户方法");
        System.out.println("用户名称: " + userName);
    }
}


创建织入类


public class MyAspect {
    public void myBefore() {
        System.out.println("方法执行之前");
    }
    public void myAfter() {
        System.out.println("方法执行之后");
    }
}


代理类


import java.lang.reflect.Method;
import org.springframework.cglib.proxy.Enhancer;
import org.springframework.cglib.proxy.MethodInterceptor;
import org.springframework.cglib.proxy.MethodProxy;
/**
 * CGLIB动态代理,实现MethodInterceptor接口
 *
 * @author 编程帮
 *
 */
public class CglibProxy implements MethodInterceptor {
    private Object target;// 需要代理的目标对象
    final MyAspect myAspect = new MyAspect();
    // 重写拦截方法
    @Override
    public Object intercept(Object obj, Method method, Object[] arr, MethodProxy proxy) throws Throwable {
        myAspect.myBefore();
        Object invoke = method.invoke(target, arr);// 方法执行,参数:target目标对象 arr参数数组
        myAspect.myAfter();
        return invoke;
    }
    // 定义获取代理对象方法
    public Object getCglibProxy(Object objectTarget) {
        // 为目标对象target赋值
        this.target = objectTarget;
        Enhancer enhancer = new Enhancer();
        // 设置父类,因为CGLIB是针对指定的类生成一个子类,所以需要指定父类
        enhancer.setSuperclass(objectTarget.getClass());
        enhancer.setCallback(this);// 设置回调
        Object result = enhancer.create();// 创建并返回代理对象
        return result;
    }
    public static void main(String[] args) {
        CglibProxy cglib= new CglibProxy();// 实例化CglibBProxy对象
        UserManager user = (UserManager) cglib.getCglibProxy(new UserManagerImpl());// 获取代理对象
        user.addUser("bianchengbang", "www.biancheng.net"); // 执行新增方法
        user.delUser("bianchengbang"); // 执行删除方法
    }
}


JDK代理和CGLIB代理的区别


JDK 动态代理是利用反射机制生成一个实现代理接口的匿名类,在调用具体方法前调用InvokeHandler来处理。而 CGLIB 动态代理是利用 ASM 开源包,加载代理对象类的 class 文件,通过修改其字节码生成子类来处理。


JDK 动态代理只能对实现了接口的类生成代理,而不能针对类。


CGLIB 是针对类实现代理,主要是对指定的类生成一个子类,覆盖其中的方法。因为是继承,所以该类或方法不能声明成 final 类型。


JDK动态代理特点


  • 代理对象必须实现一个或多个接口
  • 以接口的形式接收代理实例,而不是代理类


CGLIB动态代理特点


  • 代理对象不能被 final 修饰
  • 以类或接口形式接收代理实例


JDK与CGLIB动态代理的性能比较


生成代理实例性能:JDK > CGLIB

代理实例运行性能:JDK > CGLIB

子类来处理。

JDK 动态代理只能对实现了接口的类生成代理,而不能针对类。

CGLIB 是针对类实现代理,主要是对指定的类生成一个子类,覆盖其中的方法。因为是继承,所以该类或方法不能声明成 final 类型。



JDK动态代理特点


  • 代理对象必须实现一个或多个接口
  • 以接口的形式接收代理实例,而不是代理类


CGLIB动态代理特点


  • 代理对象不能被 final 修饰
  • 以类或接口形式接收代理实例


JDK与CGLIB动态代理的性能比较


生成代理实例性能:JDK > CGLIB

代理实例运行性能:JDK > CGLIB


相关文章
|
C++ 索引
vscode clangd c++开发常见问题和解决方案
vscode clangd c++开发常见问题和解决方案
3576 0
收集的几个国外在线接收短信验证码的网站
有时候,在某些平台上,我们可能需要注册一个临时账号。而注册过程中又需要输入手机号进行短信验证,但是我们又不想泄露隐私,所以这时候一些临时短信接收服务便派上了用场。以下收集的网站都是在线提供一些国外手机号,当你需要进行短信验证的时候(比如注册某个账号),这时你可以使用网站上的提供手机号进行接码,网站上会公开短信的所有内容。
43345 0
|
缓存 Go 数据格式
千万不要在Go IO上踩这些雷!
千万不要在Go IO上踩这些雷!
226 0
|
7月前
|
人工智能 监控 安全
从 DeepSeek 敏感信息泄露谈可观测系统的数据安全预防
探讨了 SLS 中增强数据安全的几种方式:权限精细化管控有效减少了潜在安全风险;接入层脱敏技术阻止敏感数据落库,提升了隐私保护;StoreView 字段集控制通过限制查询数据范围,降低数据泄露损害。智能监控系统提供实时监测,快速识别并阻断异常拖库行为,为企业提供了迅速响应和抵御威胁的能力。
|
网络协议 算法 关系型数据库
MySQL8 中文参考(八十四)(5)
MySQL8 中文参考(八十四)
412 5
|
11月前
|
存储 监控 数据可视化
设计行业如何借助协作软件提升团队协作力?
随着设计项目规模和复杂性的增加,设计行业越来越依赖协作软件来提高工作效率、加强团队协作、支持远程办公、实现文件版本控制等,确保项目高效推进。协作软件不仅优化了设计流程,还促进了创意交流和团队创新。
|
存储 Swift
Swift 语言:什么是闭包(Closure)?它们与函数的区别是什么?
Swift 语言:什么是闭包(Closure)?它们与函数的区别是什么?
354 1
|
SQL 分布式计算 大数据
MaxCompute ODPS重装上阵:PIVOT/UNPIVOT
MaxCompute推出新语法 - PIVOT/UNPIVOT:通过PIVOT关键字基于聚合将一个或者多个指定值的行转换为列;通过UNPIVOT关键字可将一个或者多个列转换为行。以更简洁易用的方式满足行转列和列转行的需求,简化了查询语句,提高了广大大数据开发者的生产力。
1251 1
MaxCompute  ODPS重装上阵:PIVOT/UNPIVOT
|
消息中间件 Kafka Linux
十一、Linux(CentOS7) 搭建Kafka集群
一、环境准备:   首先准备好三台CentOS系统的主机,设置ip为:172.16.20.220、172.16.20.221、172.16.20.222。   Kafka会使用大量文件和网络socket,Linux默认配置的File descriptors(文件描述符)不能够满足Kafka高吞吐量的要求,所以这里需要调整(更多性能优化,请查看Kafka官方文档):
651 56
|
XML 数据格式 开发者
数据解析之Xpath解析(超详细定位)1
数据解析之Xpath解析(超详细定位)1
490 0

热门文章

最新文章