Merge pull request dianpoint#18 from dianpoint/aop-proxy

ccoderJava · web-flow · commit 234c0883222d · 2024-11-27T19:24:07.000+08:00
Aop proxy
diff --git a/src/main/java/com/dianpoint/summer/aop/Advice.java b/src/main/java/com/dianpoint/summer/aop/Advice.java
@@ -0,0 +1,9 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 21:59
+ */
+public interface Advice {
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/Advisor.java b/src/main/java/com/dianpoint/summer/aop/Advisor.java
@@ -0,0 +1,15 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:17
+ */
+public interface Advisor {
+
+    MethodInterceptor getMethodInterceptor();
+
+    void setMethodInterceptor(MethodInterceptor methodInterceptor);
+
+    Advice getAdvice();
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/AfterAdvice.java b/src/main/java/com/dianpoint/summer/aop/AfterAdvice.java
@@ -0,0 +1,8 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:00
+ */
+public interface AfterAdvice extends Advice {}
diff --git a/src/main/java/com/dianpoint/summer/aop/AfterReturningAdvice.java b/src/main/java/com/dianpoint/summer/aop/AfterReturningAdvice.java
@@ -0,0 +1,13 @@
+package com.dianpoint.summer.aop;
+
+import java.lang.reflect.Method;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:02
+ */
+public interface AfterReturningAdvice extends AfterAdvice {
+
+    void afterReturning(Object returnValue, Method method, Object[] args, Object target) throws Throwable;
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/AfterReturningAdviceInterceptor.java b/src/main/java/com/dianpoint/summer/aop/AfterReturningAdviceInterceptor.java
@@ -0,0 +1,24 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:07
+ */
+public class AfterReturningAdviceInterceptor implements AfterAdvice, MethodInterceptor {
+
+    private final AfterReturningAdvice advice;
+
+    public AfterReturningAdviceInterceptor(AfterReturningAdvice advice) {
+        this.advice = advice;
+    }
+
+    @Override
+    public Object invoke(MethodInvocation invocation) throws Throwable {
+
+        Object reallyValue = invocation.proceed();
+        this.advice.afterReturning(reallyValue, invocation.getMethod(), invocation.getArguments(),
+            invocation.getThis());
+        return reallyValue;
+    }
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/AopProxy.java b/src/main/java/com/dianpoint/summer/aop/AopProxy.java
@@ -0,0 +1,16 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 20:54
+ */
+public interface AopProxy {
+
+    /**
+     * 获取代理对象
+     * 
+     * @return 代理对象
+     */
+    Object getProxy();
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/AopProxyFactory.java b/src/main/java/com/dianpoint/summer/aop/AopProxyFactory.java
@@ -0,0 +1,19 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 20:57
+ */
+public interface AopProxyFactory {
+
+    /**
+     * 创建AopProxy
+     * 
+     * @param target
+     *            被代理类
+     * @return aopProxy代理接口,提供不同代理方式
+     */
+    AopProxy createAopProxy(Object target);
+
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/BeforeAdvice.java b/src/main/java/com/dianpoint/summer/aop/BeforeAdvice.java
@@ -0,0 +1,8 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:00
+ */
+public interface BeforeAdvice extends Advice {}
diff --git a/src/main/java/com/dianpoint/summer/aop/DefaultAdvisor.java b/src/main/java/com/dianpoint/summer/aop/DefaultAdvisor.java
@@ -0,0 +1,26 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:18
+ */
+public class DefaultAdvisor implements Advisor {
+
+    private MethodInterceptor methodInterceptor;
+
+    @Override
+    public MethodInterceptor getMethodInterceptor() {
+        return methodInterceptor;
+    }
+
+    @Override
+    public void setMethodInterceptor(MethodInterceptor methodInterceptor) {
+        this.methodInterceptor = methodInterceptor;
+    }
+
+    @Override
+    public Advice getAdvice() {
+        return methodInterceptor;
+    }
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/DefaultAopProxyFactory.java b/src/main/java/com/dianpoint/summer/aop/DefaultAopProxyFactory.java
@@ -0,0 +1,17 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * 默认的AOP Proxy代理类创建工厂,此处采用JDK动态代理来生成代理类
+ * 
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 20:58
+ */
+public class DefaultAopProxyFactory implements AopProxyFactory {
+    @Override
+    public AopProxy createAopProxy(Object target) {
+
+        // 采用JDK dynamicProxy来实现代理类的创建
+        return new JdkDynamicAopProxy(target);
+    }
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/Interceptor.java b/src/main/java/com/dianpoint/summer/aop/Interceptor.java
@@ -0,0 +1,8 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:02
+ */
+public interface Interceptor extends Advice {}
diff --git a/src/main/java/com/dianpoint/summer/aop/JdkDynamicAopProxy.java b/src/main/java/com/dianpoint/summer/aop/JdkDynamicAopProxy.java
@@ -0,0 +1,34 @@
+package com.dianpoint.summer.aop;
+
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Method;
+import java.lang.reflect.Proxy;
+
+/**
+ * JDK Dynamic Proxy 实现AOP
+ * 
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 21:04
+ */
+public class JdkDynamicAopProxy implements AopProxy, InvocationHandler {
+
+    Object target;
+
+    public JdkDynamicAopProxy(Object target) {
+        this.target = target;
+    }
+
+    @Override
+    public Object getProxy() {
+        return Proxy.newProxyInstance(JdkDynamicAopProxy.class.getClassLoader(), target.getClass().getInterfaces(), this);
+    }
+
+    @Override
+    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
+        System.out.println("代理类执行之前");
+        Object invokeResult = method.invoke(target, args);
+        System.out.println("代理类执行之后");
+        return invokeResult;
+    }
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/MethodBeforeAdvice.java b/src/main/java/com/dianpoint/summer/aop/MethodBeforeAdvice.java
@@ -0,0 +1,14 @@
+package com.dianpoint.summer.aop;
+
+import java.lang.reflect.Method;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:11
+ */
+public interface MethodBeforeAdvice extends BeforeAdvice {
+
+    void before(Method method, Object[] args, Object target) throws Throwable;
+
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/MethodBeforeAdviceInterceptor.java b/src/main/java/com/dianpoint/summer/aop/MethodBeforeAdviceInterceptor.java
@@ -0,0 +1,21 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:13
+ */
+public class MethodBeforeAdviceInterceptor implements MethodInterceptor {
+
+    private MethodBeforeAdvice advice;
+
+    public MethodBeforeAdviceInterceptor(MethodBeforeAdvice advice) {
+        this.advice = advice;
+    }
+
+    @Override
+    public Object invoke(MethodInvocation invocation) throws Throwable {
+        this.advice.before(invocation.getMethod(), invocation.getArguments(), invocation.getThis());
+        return invocation.proceed();
+    }
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/MethodInterceptor.java b/src/main/java/com/dianpoint/summer/aop/MethodInterceptor.java
@@ -0,0 +1,11 @@
+package com.dianpoint.summer.aop;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:04
+ */
+public interface MethodInterceptor extends Interceptor {
+
+    Object invoke(MethodInvocation invocation) throws Throwable;
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/MethodInvocation.java b/src/main/java/com/dianpoint/summer/aop/MethodInvocation.java
@@ -0,0 +1,20 @@
+package com.dianpoint.summer.aop;
+
+import java.lang.reflect.Method;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 22:05
+ */
+public interface MethodInvocation {
+
+    Method getMethod();
+
+    Object[] getArguments();
+
+    Object getThis();
+
+    Object proceed() throws Throwable;
+
+}
diff --git a/src/main/java/com/dianpoint/summer/aop/ProxyFactoryBean.java b/src/main/java/com/dianpoint/summer/aop/ProxyFactoryBean.java
@@ -0,0 +1,77 @@
+package com.dianpoint.summer.aop;
+
+import com.dianpoint.summer.beans.factory.FactoryBean;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 21:18
+ */
+public class ProxyFactoryBean implements FactoryBean<Object> {
+
+    private AopProxyFactory aopProxyFactory;
+
+    private Object target;
+
+    private Object singletonInstance;
+
+    public ProxyFactoryBean() {
+        // 默认才用Jdk Dynamic 代理来实现AOP 可在此进行扩展
+        this.aopProxyFactory = new DefaultAopProxyFactory();
+    }
+
+    @Override
+    public Object getObject() throws Exception {
+        return null;
+    }
+
+    @Override
+    public Class<?> getObjectType() {
+        return null;
+    }
+
+    public AopProxy createAopProxy() {
+        return getAopProxyFactory().createAopProxy(target);
+    }
+
+    /**
+     * 通过AopProxy接口获取代理类,实现方式为AopProxy接口实现的DefaultAopProxyFactory或者其余可扩展的代理工厂类
+     * 
+     * @param aopProxy
+     *            aopProxy
+     * @return 代理结果
+     */
+    public Object getProxy(AopProxy aopProxy) {
+        return aopProxy.getProxy();
+    }
+
+    /**
+     * 获取代理对象的单例bean
+     * 
+     * @return 单例Bean
+     */
+    public synchronized Object getSingletonInstance() {
+        if (this.singletonInstance == null) {
+            AopProxy aopProxy = createAopProxy();
+            this.singletonInstance = getProxy(aopProxy);
+        }
+        return this.singletonInstance;
+    }
+
+    public Object getTarget() {
+        return target;
+    }
+
+    public void setTarget(Object target) {
+        this.target = target;
+    }
+
+    public AopProxyFactory getAopProxyFactory() {
+        return aopProxyFactory;
+    }
+
+    public void setAopProxyFactory(AopProxyFactory aopProxyFactory) {
+        this.aopProxyFactory = aopProxyFactory;
+    }
+
+}
diff --git a/src/main/java/com/dianpoint/summer/beans/factory/FactoryBean.java b/src/main/java/com/dianpoint/summer/beans/factory/FactoryBean.java
@@ -0,0 +1,18 @@
+package com.dianpoint.summer.beans.factory;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 21:03
+ */
+public interface FactoryBean<T> {
+
+    T getObject() throws Exception;
+
+    Class<?> getObjectType();
+
+    default boolean isSingleton() {
+        return true;
+    }
+
+}
diff --git a/src/test/java/com/dianpoint/summer/test/aop/proxy/SomeService.java b/src/test/java/com/dianpoint/summer/test/aop/proxy/SomeService.java
@@ -0,0 +1,12 @@
+package com.dianpoint.summer.test.aop.proxy;
+
+/**
+ * @author: github/ccoderJava
+ * @email: congccoder@gmail.com
+ * @date: 2023/3/26 21:30
+ */
+public interface SomeService {
+
+    void action();
+
+}
diff --git a/src/test/java/com/dianpoint/summer/test/aop/proxy/SomeServiceImpl.java b/src/test/java/com/dianpoint/summer/test/aop/proxy/SomeServiceImpl.java
diff --git a/src/test/java/com/dianpoint/summer/test/aop/proxy/SomeServiceProxy.java b/src/test/java/com/dianpoint/summer/test/aop/proxy/SomeServiceProxy.java
diff --git a/src/test/java/com/dianpoint/summer/test/service/SimpleServiceImpl.java b/src/test/java/com/dianpoint/summer/test/service/SimpleServiceImpl.java
diff --git a/src/test/resources/beans.xml b/src/test/resources/beans.xml
