Spring AOP异步定时任务日志优先级与自定义消息配置问题

一、先修复递归无限循环问题 #

原切面的递归问题核心是切点表达式包含了createErrorLogEntry日志方法本身——当切面捕获异常后调用该日志方法时，会再次触发切面逻辑，陷入无限循环。

修正方案：在切点中排除日志记录方法 #

假设你的日志方法位于ErrorLogService类中，调整切点表达式如下：

// 匹配异步/定时任务的基础切点
@Pointcut("@annotation(org.springframework.scheduling.annotation.Scheduled) || @annotation(org.springframework.scheduling.annotation.Async)")
public void asyncOrScheduledTask() {}

// 排除日志记录方法的切点
@Pointcut("execution(* com.yourpackage.ErrorLogService.createErrorLogEntry(..))")
public void errorLogMethod() {}

// 最终有效切点：匹配异步/定时任务，但排除日志方法
@Pointcut("asyncOrScheduledTask() && !errorLogMethod()")
public void targetTaskMethods() {}

后续切面通知（如@AfterThrowing）使用targetTaskMethods()作为切点，即可避免递归循环。

二、针对特定类配置自定义优先级与错误消息 #

最灵活的实现方式是通过自定义注解，在目标类/方法上标记配置信息，切面动态读取后生成对应日志。

1. 定义自定义配置注解 #

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface ErrorLogConfig {
    enum Priority {LOW, MEDIUM, CRITICAL}
    
    Priority priority() default Priority.LOW;
    String customMessage() default "任务执行异常";
}

2. 在目标任务类/方法上标记注解 #

比如给某个定时任务类设置CRITICAL优先级和自定义消息：

@Service
@ErrorLogConfig(priority = ErrorLogConfig.Priority.CRITICAL, customMessage = "订单定时同步任务失败")
public class OrderSyncTask {
    @Scheduled(cron = "0 0 * * * ?")
    public void syncOrders() {
        // 业务逻辑代码
    }
}

也可以单独给某个异步方法设置配置：

@Service
public class DataExportTask {
    @Async
    @ErrorLogConfig(priority = ErrorLogConfig.Priority.MEDIUM, customMessage = "数据导出异步任务失败")
    public void exportData() {
        // 业务逻辑代码
    }
}

3. 在切面中读取注解配置并生成日志 #

修改切面的异常通知逻辑，动态获取注解配置：

@Aspect
@Component
public class ErrorEntryLogger {
    @Autowired
    private ErrorLogService errorLogService;

    @AfterThrowing(pointcut = "targetTaskMethods()", throwing = "ex")
    public void logError(JoinPoint joinPoint, Throwable ex) {
        // 获取目标类与方法
        Class<?> targetClass = joinPoint.getTarget().getClass();
        Method targetMethod = ((MethodSignature) joinPoint.getSignature()).getMethod();
        
        // 优先读取方法上的注解，无则读取类上的注解
        ErrorLogConfig methodConfig = targetMethod.getAnnotation(ErrorLogConfig.class);
        ErrorLogConfig classConfig = targetClass.getAnnotation(ErrorLogConfig.class);
        ErrorLogConfig config = methodConfig != null ? methodConfig : classConfig;

        // 确定最终的优先级与错误消息
        String priority = config != null ? config.priority().name() : "LOW";
        String errorMsg = config != null ? config.customMessage() : "任务执行异常";

        // 调用日志方法（已通过切点排除，不会触发递归）
        errorLogService.createErrorLogEntry(ex.getStackTrace(), errorMsg, priority);
    }

    // 前面定义的切点方法
}

三、代码优化建议 #

• 切点精准化：如果异步/定时任务集中在特定包下，可以给切点加上包路径限制，比如execution(* com.yourpackage.tasks..*(..)) && (@annotation(Scheduled) || @annotation(Async))，减少无意义的切面匹配。
• 异常细分处理：如果需要针对不同异常类型调整日志规则，可以在通知方法中判断异常类型，比如if (ex instanceof SQLException) { /* 数据库异常特殊处理 */ }。
• 参数封装：将堆栈信息、错误消息、优先级封装成ErrorLogDTO对象，简化createErrorLogEntry的参数列表，提升代码可读性。
• 逻辑解耦：如果后续日志规则复杂（比如根据异常级别动态调整优先级），建议把规则逻辑抽离到单独的服务类中，切面只负责切点匹配和参数传递。
• 测试覆盖：编写单元测试验证切面逻辑，比如测试递归是否被排除、不同注解配置下的日志参数是否正确、异常捕获是否正常。

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