SpringBoot基于AOP的Controller实现统一日志打印的完整方案

<!-- Spring AOP 核心依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<!-- FastJSON 用于参数序列化 -->
<dependency>
    <groupId>com.alibaba.fastjson2</groupId>
    <artifactId>fastjson2</artifactId>
    <version>2.0.32</version>
</dependency>
<!-- Lombok 简化日志开发 -->
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>

package com.xm.kite.ztc.common.aspect;

import com.alibaba.fastjson2.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.List;

/**
 * AOP统一日志处理切面
 * 自动打印Controller层接口：URL、方法名、入参、响应结果、执行耗时
 * 支持慢接口告警配置
 */
@Slf4j
@Aspect
@Component
public class LoggerHandler {

    /**
     * 慢接口阈值（单位：毫秒）
     * 从配置文件读取，默认2000ms（2秒）
     */
    @Value("${method-logger.elapsed-time:2000}")
    private Long loggerHandlerElapsedTimeMs;

    /**
     * 切点：匹配指定包下所有Controller的所有方法
     * 可根据项目包路径灵活修改！！！
     */
    @Pointcut("execution(* com.xm.kite.ztc..controller..*.*(..))")
    public void allControllerMethods() {
    }

    /**
     * 环绕通知：包裹目标接口，执行前后统一处理日志
     */
    @Around("allControllerMethods()")
    public Object logAround(ProceedingJoinPoint joinPoint) throws Throwable {
        // 1. 记录接口开始时间
        long startTime = System.currentTimeMillis();

        // 2. 获取Http请求对象，解析请求URL
        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        HttpServletRequest request = attributes.getRequest();
        String requestUrl = request.getRequestURL().toString();

        // 3. 获取当前接口的类、方法名
        Logger currentLogger = LoggerFactory.getLogger(joinPoint.getSignature().getDeclaringType());
        String methodName = joinPoint.getSignature().getName();

        // 4. 安全处理入参：过滤HttpServletRequest/Response，避免序列化异常
        List<Object> safeArgs = new ArrayList<>();
        for (Object arg : joinPoint.getArgs()) {
            if (arg instanceof HttpServletRequest || arg instanceof HttpServletResponse) {
                safeArgs.add("[" + arg.getClass().getSimpleName() + "]");
            } else {
                safeArgs.add(arg);
            }
        }
        // 入参序列化为JSON
        String requestArgs = JSONObject.toJSONString(safeArgs);

        // 5. 打印【请求入参】日志
        currentLogger.info("请求开始 >>> url: {}, method: {}, args: {}", requestUrl, methodName, requestArgs);

        // 6. 执行目标接口方法
        Object result = joinPoint.proceed();

        // 7. 计算接口耗时
        long elapsedTime = System.currentTimeMillis() - startTime;
        String responseResult = JSONObject.toJSONString(result);

        // 8. 分级打印【响应结果】日志：慢接口WARN告警，正常接口INFO打印
        if (elapsedTime > loggerHandlerElapsedTimeMs) {
            currentLogger.warn("请求结束【慢接口告警】>>> 阈值:{}ms, url: {}, method: {}, args: {}, result: {}, 耗时:{}ms",
                    loggerHandlerElapsedTimeMs, requestUrl, methodName, requestArgs, responseResult, elapsedTime);
        } else {
            currentLogger.info("请求结束 >>> url: {}, method: {}, args: {}, result: {}, 耗时:{}ms",
                    requestUrl, methodName, requestArgs, responseResult, elapsedTime);
        }

        return result;
    }
}

# 日志配置：慢接口阈值（单位：毫秒）
method-logger:
  elapsed-time: 1500  # 调整为1.5秒，根据项目需求修改

// 获取请求方式
String requestMethod = request.getMethod();
// 获取客户端IP
String clientIp = request.getRemoteAddr();
// 日志中新增打印
currentLogger.info("url: {}, ip: {}, requestType: {}, method: {}, args: {}", 
        requestUrl, clientIp, requestMethod, methodName, requestArgs);

// 改造入参过滤逻辑，隐藏敏感字段
for (Object arg : safeArgs) {
    if (arg instanceof UserDTO) {
        UserDTO user = (UserDTO) arg;
        user.setPassword("***"); // 密码脱敏
    }
}

// 新增配置开关
@Value("${method-logger.enabled:true}")
private boolean loggerEnabled;

// 环绕通知中判断
@Around("allControllerMethods()")
public Object logAround(ProceedingJoinPoint joinPoint) throws Throwable {
    if (!loggerEnabled) {
        return joinPoint.proceed(); // 关闭日志，直接执行接口
    }
    // 原有日志逻辑...
}

// 示例1：只打印指定包下的接口
@Pointcut("execution(* com.xm.kite.ztc.user.controller..*.*(..))")
// 示例2：只打印带有@GetMapping注解的方法
@Pointcut("@annotation(org.springframework.web.bind.annotation.GetMapping)")

// 直接删除result参数，简化日志
currentLogger.info("请求结束 >>> url: {}, 耗时:{}ms", requestUrl, elapsedTime);

# 正常接口
INFO  c.x.k.z.t.controller.UserController - 请求开始 >>> url: http://localhost:8080/user/get, method: getUser, args: {"id":1}
INFO  c.x.k.z.t.controller.UserController - 请求结束 >>> url: http://localhost:8080/user/get, method: getUser, args: {"id":1}, result: {"code":200,"data":{"name":"张三"}}, 耗时:12ms

# 慢接口告警
WARN  c.x.k.z.t.controller.OrderController - 请求结束【慢接口告警】>>> 阈值:2000ms, url: http://localhost:8080/order/list, method: getOrderList, args: {"page":1}, result: {...}, 耗时:2560ms