本文介绍如何在 Spring AOP 中结合自定义注解（如 @Priority 和 @ErrorMessage），实现对异步/定时任务异常日志的精细化控制，避免硬编码低优先级和通用消息，提升错误追踪的准确性和可维护性。
本文介绍如何在 spring aop 中结合自定义注解（如 `@priority` 和 `@errormessage`），实现对异步/定时任务异常日志的精细化控制，避免硬编码低优先级和通用消息，提升错误追踪的准确性和可维护性。
在使用 Spring AOP 统一捕获异步或定时任务异常时，若所有错误都统一记录为 LOW 优先级和泛化消息（如 "An error occurred"），将严重削弱日志的诊断价值。理想方案是让业务逻辑决定日志语义——即由具体方法声明其期望的错误级别与上下文描述，AOP 切面则负责解析并执行标准化记录。
✅ 正确做法：定义可配置的元数据注解
首先，创建两个轻量、运行时可用的自定义注解，用于声明错误优先级和自定义消息：
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD, ElementType.TYPE})
public @interface Priority {
ErrorLogEntryPriorityType value() default ErrorLogEntryPriorityType.LOW;
}
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD, ElementType.TYPE})
public @interface ErrorMessage {
String value() default "An error occurred";
}
? 注意：@Target 同时支持 METHOD 和 TYPE，便于在类级别统一设置默认策略（如整个定时任务类默认为 CRITICAL），方法级注解则可覆盖。
✅ 改进后的切面逻辑（关键修复与增强）
原切面存在两处严重问题：
- 切点表达式错误：@Scheduled && @Async 不可能同时成立（Spring 不允许同一方法同时标注二者）；应改为 @Scheduled || @Async 或分别定义两个切点。
- 无限递归调用：return createErrorEntryLogger(pjp); 导致栈溢出 —— 这是致命 Bug，必须移除。
修正后的切面如下：
@Aspect
@Component
public class ErrorEntryLogger {
@Autowired
private ErrorLogEntryManager errorLogEntryManager;
// 拦截所有 @Scheduled 方法
@Around("@annotation(org.springframework.scheduling.annotation.Scheduled)")
public Object logScheduledErrors(ProceedingJoinPoint pjp) throws Throwable {
return handleException(pjp, ErrorLogEntryPriorityType.LOW, "Scheduled task failed");
}
// 拦截所有 @Async 方法
@Around("@annotation(org.springframework.scheduling.annotation.Async)")
public Object logAsyncErrors(ProceedingJoinPoint pjp) throws Throwable {
return handleException(pjp, ErrorLogEntryPriorityType.LOW, "Async operation failed");
}
// 核心异常处理逻辑（复用）
private Object handleException(ProceedingJoinPoint pjp, ErrorLogEntryPriorityType defaultPriority, String defaultMessage) throws Throwable {
try {
return pjp.proceed();
} catch (Exception e) {
Method method = ((MethodSignature) pjp.getSignature()).getMethod();
// 优先读取方法级 @Priority，未声明则回退到类级，最后用默认值
Priority priorityAnn = AnnotationUtils.findAnnotation(method, Priority.class);
if (priorityAnn == null) {
priorityAnn = AnnotationUtils.findAnnotation(method.getDeclaringClass(), Priority.class);
}
ErrorLogEntryPriorityType priority = (priorityAnn != null)
? priorityAnn.value()
: defaultPriority;
// 同理处理 @ErrorMessage
ErrorMessage msgAnn = AnnotationUtils.findAnnotation(method, ErrorMessage.class);
if (msgAnn == null) {
msgAnn = AnnotationUtils.findAnnotation(method.getDeclaringClass(), ErrorMessage.class);
}
String message = (msgAnn != null) ? msgAnn.value() : defaultMessage;
// 记录日志（注意：此处 userId 为 null，生产中建议从 SecurityContext 或参数提取）
errorLogEntryManager.createErrorLogEntry(null, e, priority, message);
throw e; // 重要：不吞异常，保证调用方感知失败
}
}
}
✅ 使用示例：按需声明语义化错误信息
@Service
@Priority(ErrorLogEntryPriorityType.MEDIUM) // 类级默认优先级
public class DataSyncService {
@Scheduled(fixedDelay = 30000)
@Priority(ErrorLogEntryPriorityType.CRITICAL) // 覆盖为高优
@ErrorMessage("Failed to sync user data from legacy system")
public void syncUsers() {
// 可能抛出异常...
throw new RuntimeException("Connection timeout");
}
@Async
@ErrorMessage("Background notification send failed for order #{#orderId}")
public CompletableFuture<void> sendOrderNotification(Long orderId) {
// ...
return CompletableFuture.completedFuture(null);
}
}</void>
⚠️ 关键注意事项
- 不要吞异常：切面中 catch 后必须 throw e（或重新包装），否则上游无法感知执行失败，导致任务静默中断。
- userId 的获取：当前示例传入 null，实际应结合 SecurityContextHolder、MDC 上下文或方法参数（如 @AuthenticationPrincipal）提取用户标识。
- 性能考虑：AnnotationUtils.findAnnotation() 内部已做缓存优化，无需额外担心反射开销；高频场景可预解析并缓存方法元数据。
- 事务边界：若 createErrorLogEntry 需独立事务（避免主流程回滚导致日志丢失），请为其添加 @Transactional(propagation = Propagation.REQUIRES_NEW)。
通过该设计，你既消除了重复的 try-catch 模板代码，又保留了业务层对错误语义的完全控制权——这才是 AOP “横切关注点分离” 的真正价值所在。
