Spring AOP—深入动态代理 万字详解(通俗易懂)

目录

一、前言

二、动态代理快速入门

        1.为什么需要动态代理? : 

        2.动态代理使用案例:

        3.动态代理的灵活性 : 

三、深入动态代理

        1.需求 : 

        2.实现 : 

            2.1 接口和实现类

            2.2 提供代理对象的类

            2.3 测试类

        3.引出AOP : 

四、总结


一、前言

  • 第四节内容,up打算和大家分享Spring 动态代理 相关的内容动态代理本质上是Spring AOP的一个前置的引入内容,一个AOP开篇之作,但它却相当重要,且本身难度较大
  • 注意事项——①代码中的注释也很重要;不要眼高手低,自己跟着过一遍才真正有收获;点击文章的侧边栏目录或者文章开头的目录可以进行跳转。
  • 良工不示人以朴,up所有文章都会适时补充完善。大家如果有问题都可以在评论区进行交流或者私信up。感谢阅读!

二、动态代理快速入门

        1.为什么需要动态代理? : 

        在日常开发中,往往存在这样一种需求——同时存在多个对象,这些对象对应的类都实现了同一接口,并且这些对象会去调用这个接口中的某一个方法,即多态,但是我们要求这几个对象在调用方法前,和调用方法后都要做一些业务处理,eg : 权限校验、事务管理、日志管理、安全校验等。

        如果我们将这些相同的业务处理,都下沉到每一个具体的类,就会造成代码冗余,并且没有办法进行对象的统一管理和调用;而动态代理的出现,尤对其症地解决了这个问题。

        2.动态代理使用案例:

                up先在dynamic_proxy包下创建Animal接口,以及Cat, Dog类,Cat类和Dog类都实现了Animal接口。如下图所示 : 

                Animal接口代码如下 : 

package com.cyan.spring.dynamic_proxy;/*** @author : Cyan_RA9* @version : 21.0*/
public interface Animal {public abstract void eat();
}

                Cat类代码如下 :  

package com.cyan.spring.dynamic_proxy;/*** @author : Cyan_RA9* @version : 21.0*/
public class Cat implements Animal{@Overridepublic void eat() {System.out.println("小猫爱吃鱼捏~");}
}

                Dog类代码如下 : 

package com.cyan.spring.dynamic_proxy;/*** @author : Cyan_RA9* @version : 21.0*/
public class Dog implements Animal{@Overridepublic void eat() {System.out.println("小狗爱吃骨头捏~");}
}

                然后,我们创建一个AnimalProxyProvider类,见名知意,这个类可以提供一个Animal接口的代理对象,所以,该类中肯定会定义一个方法,用来返回Animal接口的代理实例,当然,这个方法稍微有点复杂,大家可以借助up的代码注释逐渐理解。
                AnimalProxyProvider类代码如下 : (尤其注意匿名内部类中实现的invoke方法,其中的两条输出语句表示实现类对象相同的业务逻辑代码

package com.cyan.spring.dynamic_proxy;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;/*** @author : Cyan_RA9* @version : 21.0*/
public class AnimalProxyProvider {//利用接口类型对传入的对象做接收 (多态)private Animal targetAnimal;//通过带参构造传入一个Animal接口实现类的对象public AnimalProxyProvider(Animal targetAnimal) {this.targetAnimal = targetAnimal;}//编写一个方法,用于返回代理对象 (用到反射机制)public Animal getAnimalProxy() {/**java.lang.reflect.Proxy类中的 newProxyInstance方法可以返回一个代理对象。public static Object newProxyInstance(ClassLoader loader,Class<?>[] interfaces,InvocationHandler h)throws IllegalArgumentException {...}该方法需要传入三个实参 ———(1) ClassLoader loader : 类加载器(2) Class<?>[] interfaces : 接口信息(3) InvocationHandler h : 调用处理器,其本身也是一个接口,内部声明了抽象方法invoke。*///(1)得到类加载器ClassLoader classLoader = targetAnimal.getClass().getClassLoader();//(2)得到被执行对象的接口信息(因为newProxyInstance方法底层是通过接口来调用的,即接口多态)Class<?>[] interfaces = targetAnimal.getClass().getInterfaces();//(3)得到处理器对象(通过匿名内部类实现,最终返回的是一个匿名内部类对象)//!!![注意,处理器对象本身也是newProxyInstance方法的一个形参]InvocationHandler invocationHandler = new InvocationHandler() {/*** @param proxy the proxy instance that the method was invoked on** @param method the {@code Method} instance corresponding to* the interface method invoked on the proxy instance.  The declaring* class of the {@code Method} object will be the interface that* the method was declared in, which may be a superinterface of the* proxy interface that the proxy class inherits the method through.** @param args an array of objects containing the values of the* arguments passed in the method invocation on the proxy instance,* or {@code null} if interface method takes no arguments.* Arguments of primitive types are wrapped in instances of the* appropriate primitive wrapper class, such as* {@code java.lang.Integer} or {@code java.lang.Boolean}.** @return : the results of method instance invoked* @throws Throwable*/@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {/*将相同的业务逻辑代码,放在处理器对象的invoke对象中,避免了代码下沉到每个实现类所造成的代码冗余。*/System.out.println("要吃饭的嘛~");//通过反射调用实现类中的方法Object results = method.invoke(targetAnimal, args);System.out.println("吃完了捏~");return results;}};Animal animalProxy = (Animal) Proxy.newProxyInstance(classLoader, interfaces, invocationHandler);return animalProxy;}
}

                接着,up定义一个测试类,在测试类中定义一个单元测试方法,用以测试我们的动态代理是否生效。
                TestAnimal类代码如下 : 

package com.cyan.spring.dynamic_proxy;import org.junit.jupiter.api.Test;public class TestAnimal {@Testpublic void testGeyAnimalProxy() {//构造接口多态Animal animal = new Cat();Animal animal2 = new Dog();//传入需要被代理的对象AnimalProxyProvider animalProxyProvider = new AnimalProxyProvider(animal);AnimalProxyProvider animalProxyProvider2 = new AnimalProxyProvider(animal2);//得到代理对象/*注意!此处代理对象animalProxy的编译类型仍然是Animal类型,但运行类型却不再是Cat or Dog类型,而是代理类型 ——— class com.sun.proxy.$Proxy9。*/Animal animalProxy = animalProxyProvider.getAnimalProxy();Animal animalProxy2 = animalProxyProvider2.getAnimalProxy();System.out.println("animalProxy's RuntimeType = " + animalProxy.getClass());System.out.println("animalProxy2's RuntimeType = " + animalProxy2.getClass());//通过代理对象调用实现类方法animalProxy.eat();System.out.println("==============================");animalProxy2.eat();}
}

                运行结果 : 

                现在我们进行Debug断点调试,断点如下图所示 : 

                跳入eat()方法时会发现,IDEA直接跳到了AnimalProxyProvider类的getAnimalProxy方法中——匿名内部类实现的invoke方法里面,如下图所示 : 

                再往下执行便是通过反射调用对应的method,一直往下追,最终会跳到实现类的eat()方法中,如下图所示 : 

        3.动态代理的灵活性 : 

                动态代理的灵活性体现在哪里?
                首先,被代理的对象是可变的。并且,代理对象所调用的方法也是可变的

                比方说,up在Animal接口中新定义了一个sleep方法,如下图所示 : 

                然后,up在Cat类中实现了sleep方法,如下图所示 : 

                接着,修改匿名内部类实现的invoke方法中的“业务逻辑”代码,如下图所示 : 

                最后,up在测试类中新定义一个单元测试方法,测试动态代理是否生效。
                testSleep()方法代码如下 : 

    @Testpublic void testSleep() {//1.构造接口多态Animal animal = new Cat();//2.传入需要被代理的对象AnimalProxyProvider animalProxyProvider = new AnimalProxyProvider(animal);//3.获取代理对象Animal animalProxy = animalProxyProvider.getAnimalProxy();//4.通过代理对象调用实现类方法String sleepMinutes = animalProxy.sleep(Long.valueOf(1314));}

                运行结果 : 


三、深入动态代理

        1.需求 : 

        定义Calculator接口,表示一个计算器,该接口中定义有可以完成简单加减乘除运算的方法,要求在每次执行运算方法前后,都打印出运算日志(运算法则和运算参数,以及运算结果)

        2.实现 : 

            2.1 接口和实现类

                首先分析需求,既然要求在每次执行运算方法前后都打印出运算日志,显然我们会想到——仍是在匿名内部类实现的invoke方法中动手脚。
                别的不说,先来定义Calculator接口和一个它的实现类
                Calculator接口如下 : (声明了“加减乘除”四个抽象方法)

package com.cyan.spring.dynamic_proxy;/*** @author : Cyan_RA9* @version : 21.0*/
public interface Calculator {public abstract double add(double n1, double n2);public abstract double subtract(double n1, double n2);public abstract double multiply(double n1, double n2);public abstract double divide(double n1, double n2);
}

                定义一个实现类Calculator_Demo1,代码如下 : 

package com.cyan.spring.dynamic_proxy;/*** @author : Cyan_RA9* @version : 21.0*/
public class Calculator_Demo1 implements Calculator {@Overridepublic double add(double n1, double n2) {return n1 + n2;}@Overridepublic double subtract(double n1, double n2) {return n1 - n2;}@Overridepublic double multiply(double n1, double n2) {return n1 * n2;}@Overridepublic double divide(double n1, double n2) {//分母不允许为0if (n2 != 0) {return n1 / n2;}return -1;}
}

            2.2 提供代理对象的类

                定义一个CalculatorProxyProvider类,与上文 “动态代理使用案例” 中定义的“提供代理对象的类”类似,都需要定义一个方法用于返回代理对象。
                CalculatorProxyProvider类代码如下 : 

package com.cyan.spring.dynamic_proxy;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.time.LocalDateTime;public class CalculatorProxyProvider {private Calculator calculator;public CalculatorProxyProvider(Calculator calculator) {this.calculator = calculator;}/*底层仍然使用java.lang.reflect包下的Proxy类的newProxyInstance方法来获取代理对象。*/public Calculator getCalculatorProxy() {//1.获取newProxyInstance方法的第一个参数————类加载器ClassLoader classLoader = calculator.getClass().getClassLoader();//2.获取newProxyInstance方法的第二个参数————接口信息Class<?>[] interfaces = calculator.getClass().getInterfaces();//3.获取newProxyInstance方法的第三个参数————处理器对象//仍然借助匿名内部类来实现,并通过构造接口多态的形式做接收。InvocationHandler invocationHandler = new InvocationHandler() {@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {//获取到当前传入的参数double n1 = (double) args[0];double n2 = (double) args[1];//获取当前方法名String name = method.getName();//定义运算结果double result = 0.0;try {//Δ在运算方法执行前打印出运算日志System.out.println("运算日志————运算法则 = " + name + ",传入两个参数分别是 " + n1 + " 和 " + n2);//执行运算result = (double) method.invoke(calculator, args);System.out.println("result = " + result);//Δ在运算方法执行后打印出运算日志System.out.println("运算日志————运算法则 = " + name + ",运算结果 = " + result);//返回运算结果return result;} catch (Exception e) {System.out.println("异常日志————" + LocalDateTime.now() + ",方法" + method.getName() + "执行异常");throw new RuntimeException(e);} finally {System.out.println("执行日志————" + method.getName() + "方法执行结束。");}}};//4.调用newProxyInstance方法,得到代理对象Calculator instance = (Calculator) Proxy.newProxyInstance(classLoader, interfaces, invocationHandler);//5.返回获得的代理对象return instance;}
}

            2.3 测试类

                最后,仍然是在测试类中定义一个单元测试方法,up新定义了一个TestCalculator类,代码如下 : 

package com.cyan.spring.dynamic_proxy;import org.junit.jupiter.api.Test;public class TestCalculator {@Testpublic void testArithmetic() {//1.构造接口多态Calculator calculator = new Calculator_Demo1();//2.传入需要被代理的对象CalculatorProxyProvider calculatorProxyProvider = new CalculatorProxyProvider(calculator);//3.获取代理对象Calculator calculatorProxy = calculatorProxyProvider.getCalculatorProxy();//4.通过代理对象调用实现类方法double addResult = calculatorProxy.add(200.333, 33);System.out.println("-----------------------------");double subtractResult = calculatorProxy.subtract(141, 5);System.out.println("-----------------------------");double multiplyResult = calculatorProxy.multiply(11.11, 2);System.out.println("-----------------------------");double divideResult = calculatorProxy.divide(3917.0, 500.00);}
}

                运行结果 : 

                注意——
                (1) CalculatorProxyProvider类的这段代码,如下图所示 : 

                在AOP中,称为“横切关注点”,也叫“前置通知

                (2) 而下面的这段代码,如下图所示 : 

                从AOP的角度来看,也称为一个“横切关注点”,但也叫“后置通知

                (3) 此外,异常处理——catch语句块中的这段代码,如下图所示 : 

                从AOP看,也称为一个“横切关注点”,但又称为“异常通知”。

                (4) 最后,finally代码块中的内容,如下图所示 : 

                从AOP看,也称为一个“横切关注点”,但又称为“最终通知

        3.引出AOP : 

                分析一下我们方才写得代码,如下图所示 : 

                可以看到,无论是“前置通知”,“后置通知”,还是“异常通知”,“最终通知”。我们都只是草草地用了一条输出语句敷衍过去,这使得我们的代码不够牛逼,功能不够强大,且代码死板,不够灵活。
                而作为一名OOP程序员,我们会容易联想到——假如此处的输出语句都替换成方法,用一个方法直接切入,那不就既满足灵活性,又可以实现强大的功能吗?


四、总结

  • 🆗,以上就是Spring系列博文第四小节的全部内容了。
  • 总结一下,我们应该明白动态代理究竟“动态”在哪里?—— 不止是被代理对象可变,且代理对象执行的方法也是可变的。我们还需要知道newProxyInstance方法的三个形参分别有什么作用,以及如何获取这三个形参(尤其是第三个形参——处理器对象的获取,用到了匿名内部类)。总之,这篇博文其实是为了给“Spring—AOP”的分享做一个铺垫,我们以一个问题开始,又以一个问题结尾,也符合这篇博客的定位。
  • 下一节内容——Spring AOP—切入表达式和基于XML配置AOP,我们不见不散。感谢阅读!

        System.out.println("END---------------------------------------"); 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/582733.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Mybatis行为配置之Ⅱ—结果相关配置项说明

专栏精选 引入Mybatis Mybatis的快速入门 Mybatis的增删改查扩展功能说明 mapper映射的参数和结果 Mybatis复杂类型的结果映射 Mybatis基于注解的结果映射 Mybatis枚举类型处理和类型处理器 再谈动态SQL 文章目录 专栏精选引言摘要正文autoMappingBehaviorautoMappingU…

基于遗传算法的航线规划

MATLAB2016b可以正常运行 基于遗传算法的无人机航线规划资源-CSDN文库

代码随想录算法训练营Day13 |104.二叉树的最大深度、559.N叉树的最大深度、111.二叉树的最小深度、222.完全二叉树的节点个数

LeetCode 104 二叉树的最大深度 本题思想&#xff1a;用后序遍历的思想&#xff0c;先判断出左子树的深度&#xff0c;然后在右子树的深度。最后取大的那一个再加上根节点。就是最大深度。 class Solution {public int maxDepth(TreeNode root) {if(root null){return 0;}int…

(13)Linux 进程的优先级、进程的切换以及环境变量等

前言&#xff1a;我们先讲解进程的优先级。然后讲解进程的切换&#xff0c;最后我们讲解环境变量&#xff0c;并且做一个 "让自己的可执行程序不带路径也能执行"的实践&#xff0c;讲解环境变量的到如何删除&#xff0c;最后再讲几个常见的环境变量。 一、进程优先级…

跟着LearnOpenGL学习10--基础光照

文章目录 一、前言二、环境光照三、漫反射光照3.1、法向量3.2、计算漫反射光照3.3、全部代码3.4、法线矩阵 四、镜面光照4.1、全部代码 一、前言 现实世界的光照是极其复杂的&#xff0c;而且会受到诸多因素的影响&#xff0c;这是我们有限的计算能力所无法模拟的。 因此Open…

使用Rust发送邮件

SMTP协议与MIME协议 SMTP&#xff08;简单邮件传输协议,Simple Mail Transfer Protocol&#xff09;是一种用于发送和接收电子邮件的互联网标准通信协议。它定义了电子邮件服务器如何相互发送、接收和中继邮件。SMTP 通常用于发送邮件&#xff0c;而邮件的接收通常由 POP&#…

响应式绑定<a-textarea>的内容

项目中的 <a-textarea>组件需要自动填入下方数据表的物品名称数量单位&#xff0c;效果如下&#xff1a; 尝试 <a-textarea>{{插值}}</a-textarea>&#xff0c;实现不了&#xff0c;问ai得知需要使用v-decorator 指令的initialValue 属性 问&#xff1a; 如何…

地震烈度速报与预警工程成功案例的经验分享 | TDengine 技术培训班第一期成功落地

近日&#xff0c;涛思数据在成都开设了“国家地震烈度速报与预警工程数据库 TDengine、消息中间件 TMQ 技术培训班”&#xff0c;这次培训活动共分为三期&#xff0c;而本次活动是第一期。其目标是帮助参与者深入了解 TDengine 和 TMQ 的技术特点和应用场景&#xff0c;并学习如…

pybullet安装时出现fatal error C1083: 无法打开包括文件: “string.h”: No such file or directory

pybullet安装时出现fatal error C1083: 无法打开包括文件: “string.h”: No such file or directory 报错原文&#xff1a; -----CloneTreeCreator.cppD:\Program_Professional\Microsoft Visual Studio\2022\BuildTools\VC\Tools\MSVC\14.38.33130\include\cstring(11): fat…

腾讯云服务器如何买(购买腾讯云服务器的详细步骤)

腾讯云服务器购买流程直接在官方秒杀活动上购买比较划算&#xff0c;在云服务器CVM或轻量应用服务器页面自定义购买价格比较贵&#xff0c;但是自定义购买云服务器CPU内存带宽配置选择范围广&#xff0c;活动上购买只能选择固定的活动机&#xff0c;选择范围窄&#xff0c;但是…

canal 数据同步组件

canal 数据异构组件 为啥要使用这个组件&#xff1f; 在更新DB的时候不同步更新到redis&#xff0c;es等数据库中&#xff0c;时间太久&#xff0c;而且可能会存在同步失败的问题&#xff0c;因此引入canal去拉取DB的数据&#xff0c;再去更新到redis&#xff0c;es等数据库中&…

TiDB SQL调优案例TiFlash

背景 早上收到某系统的告警tidb节点挂掉无法访问&#xff0c;情况十万火急。登录中控机查了一下display信息&#xff0c;4个TiDB、Prometheus、Grafana全挂了&#xff0c;某台机器hang死无法连接&#xff0c;经过快速重启后集群恢复&#xff0c;经排查后是昨天上线的某个SQL导…

OpenGL 绘制Mesh数据(Qt)

文章目录 一、简介二、实现代码三、实现效果一、简介 Mesh数据的结构主要就是点与三角面片,因此本质上仍然是对三角面片进行绘制。这里我们借助VCG这个库实现对Mesh数据的读取,这个库相对简单轻巧,很方便使用。 二、实现代码 由于修改的部分很多,我们逐一进行解释一下: --…

Seata 中封装了四种分布式事务模式,分别是: AT 模式, TCC 模式, Saga 模式, XA 模式,

文章目录 seata概述Seata 中封装了四种分布式事务模式&#xff0c;分别是&#xff1a;AT 模式&#xff0c;TCC 模式&#xff0c;Saga 模式&#xff0c;XA 模式&#xff0c; 今天我们来聊聊seata seata 概述 在微服务架构下&#xff0c;由于数据库和应用服务的拆分&#xff0c…

【SAM系列】Auto-Prompting SAM for Mobile Friendly 3D Medical Image Segmentation

论文链接&#xff1a;https://arxiv.org/pdf/2308.14936.pdf 核心&#xff1a; finetune SAM,为了不依赖外部prompt&#xff0c;通过将深层的特征经过一个编-解码器来得到prompt embedding&#xff1b;finetune完之后做蒸馏

PTA-感染人数

设某住宿区域是一个nn的方阵&#xff0c;方阵中的每个小方格为一个房间&#xff0c;房间里可能住一个人&#xff0c;也可能空着。第一天&#xff0c;某些房间中住着的人得了一种高传染性的流感&#xff0c;以后每一天&#xff0c;得流感的人会使其邻居&#xff08;住在其上、下…

76 Python开发-内外网收集Socket子域名DNS

目录 Python开发相关知识点本篇文章涉及知识点演示案例:IP&Whois&系统指纹获取代码段-外网CDN&子域名&端口扫描&交互代码段-外网IP&计算机名&存活主机&端口扫描代码段-内网Py格式解析环境与可执行程序格式转换-Pyinstaller 涉及资源&#xff1…

git 学习 之一个规范的 commit 如何写

最好的话做一件完整的事情就提交一次

一种删除 KubeSphere 中一直卡在 Terminating 的 Namespace--KubeSphere Logging System的简单方法

文章目录 一、问题提出二、删除方法1&#xff0c;获取kubesphere-logging-syste的详细信息json文件2&#xff0c;编辑kubesphere-logging-system.json3&#xff0c;执行清理命令 三、检查结果 一、问题提出 在使用 KubeSphere 的时候发现有一个日志服务KubeSphere Logging Sys…

YoloV8改进策略:基于自研的图注意力机制改进| 独家改进方法|图卷积和注意力融合模块

摘要 SE注意力机制是一种通过显式建模卷积特征的信道之间相互依赖性的方法,旨在提高网络产生的表示的质量。SE注意力机制包括两个步骤:Squeeze和Excitation。在Squeeze步骤中,通过全局平均池化操作将输入特征图压缩成一个向量,然后通过一个全连接层将其映射到一个较小的向…