Aspect AOP未拦截切入点内所有抛异常方法问题排查

在微服务系统中实现了一个用于错误日志记录与上报的Aspect，但该切面并未拦截切入点内所有抛出异常的方法。例如调用Kafka消息处理方法时出现SerializationException，切面既未拦截也未记录该异常。尝试过@Around和@AfterThrowing注解，@Around无生效通知，@AfterThrowing虽有适用通知但仍无法覆盖全部场景。

提供的代码 #

切面代码 #

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

@Component
@Aspect
@Slf4j
public class LoggingAspect {
    @Pointcut("execution(* *(..)) && within(com.example..*)")
    public void triggerPointcut() {
        System.out.println("triggerPointcut");
    }
    

    @AfterThrowing(pointcut = "triggerPointcut()", throwing = "ex")
    public void logAfterThrowingAllMethods(JoinPoint joinPoint, Throwable ex) {
        System.out.println("****LoggingAspect.logAfterThrowingAllMethods() " + ex);
    }
}

未被拦截的目标代码 #

@Slf4j
public class KafkaRunner implements Runnable{
    private final Consumer<String, Object> consumer;

    public KafkaRunner(Consumer<String, Object> consumer) {
        this.consumer = consumer;
    }

    public void start(){
        consumer.subscribe(Collections.singletonList("topic"));
        try{
            while(true){
                ConsumerRecords<String, Object> records = consumer.poll(Duration.ofMillis(100));
                for(ConsumerRecord<String, Object> record : records){
                    System.out.println("Received message: (" + record.key() + ", " + record.value() + ") at offset " + record.offset());
                }
            }
        } catch (Exception e){
            System.out.println("Exception occurred: " + e);
        } finally {
            consumer.close();
        }
    
    }
}

原因分析与解决方案 #

1. 异常被方法内部捕获，未向外抛出 #

@AfterThrowing注解仅能拦截方法向外抛出的未捕获异常，而KafkaRunner的start方法用try-catch块捕获了所有Exception且未重新抛出，异常被方法内部吞掉，切面无法感知。

解决方式：

• 在catch块中重新抛出异常（可包装为运行时异常）：

  catch (Exception e){
      System.out.println("Exception occurred: " + e);
      throw new RuntimeException("Kafka消费异常", e);
  }
  

• 若不想修改业务代码，改用AspectJ原生织入（编译时/加载时织入），它能拦截方法内部的异常，不依赖Spring代理机制。

2. 目标类未被Spring容器管理 #

Spring AOP基于动态代理实现，仅能拦截Spring容器中的Bean。如果KafkaRunner是手动new出来的实例，而非Spring注入的Bean，切面无法生效。

解决方式：

• 给KafkaRunner添加@Component或@Service注解，使其成为Spring Bean；
• 手动创建实例时，通过ApplicationContext.getBean()获取，而非直接new。

3. 切入点范围验证 #

确认KafkaRunner所在的包是否在com.example..*范围内，若不在，切入点triggerPointcut()不会匹配该类方法，导致切面不生效。

内容的提问来源于stack exchange，提问作者nova_rem