栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

spring boot 项目之-引入AOP切面

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

spring boot 项目之-引入AOP切面

(结合自定义注解,实现日志的处理)

1.引入依赖


    org.springframework
    spring-aop


    org.aspectj
    aspectjweaver


    org.aspectj
    aspectjrt

2.创建自己的自定义注解

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@documented
public @interface BussinessLog {
    
    String operateType() default "";
    
    String sourceList() default "";
    
    String msg() default "";
}

2.创建切面

@Slf4j
@Aspect
@Component
public class BusinessLogAspect {
    //利用注解 配置织入点
    @Pointcut("@annotation(com.qinzhy.mydemo.annotation.BussinessLog)")
    public void annotationPointCut(){}

    
    @After("annotationPointCut()")
    public void insertLogByAnnotion(JoinPoint joinPoint){
        log.info(JSON.toJSonString("后置通知 : "+joinPoint));
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();
        BussinessLog bussinessLog = method.getAnnotation(BussinessLog.class);
        //获取注解的信息
        String operateType = bussinessLog.operateType();
        String sourceList = bussinessLog.sourceList();
        String msg = bussinessLog.msg();
        log.info("后置方法式AOP拦截 【{}】" , operateType);
        log.info("后置方法式AOP拦截 【{}】" , sourceList);
        log.info("后置方法式AOP拦截 【{}】" , msg);


        //获取session中用户的信息

        //保存日志信息


    }

    
    @Before("execution(* com.qinzhy.mydemo.controller.TestAspectController.*(..))")
    public void beforeLogByAnnotion(JoinPoint joinPoint){
        log.info(JSON.toJSonString("前置通知 : "+ joinPoint));
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();
        BussinessLog bussinessLog = method.getAnnotation(BussinessLog.class);
        //获取注解的信息
        String operateType = bussinessLog.operateType();
        String sourceList = bussinessLog.sourceList();
        String msg = bussinessLog.msg();
        log.info("方法式AOP拦截 【{}】" , operateType);
                                                                                                                                                    log.info("后置异常注解式AOP拦截 【{}】" , sourceList);
        log.info("方法式AOP拦截 【{}】" , msg);
        //获取session中用户的信息

        //保存日志信息

    }


    
    @AfterThrowing("annotationPointCut()")
    public void exceptionLogByAnnotion(JoinPoint joinPoint){
        log.info(JSON.toJSonString("前置通知 : "+ joinPoint));
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();
        BussinessLog bussinessLog = method.getAnnotation(BussinessLog.class);
        //获取注解的信息
        String operateType = bussinessLog.operateType();
        String sourceList = bussinessLog.sourceList();
        String msg = bussinessLog.msg();
        log.info("异常捕获注解式AOP拦截 【{}】" , operateType);
        log.info("异常捕获注解式AOP拦截 【{}】" , sourceList);
        log.info("异常捕获注解式AOP拦截 【{}】" , msg);
        //获取session中用户的信息

        //保存日志信息

    }

}

3.使用该自定义的日志注解

@BussinessLog(operateType = "add",sourceList = "新增列表", msg = "测试注解式拦截")
@GetMapping("/add")
public String testAspect(){

    System.out.println("执行中>>>>>>>>>>>>>");
    return  "success";
}

4.实际使用案例

异常日志处理 或者成功后日志处理:未加入的安全模块以及session处理

@Slf4j
@Aspect
@Component
public class BusinessLogAspect {
    //利用注解 配置织入点
    @Pointcut("@annotation(com.qinzhy.mydemo.annotation.BussinessLog)")
    public void annotationPointCut(){}

    
    @AfterReturning( pointcut = "annotationPointCut()", returning = "jsonResult")
    public void doAfterReturning(JoinPoint joinPoint, Object jsonResult){
        log.info(JSON.toJSonString("成功日志处理通知 : "+joinPoint));
        handleLog(joinPoint, null,  jsonResult);

    }



    
    @AfterThrowing(value = "annotationPointCut()", throwing = "e")
    public void doAfterThrowing(JoinPoint joinPoint, Exception e){
        log.info(JSON.toJSonString("异常拦截通知 : "+ joinPoint));
        handleLog(joinPoint, e,  null);
    }

    
    protected void handleLog(final JoinPoint joinPoint, final Exception e, Object jsonResult){
        //获取注解
        BussinessLog bussinessLog = this.getAnnotationLog( joinPoint);
        if(bussinessLog == null){
            return;
        }
        //获取注解的信息
        String operateType = bussinessLog.operateType();
        String sourceList = bussinessLog.sourceList();
        String msg = bussinessLog.msg();
        log.info("注解式AOP拦截 【{}】" , operateType);
        log.info("注解式AOP拦截 【{}】" , sourceList);
        log.info("注解式AOP拦截 【{}】" , msg);

        //获取用户信息


        //获取请求参数信息  ip  等


        // 返回参数
        if(jsonResult != null){
            //赋值到返回参数存放字段里

        }
        //根据Exception e 是否存在来判断是否执行成果
        if ( e != null){
            //设置执行失败的状态

            //设置失败的原因 e.getMessage();

        }else{
            //设置执行成功的状态

        }

        //调用保存到数据库的方法



    }


    
    private BussinessLog getAnnotationLog(JoinPoint joinPoint){
        joinPoint.getSignature();
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();
        if(method != null){
            return method.getAnnotation(BussinessLog.class);
        }
        return null;

    }

}

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/755942.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号