springBoot + Aspect 通过注解实现代理

电玩女神 2023-03-03 12:25 7阅读 0赞

1.pom

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-aop</artifactId>
            </dependency>

2.注解

package com.gray.demo.core.proxy2;
    
    import java.lang.annotation.Documented;
    import java.lang.annotation.ElementType;
    import java.lang.annotation.Retention;
    import java.lang.annotation.RetentionPolicy;
    import java.lang.annotation.Target;
    /**
     * 缓存更新注解
     */
    @Target(ElementType.METHOD)
    @Retention(RetentionPolicy.RUNTIME)
    public @interface CacheUpdate {
    
        String tableName() default "";
    
        String key() default "";
    
        String value() default "";
    
        CacheTypeEnum type() default CacheTypeEnum.REDIS;
    }

3.Aspect 代理类

package com.gray.demo.core.proxy2;
    
    import com.google.gson.Gson;
    import org.aspectj.lang.JoinPoint;
    import org.aspectj.lang.ProceedingJoinPoint;
    import org.aspectj.lang.annotation.*;
    import org.aspectj.lang.reflect.MethodSignature;
    import org.springframework.stereotype.Component;
    
    import java.lang.annotation.Annotation;
    import java.lang.reflect.Method;
    
    
    @Aspect
    @Component
    public class SysLogAspect {
    
        private static final String annotationPath = "com.gray.demo.core.proxy2.CacheUpdate";
    
        @Pointcut("@annotation(com.gray.demo.core.proxy2.CacheUpdate)")
        public void logPointCut() {
    
        }
    
        @Around("logPointCut()")
        public Object around(ProceedingJoinPoint point) throws Throwable {
            long beginTime = System.currentTimeMillis();
    
            System.out.println("环绕start");
    
            //执行方法
            Object result = point.proceed();
            //执行时长(毫秒)
            long time = System.currentTimeMillis() - beginTime;
            //保存日志
            System.out.println("环绕end");
            return result;
        }
    
        @Before("logPointCut()")
        public void before(JoinPoint joinPoint) throws Throwable {
            Object args[] = joinPoint.getArgs();
            MethodSignature signature = (MethodSignature)joinPoint.getSignature();
            Method method = signature.getMethod();
    //        System.out.println("传入参数" + method.getDeclaringClass().getName());
    //        System.out.println("传入参数" + method.getName());
    //        System.out.println("传入参数" + new Gson().toJson(args));
        }
    
        @AfterReturning(value = "logPointCut()",returning = "rvt")
        public void after(JoinPoint joinPoint,Object rvt) throws Throwable {
            Class<? extends Annotation> methodAnnotation = Class.forName(annotationPath).asSubclass(Annotation.class);
    
            Object args[] = joinPoint.getArgs();
            MethodSignature signature = (MethodSignature)joinPoint.getSignature();
            Method method = signature.getMethod();
            System.out.println("传入参数" + method.getDeclaringClass().getName());
            System.out.println("传入参数" + method.getName());
    
    //        传入参数名
    //        method.getParameters();
            System.out.println("传入参数" + new Gson().toJson(args));
            System.out.println("返回参数" + new Gson().toJson(rvt));
    
            //注解信息
            Annotation methodAn = method.getAnnotation(methodAnnotation);
            if(methodAn == null){
                return;
            }
            Class<?> c = methodAn.getClass();
            //注解方法参数
            String tableName = String.valueOf(c.getMethod("tableName").invoke(methodAn));
            String key = String.valueOf(c.getMethod("key").invoke(methodAn));
            String value = String.valueOf(c.getMethod("value").invoke(methodAn));
            CacheTypeEnum type = (CacheTypeEnum)c.getMethod("type").invoke(methodAn);
    
            System.out.println("注解信息:" + tableName);
            System.out.println("注解信息:" + key);
            System.out.println("注解信息:" + value);
            System.out.println("注解信息:" + type);
        }
    }

3.工具枚举

package com.gray.demo.core.proxy2;
    
    import lombok.Getter;
    
    /**
     * Created on 2020/7/30.
     *
     * @author Gray
     * @since 1.0
     */
    @Getter
    public enum CacheTypeEnum {
        REDIS(1,"redis","redis缓存"),
        CHANNEL(2,"channel","channel缓存"),
        NATIVE(3,"native","本地缓存"),
        ;
        CacheTypeEnum(int id, String name, String descript){
            this.id = id;
            this.name = name;
            this.descript = descript;
        }
    
        private int id;
        private String name;
        private String descript;
    }

4.测试类

@RestController
    public class TestController {
    
        /**
         * 修改登录用户密码
         */
        @CacheUpdate(type = CacheTypeEnum.REDIS,tableName = "playerInfo", key = "playerInfo",value = "playerId")
        @RequestMapping("/password")
        public Object password(String password, String playerId){
    
            System.out.println("old:" + password + ",playerId:" + playerId);
    
            return "ok";
        }
    }

这样调用是不会被代理的！！！

@RequestMapping("/password")
        public Object password(String password, String playerId){
    
            System.out.println("old:" + password + ",playerId:" + playerId);
            nnn("2321321");
            return "ok";
        }
    
        @CacheUpdate(type = CacheTypeEnum.REDIS,tableName = "playerInfo", key = "playerInfo",value = "playerId")
        public String nnn(String playerId){
            return "ok";
        }

需要改成

@Autowired
        TestController testController;
    
        /**
         * 修改登录用户密码
         */
        @RequestMapping("/password")
        public Object password(String password, String playerId){
    
            System.out.println("old:" + password + ",playerId:" + playerId);
            testController.nnn("2321321");
            return "ok";
        }
    
        @CacheUpdate(type = CacheTypeEnum.REDIS,tableName = "playerInfo", key = "playerInfo",value = "playerId")
        public String nnn(String playerId){
            return "ok";
        }