事务管理：
// 自定义注解
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface CustomTransactional {
String value() default "";
boolean readOnly() default false;
}
// 业务类
@Service
public class UserService {
@CustomTransactional(value = "userTx", readOnly = false)
public User createUser(User user) {
// 业务逻辑
return userRepository.save(user);
}
@CustomTransactional(value = "queryTx", readOnly = true)
public User getUser(Long id) {
return userRepository.findById(id).orElse(null);
}
}
// AOP切面
@Aspect
@Component
public class TransactionAspect {
@Around("@annotation(tx)")
public Object handleTransaction(ProceedingJoinPoint joinPoint,
CustomTransactional tx) throws Throwable {
System.out.println("=== 事务开始 ===");
System.out.println("事务名称：" + tx.value());
System.out.println("是否只读：" + tx.readOnly());
System.out.println("目标方法：" + joinPoint.getSignature().getName());
try {
Object result = joinPoint.proceed();
System.out.println("=== 事务提交 ===");
return result;
} catch (Exception e) {
System.out.println("=== 事务回滚 ===");
throw e;
}
}
}