使用propagate=NEVER仍创建Spring事务致HikariCP连接泄漏问题

问题根源 #

你的代码出现连接泄漏的核心原因是方法上的@Transactional(propagation = NEVER)注解未生效，导致类级别@Transactional的事务配置被应用到testTransactionLeak()方法：

• Spring事务代理基于动态AOP实现，若testTransactionLeak()被同一个控制器类的其他方法内部调用，代理不会拦截该调用，方法上的事务注解会被忽略，类级别的事务会被激活。
• 类级事务生效时，整个testTransactionLeak()方法处于同一个事务上下文内，repository.findAll()获取的数据库连接会被持有到方法执行完毕（包括40秒sleep），超过HikariCP的30秒连接泄漏检测阈值，触发告警。
• 移除所有@Transactional注解后，Spring Data JPA的Repository方法会自动创建并提交短生命周期的只读事务，执行完findAll()后立即释放连接，不会出现泄漏。

解决方案 #

以下几种方式可解决问题，同时保留类级别的@Transactional来统一控制事务：

1. 修正注解参数并确保外部调用代理生效 #

如果testTransactionLeak()是被外部直接调用（如HTTP请求），先修正注解参数的拼写错误，确保方法上的事务注解优先级覆盖类级别配置：

@Transactional(propagation = Propagation.NEVER)
public void testTransactionLeak() throws InterruptedException {
    repository.findAll();
    Thread.sleep(40_000);
}

注：若只是想以非事务方式执行，更推荐使用Propagation.NOT_SUPPORTED——它会挂起现有事务，以非事务模式运行，避免因意外存在事务而抛出异常。

2. 解决内部方法调用的代理失效问题 #

如果testTransactionLeak()被同一个类的其他方法内部调用，需通过代理对象调用该方法：

@Transactional
@RestController
public class TestController {

    @Autowired
    private TestController selfProxy;

    public void someOtherMethod() {
        // 通过代理对象调用，确保事务注解生效
        selfProxy.testTransactionLeak();
    }

    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void testTransactionLeak() throws InterruptedException {
        repository.findAll();
        Thread.sleep(40_000);
    }
}

也可以通过ApplicationContext获取代理对象：

@Autowired
private ApplicationContext context;

public void someOtherMethod() {
    TestController proxy = context.getBean(TestController.class);
    proxy.testTransactionLeak();
}

3. 将无事务方法抽离到独立Bean #

把不需要事务的方法移到单独的Spring Bean中，确保调用时走代理，事务注解生效：

// 保留类级事务的控制器
@Transactional
@RestController
public class TestController {

    @Autowired
    private TestService testService;

    public void someMethod() {
        testService.testTransactionLeak();
    }

    public void otherCrudEndpoint(){
        repository.doSomething();
    }
}

// 独立的无事务服务类
@Service
public class TestService {

    @Autowired
    private YourRepository repository;

    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void testTransactionLeak() throws InterruptedException {
        repository.findAll();
        Thread.sleep(40_000);
    }
}

4. 调整类级事务默认配置 #

如果大部分控制器方法需要事务，少数方法不需要，可将类级@Transactional设为默认，在不需要事务的方法上明确禁用：

@Transactional
@RestController
public class TestController {

    // 禁用事务，以非事务方式执行
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void testTransactionLeak() throws InterruptedException {
        repository.findAll();
        Thread.sleep(40_000);
    }

    // 继承类级事务配置
    public void otherCrudEndpoint(){
        repository.doSomething();
    }
}

内容的提问来源于stack exchange，提问作者KP_EV