SpringBoot集成Atomikos出现连接池耗尽空闲连接堆积问题咨询

根因定位 #

经排查你的代码和配置存在以下核心问题导致空闲连接无法回收：

• 配置映射错误：application.yml中tac数据源参数存放在app.datasource.tac节点下，但DataSourceConfigurationTAC.java中borrowConnectionTimeout、maxIdleTime、minPoolSize、maxPoolSize参数的@Value注解错误读取app.datasource.danc前缀，导致核心回收参数未生效，maxIdleTime默认值为0代表空闲连接永久不回收，直接导致连接持续堆积耗尽池资源。
• 缺少连接池维护线程显式配置：Atomikos默认的连接池空闲检查间隔较长，未显式配置的情况下回收逻辑执行频率不足。
• Atomikos 4.0.6版本存在已知的非XA数据源连接释放bug，会导致部分完成事务的连接未被正确归还到连接池。

修复步骤 #

1. 修正配置映射前缀 #

修改DataSourceConfigurationTAC.java中的@Value注解前缀，确保参数正确注入：

// 原错误前缀app.datasource.danc改为app.datasource.tac
@Value("${app.datasource.tac.borrow_conn_timeout}")
Integer borrowConnectionTimeout;

@Value("${app.datasource.tac.max_idle_time}")
Integer maxIdleTime;

@Value("${app.datasource.tac.min_pool_size}")
Integer minPoolSize;

@Value("${app.datasource.tac.max_pool_size}")
Integer maxPoolSize;

2. 显式配置连接池维护参数 #

在application.yml的app.datasource.tac节点下新增维护间隔配置：

tac:
  # 原有配置不变，新增以下参数
  pool_maintenance_interval: 30 # 连接池后台检查线程执行间隔，单位秒
  test_on_borrow: true # 借取连接时校验连接有效性
  test_while_idle: true # 空闲时校验连接有效性

在DataSourceConfigurationTAC.java的tacDataSource方法中补充配置注入：

@Value("${app.datasource.tac.pool_maintenance_interval}")
Integer poolMaintenanceInterval;

@Value("${app.datasource.tac.test_on_borrow}")
Boolean testOnBorrow;

@Value("${app.datasource.tac.test_while_idle}")
Boolean testWhileIdle;

@Bean(name = "dataSource")
@Primary
public DataSource tacDataSource() throws SQLException {
    AtomikosNonXADataSourceBean bean = new AtomikosNonXADataSourceBean();
    // 原有配置不变，新增以下配置
    bean.setPoolSizeMaintenanceInterval(poolMaintenanceInterval);
    bean.setTestOnBorrow(testOnBorrow);
    bean.setTestWhileIdle(testWhileIdle);
    return bean;
}

3. 可选优化：升级Atomikos版本 #

将Atomikos依赖版本升级到4.0.7及以上，该版本修复了4.0.6存在的非XA数据源连接泄漏问题，无需修改业务代码兼容性良好。

4. 事务边界校验 #

新增全局事务异常拦截逻辑，确保所有事务执行完成后无论成功或异常都能正确提交/回滚，避免业务代码异常导致事务未结束、连接被长期占用。

效果验证 #

• 压测验证：启动应用执行事务压测，压测结束后等待max_idle_time + pool_maintenance_interval的时间，通过数据库连接查询命令（PostgreSQL执行select count(*) from pg_stat_activity where datname = '你的库名'）观察连接数是否下降到minPoolSize附近，确认空闲回收逻辑生效。
• 日志验证：将com.atomikos.jdbc日志级别调整为DEBUG，检查是否有空闲连接销毁的日志输出。

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