Java 中怎么用拦截器统计系统中所有事务的平均执行时长-java教程-PHP中文网

首选AOP+TransactionSynchronization统计事务耗时：在@Around中记录起始时间并注册TransactionSynchronization，在afterCompletion中计算并上报，确保精准、低侵入；HandlerInterceptor仅适合粗略请求级统计，DataSource代理适用于SQL级深度观测。

java 中怎么用拦截器统计系统中所有事务的平均执行时长

在 Java 中，可以通过 Spring 的 HandlerInterceptor 或更合适的 TransactionSynchronization + AOP 方式来统计事务执行时长；但需注意：拦截器（HandlerInterceptor）本身无法直接拦截事务的开始与结束，因为它作用于 Web 层（Controller 方法前后），而事务通常由 @Transactional 在 Service 层生效，二者生命周期不重合。真正可靠的方式是结合 TransactionSynchronizationManager 和 AOP，或使用 Spring 提供的 TransactionSynchronization 回调机制。

用 AOP + TransactionSynchronization 统计事务耗时

这是最准确、侵入性小、能覆盖所有 @Transactional 方法的方式：

定义一个切面，匹配所有被 @Transactional 注解的方法（或按包/类名规则）
在 @Around 前记录起始时间，并注册一个 TransactionSynchronization
该同步器的 afterCompletion(int status) 方法会在事务提交/回滚后执行，此时可计算并上报耗时
为避免线程复用导致的上下文污染，务必在 beforeCompletion() 或 afterCompletion() 中清理 ThreadLocal 存储的时间戳

示例代码片段：

spring-boot-starter-aop

@Aspect
@Component
public class TransactionTimingAspect {
<pre class="brush:php;toolbar:false;">private final MeterRegistry meterRegistry; // 如用 Micrometer（推荐）
private final ThreadLocal<long> startTime = new ThreadLocal();

public TransactionTimingAspect(MeterRegistry meterRegistry) {
    this.meterRegistry = meterRegistry;
}

@Pointcut("@annotation(org.springframework.transaction.annotation.Transactional)")
public void transactionalMethod() {}

@Around("transactionalMethod()")
public Object measureTransactionTime(ProceedingJoinPoint joinPoint) throws Throwable {
    long start = System.nanoTime();
    startTime.set(start);

    // 注册事务同步器（仅当当前存在事务时才注册）
    if (TransactionSynchronizationManager.isActualTransactionActive()) {
        TransactionSynchronizationManager.registerSynchronization(
            new TransactionSynchronizationAdapter() {
                @Override
                public void afterCompletion(int status) {
                    Long begin = startTime.get();
                    if (begin != null) {
                        long durationNs = System.nanoTime() - begin;
                        double durationMs = durationNs / 1_000_000.0;

                        // 上报指标（如 Micrometer）
                        Timer.builder("transaction.duration")
                             .tag("method", joinPoint.getSignature().toShortString())
                             .tag("status", status == TransactionSynchronization.STATUS_COMMITTED ? "committed" : "rolledback")
                             .register(meterRegistry)
                             .record(durationMs, TimeUnit.MILLISECONDS);

                        startTime.remove();
                    }
                }
            }
        );
    }

    try {
        return joinPoint.proceed();
    } catch (Throwable t) {
        throw t;
    }
}</long>

}