From 10a8f32e5a63888bac8a1041f2c06b1d3fd669d8 Mon Sep 17 00:00:00 2001 From: linlei Date: Tue, 9 Apr 2024 15:36:20 +0800 Subject: [PATCH] =?UTF-8?q?TargetSource=E6=BA=90=E7=A0=81=E5=88=86?= =?UTF-8?q?=E6=9E=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 1 + spring-aop/pom.xml | 1 + spring-aop/spring-aop-targetSource/README.md | 293 ++++++++++++++++++ spring-aop/spring-aop-targetSource/pom.xml | 14 + .../spring/ConnectionPoolTargetSource.java | 86 +++++ .../java/com/xcs/spring/MyConnection.java | 25 ++ .../java/com/xcs/spring/TargetSourceDemo.java | 20 ++ 7 files changed, 440 insertions(+) create mode 100644 spring-aop/spring-aop-targetSource/README.md create mode 100644 spring-aop/spring-aop-targetSource/pom.xml create mode 100644 spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/ConnectionPoolTargetSource.java create mode 100644 spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/MyConnection.java create mode 100644 spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/TargetSourceDemo.java diff --git a/README.md b/README.md index 45e385f..0467108 100644 --- a/README.md +++ b/README.md @@ -200,6 +200,7 @@ - [Advice](spring-aop/spring-aop-advice/README.md)：AOP核心接口，定义切面通知行为。 - [Advisor](spring-aop/spring-aop-advisor/README.md)：用于将通知和切点结合，实现切面编程的横切关注点。 - [AdvisorAdapter](spring-aop/spring-aop-advisorAdapter/README.md)：适配不同类型通知到拦截器链。 + - [TargetSource](spring-aop/spring-aop-targetSource/README.md)：管理AOP代理对象的获取与释放。 + Spring AOT diff --git a/spring-aop/pom.xml b/spring-aop/pom.xml index 2814734..acd2aca 100644 --- a/spring-aop/pom.xml +++ b/spring-aop/pom.xml @@ -13,6 +13,7 @@ spring-aop-pointcut spring-aop-advice spring-aop-advisorAdapter + spring-aop-targetSource 4.0.0 diff --git a/spring-aop/spring-aop-targetSource/README.md b/spring-aop/spring-aop-targetSource/README.md new file mode 100644 index 0000000..9c27918 --- /dev/null +++ b/spring-aop/spring-aop-targetSource/README.md @@ -0,0 +1,293 @@ +## TargetSource + +- [TargetSource](#TargetSource) + - [一、基本信息](#一基本信息) + - [二、知识储备](#二知识储备) + - [三、基本描述](#三基本描述) + - [四、主要功能](#四主要功能) + - [五、接口源码](#五接口源码) + - [六、主要实现](#六主要实现) + - [七、最佳实践](#七最佳实践) + - [八、与其他组件的关系](#八与其他组件的关系) + - [九、常见问题](#九常见问题) + +### 一、基本信息 + +✒️ **作者** - Lex 📝 **博客** - [掘金](https://juejin.cn/user/4251135018533068/posts) 📚 **源码地址** - [github](https://github.com/xuchengsheng/spring-reading) + +### 二、知识储备 + +1. **AOP 编程模型** + + + 了解 AOP 编程模型，包括横切关注点和切面等，以及如何使用 Spring AOP 在这个模型下进行编程。 + +2. **目标对象管理** + + + 理解在 Spring AOP 中如何管理目标对象以及切面如何与目标对象进行交互。 + +3. **设计模式** + + + 熟悉一些设计模式对理解和实现 `TargetSource` 接口可能会有所帮助，特别是工厂模式、代理模式等。因为在实现 `TargetSource` 接口时，你可能会使用到这些模式。 + +### 三、基本描述 + +`TargetSource` 接口是 Spring AOP 框架中的一个关键组件，用于定义获取目标对象的策略，允许我们灵活地管理目标对象的创建和管理。通过实现该接口，可以实现各种目标对象的获取方式，如单例、原型、池化等，从而为 AOP 切面提供了更高度的可定制性和灵活性。 + +### 四、主要功能 + +1. **目标对象获取方法** + + + `getTarget()`，该方法根据具体的策略获取目标对象，如单例、原型、池化等。 + +2. **目标对象释放方法** + + + `releaseTarget(Object target)`，一些实现可能需要释放目标对象，如将对象返回到对象池中。 + +3. **灵活的目标对象管理** + + + 可以根据应用程序的需求实现自定义的目标对象获取策略，从而实现对目标对象的灵活管理。 + +4. **内置的目标源实现** + + + Spring AOP 提供了几种内置的 `TargetSource` 实现，如 `SingletonTargetSource`、`PrototypeTargetSource`、`ThreadLocalTargetSource` 等，可以根据具体情况选择合适的目标源实现。 + +5. **扩展性和定制性** + + + 我们可以通过实现 `TargetSource` 接口来实现自定义的目标源，从而满足特定场景下的需求，如基于线程的对象管理、对象池管理等。 + +### 五、接口源码 + +`TargetSource` 接口用于获取当前 AOP 调用的目标对象，通过 `getTarget()` 方法获取目标对象，并通过 `releaseTarget(Object target)` 方法释放目标对象。接口定义了 `getTargetClass()` 方法用于返回目标对象的类型，`isStatic()` 方法用于检查是否所有调用 `getTarget()` 方法的返回值都是相同的对象。此接口支持静态和动态目标源，静态目标源始终返回相同的目标对象，而动态目标源支持池化、热交换等功能。 + +```java +/** + * TargetSource 接口用于获取 AOP 调用的当前目标对象，如果没有环绕通知选择结束拦截器链，则将通过反射调用目标对象。 + * + *

如果 TargetSource 是 "static"，它将始终返回相同的目标对象，从而允许 AOP 框架进行优化。动态目标源可以支持池化、热交换等。 + * + *

应用程序开发人员通常不需要直接使用 TargetSources：这是一个 AOP 框架接口。 + * + * @author Rod Johnson + * @author Juergen Hoeller + */ +public interface TargetSource extends TargetClassAware { + + /** + * 返回此 TargetSource 返回的目标类型。 + *

可以返回 {@code null}，尽管某些 TargetSource 的用法可能只使用预定的目标类。 + * + * @return 此 TargetSource 返回的目标类型 + */ + @Override + @Nullable + Class getTargetClass(); + + /** + * 所有对 getTarget() 的调用是否将返回相同的对象？ + *

在这种情况下，不需要调用 releaseTarget(Object)，并且 AOP 框架可以缓存 getTarget() 的返回值。 + * + * @return 如果目标是不可变的，则为 true + * @see #getTarget + */ + boolean isStatic(); + + /** + * 返回一个目标实例。在 AOP 框架调用 AOP 方法调用的目标之前立即调用此方法。 + * + * @return 包含连接点的目标对象，如果没有实际目标实例，则为 {@code null} + * @throws Exception 如果无法解析目标对象 + */ + @Nullable + Object getTarget() throws Exception; + + /** + * 释放从 getTarget() 方法获取的给定目标对象（如果有）。 + * + * @param target 从调用 getTarget() 获取的对象 + * @throws Exception 如果无法释放对象 + */ + void releaseTarget(Object target) throws Exception; + +} +``` + +### 六、主要实现 + +1. **SingletonTargetSource** + + 用于管理单例对象的目标源。该实现每次调用 `getTarget()` 方法都返回同一个单例对象，适用于目标对象是单例的情况。 +2. **PrototypeTargetSource** + + 用于每次调用时创建新对象的目标源。该实现每次调用 `getTarget()` 方法都返回一个新的目标对象实例，适用于目标对象需要频繁更新或重置的情况。 +3. **ThreadLocalTargetSource** + + 用于在每个线程中保持一个目标对象的引用。该实现在每个线程中都维护一个目标对象的副本，适用于需要在多线程环境中使用不同的目标对象实例的情况。 +4. **CommonsPool2TargetSource** + + 用于使用 Apache Commons Pool 来管理目标对象的池化目标源。该实现通过对象池管理目标对象的创建和销毁，以提高对象的重用性和性能。 + +### 七、最佳实践 + +使用 Spring 的代理工厂（`ProxyFactory`）和目标源（`TargetSource`）来创建代理对象。在这个示例中，我们创建了一个连接池目标源（`ConnectionPoolTargetSource`），设置连接池的大小为 3。然后，我们将这个连接池目标源设置为代理工厂的目标源，并通过代理工厂获取代理对象。最后，我们通过代理对象调用了10次方法。 + +```java +public class TargetSourceDemo { + + public static void main(String[] args) { + // 创建代理工厂 + ProxyFactory proxyFactory = new ProxyFactory(); + // 设置目标源为连接池目标源，连接池大小为3 + proxyFactory.setTargetSource(new ConnectionPoolTargetSource(3)); + // 获取代理对象 + MyConnection proxy = (MyConnection) proxyFactory.getProxy(); + + // 调用10次方法 + for (int i = 0; i < 10; i++) { + System.out.println("MyConnection Name = " + proxy.getName()); + } + } +} +``` + +`ConnectionPoolTargetSource` 类实现了 Spring 的 `TargetSource` 接口，用于管理自定义连接对象的连接池。在构造函数中，它会初始化一个固定大小的阻塞队列作为连接池，并填充连接对象。通过实现 `getTarget()` 方法，它能够从连接池中获取连接对象，并在 `releaseTarget()` 方法中释放连接对象。 + +```java +/** + * 连接池目标源，用于管理自定义连接对象的连接池。 + * + * @author xcs + * @date 2024年4月9日15:26:28 + */ +public class ConnectionPoolTargetSource implements TargetSource { + + /** + * 连接池 + */ + private final BlockingQueue connectionPool; + + /** + * 构造函数，初始化连接池。 + * + * @param poolSize 连接池大小 + */ + public ConnectionPoolTargetSource(int poolSize) { + this.connectionPool = new ArrayBlockingQueue<>(poolSize); + initializeConnectionPool(poolSize); + } + + /** + * 初始化连接池，填充连接对象。 + * + * @param poolSize 连接池大小 + */ + private void initializeConnectionPool(int poolSize) { + for (int i = 0; i < poolSize; i++) { + MyConnection connection = new MyConnection("Connection" + i); + connectionPool.offer(connection); + } + } + + /** + * 获取目标类的类型。 + * + * @return 目标类的类型 + */ + @Override + public Class getTargetClass() { + return MyConnection.class; + } + + /** + * 判断目标对象是否是静态的。 + * + * @return 如果目标对象是静态的，则返回true，否则返回false + */ + @Override + public boolean isStatic() { + return false; + } + + /** + * 获取连接对象。 + * + * @return 连接对象 + * @throws Exception 如果获取连接对象时发生异常 + */ + @Override + public Object getTarget() throws Exception { + return connectionPool.take(); + } + + /** + * 释放连接对象。 + * + * @param target 待释放的连接对象 + * @throws Exception 如果释放连接对象时发生异常 + */ + @Override + public void releaseTarget(Object target) throws Exception { + if (target instanceof MyConnection) { + connectionPool.offer((MyConnection) target); + } + } +} +``` + +`MyConnection` 类代表了一个自定义的连接对象。 + +```java +public class MyConnection { + + private String name; + + public MyConnection(String name) { + this.name = name; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + @Override + public String toString() { + return "MyConnection{" + + "name='" + name + '\'' + + '}'; + } +} +``` + +运行结果，连接池会循环地提供连接对象，直到连接池中的所有连接对象都被使用过一次后，再重新开始循环。这与预期的连接池行为一致，确保了连接对象的复用和管理。 + +```java +MyConnection Name = Connection0 +MyConnection Name = Connection1 +MyConnection Name = Connection2 +MyConnection Name = Connection0 +MyConnection Name = Connection1 +MyConnection Name = Connection2 +MyConnection Name = Connection0 +MyConnection Name = Connection1 +MyConnection Name = Connection2 +MyConnection Name = Connection0 +``` + +### 八、与其他组件的关系 + +1. **ProxyFactory** + + + 用于创建代理对象。`ProxyFactory` 可以设置 `TargetSource` 实现类，并通过 `getProxy()` 方法来获取代理对象，从而在运行时对目标对象应用切面逻辑。 + +2. **Advice** + + + 用于在目标对象的方法执行前、后或异常时执行特定的逻辑。Advice 可以通过 AOP 拦截器与 `TargetSource` 关联，从而实现对目标对象的增强操作。 + +### 九、常见问题 + +1. **目标对象类型不匹配** + + + 在配置 `TargetSource` 实现类时，需要确保目标对象的类型与实际目标对象的类型一致，否则可能会导致类型转换异常或者运行时错误。 + +2. **目标对象生命周期管理** + + + 在使用 `TargetSource` 时，需要确保目标对象的生命周期管理正确，特别是在目标对象的初始化、销毁和异常处理方面，需要注意避免资源泄漏和对象状态不一致等问题。 \ No newline at end of file diff --git a/spring-aop/spring-aop-targetSource/pom.xml b/spring-aop/spring-aop-targetSource/pom.xml new file mode 100644 index 0000000..a89f2a7 --- /dev/null +++ b/spring-aop/spring-aop-targetSource/pom.xml @@ -0,0 +1,14 @@ + + + + com.xcs.spring + spring-aop + 0.0.1-SNAPSHOT + + + 4.0.0 + spring-aop-targetSource + + \ No newline at end of file diff --git a/spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/ConnectionPoolTargetSource.java b/spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/ConnectionPoolTargetSource.java new file mode 100644 index 0000000..9921d34 --- /dev/null +++ b/spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/ConnectionPoolTargetSource.java @@ -0,0 +1,86 @@ +package com.xcs.spring; + +import org.springframework.aop.TargetSource; + +import java.util.concurrent.ArrayBlockingQueue; +import java.util.concurrent.BlockingQueue; + +/** + * 连接池目标源，用于管理自定义连接对象的连接池。 + * + * @author xcs + * @date 2024年4月9日15:26:28 + */ +public class ConnectionPoolTargetSource implements TargetSource { + + /** + * 连接池 + */ + private final BlockingQueue connectionPool; + + /** + * 构造函数，初始化连接池。 + * + * @param poolSize 连接池大小 + */ + public ConnectionPoolTargetSource(int poolSize) { + this.connectionPool = new ArrayBlockingQueue<>(poolSize); + initializeConnectionPool(poolSize); + } + + /** + * 初始化连接池，填充连接对象。 + * + * @param poolSize 连接池大小 + */ + private void initializeConnectionPool(int poolSize) { + for (int i = 0; i < poolSize; i++) { + MyConnection connection = new MyConnection("Connection" + i); + connectionPool.offer(connection); + } + } + + /** + * 获取目标类的类型。 + * + * @return 目标类的类型 + */ + @Override + public Class getTargetClass() { + return MyConnection.class; + } + + /** + * 判断目标对象是否是静态的。 + * + * @return 如果目标对象是静态的，则返回true，否则返回false + */ + @Override + public boolean isStatic() { + return false; + } + + /** + * 获取连接对象。 + * + * @return 连接对象 + * @throws Exception 如果获取连接对象时发生异常 + */ + @Override + public Object getTarget() throws Exception { + return connectionPool.take(); + } + + /** + * 释放连接对象。 + * + * @param target 待释放的连接对象 + * @throws Exception 如果释放连接对象时发生异常 + */ + @Override + public void releaseTarget(Object target) throws Exception { + if (target instanceof MyConnection) { + connectionPool.offer((MyConnection) target); + } + } +} diff --git a/spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/MyConnection.java b/spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/MyConnection.java new file mode 100644 index 0000000..c256d46 --- /dev/null +++ b/spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/MyConnection.java @@ -0,0 +1,25 @@ +package com.xcs.spring; + +public class MyConnection { + + private String name; + + public MyConnection(String name) { + this.name = name; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + @Override + public String toString() { + return "MyConnection{" + + "name='" + name + '\'' + + '}'; + } +} diff --git a/spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/TargetSourceDemo.java b/spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/TargetSourceDemo.java new file mode 100644 index 0000000..8fda52f --- /dev/null +++ b/spring-aop/spring-aop-targetSource/src/main/java/com/xcs/spring/TargetSourceDemo.java @@ -0,0 +1,20 @@ +package com.xcs.spring; + +import org.springframework.aop.framework.ProxyFactory; + +public class TargetSourceDemo { + + public static void main(String[] args) { + // 创建代理工厂 + ProxyFactory proxyFactory = new ProxyFactory(); + // 设置目标源为连接池目标源，连接池大小为3 + proxyFactory.setTargetSource(new ConnectionPoolTargetSource(3)); + // 获取代理对象 + MyConnection proxy = (MyConnection) proxyFactory.getProxy(); + + // 调用10次方法 + for (int i = 0; i < 10; i++) { + System.out.println("MyConnection Name = " + proxy.getName()); + } + } +}