SpringBoot优雅统计接口耗时实战中的四种高效方案

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>

@Aspect
@Component
@Slf4j
public class ApiTimeAspect {
    
    // 定义切入点：所有Controller的public方法
    @Pointcut("execution(public * com.example..controller.*.*(..))")
    public void apiPointcut() {}
    
    @Around("apiPointcut()")
    public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
        long startTime = System.currentTimeMillis();
        Object result;
        try {
            result = joinPoint.proceed();
        } finally {
            long cost = System.currentTimeMillis() - startTime;
            recordCost(joinPoint, cost);
        }
        return result;
    }
    
    private void recordCost(ProceedingJoinPoint joinPoint, long cost) {
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        String methodName = signature.getDeclaringTypeName() + "." + signature.getName();
        
        log.info("API耗时统计 || 方法: {} || 耗时: {}ms", methodName, cost);
        
        // 可扩展存储到数据库
        // monitorService.saveApiCost(methodName, cost);
    }
}

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface TimeMonitor {
    String value() default "";
}

// 在切面中修改切入点表达式
@Pointcut("@annotation(com.example.annotation.TimeMonitor)")
public void annotationPointcut() {}

// 使用示例
@RestController
public class OrderController {
    
    @TimeMonitor("创建订单接口")
    @PostMapping("/orders")
    public Order createOrder() {
        // 业务逻辑
    }
}

@WebFilter(urlPatterns = "/*")
@Slf4j
public class TimeCostFilter implements Filter {
    
    @Override
    public void doFilter(ServletRequest request, ServletResponse response, 
                       FilterChain chain) throws IOException, ServletException {
        long start = System.currentTimeMillis();
        try {
            chain.doFilter(request, response);
        } finally {
            HttpServletRequest req = (HttpServletRequest) request;
            String uri = req.getRequestURI();
            long cost = System.currentTimeMillis() - start;
            
            log.info("请求路径: {} || 耗时: {}ms", uri, cost);
        }
    }
}

@SpringBootApplication
@ServletComponentScan
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

@Component
@Slf4j
public class TimeInterceptor implements HandlerInterceptor {
    
    private static final ThreadLocal<Long> TIME_HOLDER = new ThreadLocal<>();
    
    @Override
    public boolean preHandle(HttpServletRequest request, 
                            HttpServletResponse response, 
                            Object handler) {
        TIME_HOLDER.set(System.currentTimeMillis());
        return true;
    }
    
    @Override
    public void afterCompletion(HttpServletRequest request,
                               HttpServletResponse response,
                               Object handler, Exception ex) {
        long start = TIME_HOLDER.get();
        long cost = System.currentTimeMillis() - start;
        TIME_HOLDER.remove();
        
        String params = getRequestParams(request);
        log.info("请求路径: {}?{} || 耗时: {}ms", 
                request.getRequestURI(), params, cost);
    }
    
    private String getRequestParams(HttpServletRequest request) {
        return request.getParameterMap().entrySet().stream()
            .map(entry -> entry.getKey() + "=" + Arrays.toString(entry.getValue()))
            .collect(Collectors.joining("&"));
    }
}

@Configuration
public class WebConfig implements WebMvcConfigurer {
    
    @Autowired
    private TimeInterceptor timeInterceptor;
    
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(timeInterceptor)
            .addPathPatterns("/api/**");
    }
}

<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-registry-prometheus</artifactId>
</dependency>

@Configuration
public class MetricsConfig {
    
    @Bean
    public TimedAspect timedAspect(MeterRegistry registry) {
        return new TimedAspect(registry);
    }
}

// 在Controller方法上添加注解
@RestController
public class ProductController {
    
    @Timed(value = "product.detail.time", description = "商品详情接口耗时")
    @GetMapping("/products/{id}")
    public Product getDetail(@PathVariable Long id) {
        // 业务逻辑
    }
}

scrape_configs:
  - job_name: 'spring_app'
    metrics_path: '/actuator/prometheus'
    static_configs:
      - targets: ['localhost:8080']

@Async
public void saveCostLog(String method, long cost) {
    // 异步存储到数据库
}

if (random.nextDouble() < 0.1) { // 10%采样率
    recordCost(joinPoint, cost);
}

try {
    recordCost(...);
} catch (Exception e) {
    log.error("耗时统计异常", e);
}