炸裂！Spring AOP 竟能让代码效率飙升 10 倍？架构师私藏的高级玩法全曝光，看完直接封神！

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

import java.util.Arrays;

@Aspect
@Component
public class LoggingAspect {

    // 定义切入点
    @Pointcut("execution(* com.example.service.*.*(..))")
    public void serviceMethods() {}

    // 前置通知
    @Before("serviceMethods()")
    public void beforeAdvice(JoinPoint joinPoint) {
        System.out.println("Before method: " + joinPoint.getSignature().getName() + 
                           " with arguments: " + Arrays.toString(joinPoint.getArgs()));
    }

    // 后置通知
    @AfterReturning(pointcut = "serviceMethods()", returning = "result")
    public void afterReturningAdvice(JoinPoint joinPoint, Object result) {
        System.out.println("After returning method: " + joinPoint.getSignature().getName() +
                           " with result: " + result);
    }

    // 异常通知
    @AfterThrowing(pointcut = "serviceMethods()", throwing = "ex")
    public void afterThrowingAdvice(JoinPoint joinPoint, Exception ex) {
        System.out.println("After throwing method: " + joinPoint.getSignature().getName() +
                           " with exception: " + ex.getMessage());
    }

    // 最终通知
    @After("serviceMethods()")
    public void afterFinallyAdvice(JoinPoint joinPoint) {
        System.out.println("After finally method: " + joinPoint.getSignature().getName());
    }

    // 环绕通知
    @Around("serviceMethods()")
    public Object aroundAdvice(ProceedingJoinPoint joinPoint) throws Throwable {
        long startTime = System.currentTimeMillis();
        Object result = joinPoint.proceed(); // 执行目标方法
        long timeTaken = System.currentTimeMillis() - startTime;
        System.out.println("Around method: " + joinPoint.getSignature().getName() +
                           " took " + timeTaken + " ms");
        return result;
    }
}

package com.example.service;

import org.springframework.stereotype.Service;

@Service
public class UserService {

    public String getUserInfo(String userId) {
        System.out.println("Fetching user info for user: " + userId);
        return "User Info for " + userId;
    }

    public void updateUser(String userId, String info) {
        System.out.println("Updating user info for user: " + userId);
    }
}

import com.example.service.UserService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class AopTest {
    public static void main(String[] args) {
        ApplicationContext context = new AnnotationConfigApplicationContext("com.example");
        UserService userService = context.getBean(UserService.class);

        userService.getUserInfo("123");
        userService.updateUser("123", "New Info");
    }
}

import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;

@Aspect
@Component
public class TransactionAspect {

    @Autowired
    private PlatformTransactionManager transactionManager;

    @Pointcut("execution(* com.example.service.*.*(..))")
    public void transactionalMethods() {}

    @Around("transactionalMethods()")
    public Object manageTransaction(ProceedingJoinPoint joinPoint) throws Throwable {
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        TransactionStatus status = transactionManager.getTransaction(def);

        try {
            Object result = joinPoint.proceed();
            transactionManager.commit(status);
            return result;
        } catch (Exception e) {
            transactionManager.rollback(status);
            throw e;
        }
    }
}

package com.example.service;

import org.springframework.stereotype.Service;

@Service
public class OrderService {

    public void placeOrder(String orderId) {
        System.out.println("Placing order: " + orderId);
        // 模拟数据库操作
        if (orderId.equals("fail")) {
            throw new RuntimeException("Order placement failed");
        }
        System.out.println("Order placed successfully");
    }
}

import com.example.service.OrderService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class TransactionTest {
    public static void main(String[] args) {
        ApplicationContext context = new AnnotationConfigApplicationContext("com.example");
        OrderService orderService = context.getBean(OrderService.class);

        orderService.placeOrder("123"); // 成功
        orderService.placeOrder("fail"); // 失败
    }
}