aop前置增强、后置、环绕增强java方方园园的博客-

后置

   @AfterReturning(value="@annotation(com.sdyy.biz.act.maint.aop.annotation.ResIfNull)",returning="result")      public void AfterReturning(JoinPoint joinPoint , Object result) {          logger.info("AfterReturning------------start");           ResIfNull myAnno= ((MethodSignature)joinPoint.getSignature()).getMethod().getAnnotation(ResIfNull.class); if ("obj".equals(myAnno.type())) { if (result == null) {                  throw new SysException("初始化流程失败，请定义服务流程"); } } else if ("list".equals(myAnno.type())) { if (result instanceof List) {                  List res = (List) result; if (res.size() == 0) {                      throw new SysException("初始化流程失败，请配置参数"); } } } } 

前置

@Before(value="@annotation(com.sdyy.biz.act.maint.aop.annotation.IfMount)") public void ifMountCheck(JoinPoint joinPoint) throws Exception {     Object[] args = joinPoint.getArgs();     if(dsServiceDetailService.getMountCount(args[0].toString())<=0){         //说明没有挂接数据         throw new SysException("请挂接数据"); }     //获取方法参数   } 

环绕

package com.sdyy.common.aop; import com.sdyy.common.annotation.OperLog; import com.sdyy.common.controller.BaseController; import com.sdyy.common.entity.KafkaMessage; import com.sdyy.common.entity.Log; import com.sdyy.common.kafka.KafkaProducer; import com.sdyy.common.retobj.BaseEntity; import com.sdyy.common.utils.DateUtils; import com.sdyy.core.auth.operator.entity.AuthOperator; import lombok.extern.log4j.Log4j; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; import org.aspectj.lang.annotation.Aspect; import org.aspectj.lang.annotation.Pointcut; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.web.context.request.RequestAttributes; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import javax.servlet.http.HttpServletRequest;  /**  *  * 　  * @className: LogAspect  * 　　* @description:日志切面  * 　　* @param:  * 　　* @return:  * 　　* @throws:  * 　　* @author: lizz  * 　　* @date: 2020/03/15 18:37  *  */ @Log4j @Component @Aspect public class LogAspect {      @Autowired     private KafkaProducer producer;     /**      * @Description: 方法切入点      * @Author: lizz      * @Date: 2020/3/15 18:56      * @Reviser:修改人      * @ReviseDate:修改时间      * @Revision:修改内容      **/     @Pointcut("execution(* com.sdyy.maint.*.controller.*.*(..))")     public void pointerCutMethod() { }      /**      * @Description: 环绕通知      * @Author: lizz      * @Date: 2020/3/15 18:56      * @Reviser:修改人      * @ReviseDate:修改时间      * @Revision:修改内容      **/     @Around(value = "pointerCutMethod() && @annotation(annotation)")     public Object doAround(ProceedingJoinPoint joinPoint, OperLog annotation) {         Log logs = new Log();         //通过注解获取当前属于那个模块         logs.setModuleName(annotation.moduleName());         //通过注解获取当前的操作方式         logs.setOperation(annotation.option());         logs.setCreatedate(DateUtils.getCurrentDate());         RequestAttributes ra = RequestContextHolder.getRequestAttributes();         Long beginTime = System.currentTimeMillis(); if (ra != null) {             ServletRequestAttributes sra = (ServletRequestAttributes) ra;             HttpServletRequest request = sra.getRequest();              String ip = request.getRemoteHost();             logs.setUserIp(ip);             logs.setReqUrl(request.getRequestURI());             // 从session中获取用户信息             AuthOperator authOperator = (AuthOperator) request.getSession().getAttribute(BaseController.LOGIN_IN_OPERATOR_SESSION); if (authOperator != null) {                 logs.setUserName(authOperator.getUserId()); } }         try {             Object object = joinPoint.proceed(); if (object != null) { if (object instanceof BaseEntity) {                     if(((BaseEntity) object).getStatus()==200){                         logs.setOperResult("成功"); }else {                         logs.setOperResult(((BaseEntity) object).getMessage()); } } }             KafkaMessage ms =new KafkaMessage();             ms.setMsg(logs);             producer.send("logs", ms); return object; } catch (Throwable e) {              logs.setOperResult("失败：" + e.getMessage());             KafkaMessage ms =new KafkaMessage();             ms.setMsg(logs);             producer.send("logs", ms);             log.error("异常"+e); return null; } } }