通过spring AOP Aspectj的异常处理

Question

在我的项目中，我有一个域层，它基本上是 POJO 和一个位于域层之上的 Spring 控制器/服务层。我还有一个位于服务和域之间的 AOP 层。

我的领域层正在抛出业务异常，这些异常现在正在服务层中处理。

但是我想更改它，以便在 AOP 层中处理从域层抛出的异常。 AOP 层将某种错误响应发送回 spring 控制器/web 服务层。

我可以创建一个 IBizResponse 并创建它的两个子类/接口，可能是一个 SuccessResponse 和一个 ErrorResponse，并使我的域层方法返回 IBizResponse。但是我无法弄清楚如何使 AOP 将 ErrorResponse 对象返回到服务层。

原文由 Nitish Raj 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

请参阅 https://docs.spring.io/spring/docs/4.1.0.RELEASE/spring-framework-reference/htmlsingle/#aop-introduction-defn 的抛出建议部分之后

After throwing advice 在匹配的方法执行通过抛出异常退出时运行。它是使用@AfterThrowing 注释声明的：

例子

import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.AfterThrowing;

@Aspect
public class AfterThrowingExample {

   @AfterThrowing("com.xyz.myapp.SystemArchitecture.dataAccessOperation()")
   public void doRecoveryActions() {
     // ...
    }

}

import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.AfterThrowing;

@Aspect
public class AfterThrowingExample {

    @AfterThrowing(
    pointcut="com.xyz.myapp.SystemArchitecture.dataAccessOperation()",
    throwing="ex")
    public void doRecoveryActions(DataAccessException ex) {
       // ...
     }

}

原文由 vinayknl 发布，翻译遵循 CC BY-SA 3.0 许可协议

Answer 2

我遇到了相同的场景，在任何异常处理的情况下，我都必须返回错误响应 DTO。在@Aspect 类中，

 @Aspect
@Component
public class MyAspect{

    private static final Logger LOGGER = LoggerFactory.getLogger(MyAspect.class);

    @Pointcut("execution(* com.linda.dao.strategy.*.*(..))")
    public void strategyMethods() { }

    @Pointcut("execution(* com.linda.controller.*.*(..)) || execution(* com.linda.Manager.*(..))")
    public void controllerMethods(){  }

    @Around("strategyMethods()")
    public Object profileStrategyMethods(ProceedingJoinPoint pjp) throws Throwable {

        long start = System.currentTimeMillis();
        Object output = null;
        LOGGER.info("Class:"+pjp.getTarget().getClass()+" entry -> method ->"+pjp.getSignature().getName());
        try{
            output = pjp.proceed();
            long elapsedTime = System.currentTimeMillis() - start;
            LOGGER.info("Method execution time: " + elapsedTime + " milliseconds.");
            LOGGER.info("Class:"+pjp.getTarget().getClass()+" exit -> method ->"+pjp.getSignature().getName());
        }catch(Throwable t){
            throw new InternalServerException(t.getMessage());
        }

        return output;
    }

    @AfterThrowing(pointcut="execution(* com.linda.dao.strategy.*.*(..)) || execution(* com.linda.controller.*.*(..)) || execution(* com.linda.Manager.*(..))",throwing = "ex")
    public void doRecoveryActions(JoinPoint joinPoint, Throwable ex) {

        Signature signature = joinPoint.getSignature();
        String methodName = signature.getName();
        String stuff = signature.toString();
        String arguments = Arrays.toString(joinPoint.getArgs());
        LOGGER.error("Write something in the log... We have caught exception in method: "
                + methodName + " with arguments "
                + arguments + "\nand the full toString: " + stuff + "\nthe exception is: "
                + ex.getMessage());
    }
}

定义了另一个异常处理类，如下所示：

 @ControllerAdvice
public class ExceptionLogAdvice {

    @ExceptionHandler(InternalServerException.class)
    @ResponseStatus(HttpStatus.BAD_GATEWAY)
    @ResponseBody
    public ResponseEntity<Object> handleValidationException(final InternalServerException internalServerException){

        ErrorResponseDTO dto = constructErrorResponse(internalServerException);
        return ResponseEntity.status(HttpStatus.BAD_GATEWAY).body(dto);
    }
}

稍微调整了代码，因为我无法共享实际代码。希望我把这个概念说清楚了。

原文由 Linz 发布，翻译遵循 CC BY-SA 4.0 许可协议