Spring Boot执行XML配置批处理任务后数据库连接未释放致连接耗尽问题求助

你遇到的核心问题是每次API请求都手动创建并关闭Spring上下文，导致数据库连接资源无法正确释放，最终引发连接池耗尽的异常。下面是具体的解决方案：

1. 停止手动创建ApplicationContext，复用Spring Boot的全局上下文 #

你的当前代码每次请求都新建ClassPathXmlApplicationContext，虽然调用了context.close()，但Spring Batch相关的数据源、连接池等资源无法被彻底销毁回收。正确的做法是把XML配置的批处理Bean导入到Spring Boot的全局上下文里，由Spring统一管理生命周期。

在你的Spring Boot主类或者配置类上添加@ImportResource注解，导入批处理XML配置：

@SpringBootApplication
@ImportResource("classpath:path/to/batch-job-config.xml")
public class BatchTestApplication {
    public static void main(String[] args) {
        SpringApplication.run(BatchTestApplication.class, args);
    }
}

2. 重构控制器代码，注入所需Bean而非手动创建 #

修改你的控制器，通过构造函数注入Job、JobLauncher、JobRepository等Bean，不用再手动创建上下文：

@RestController
public class BatchJobController {

    private final Job batchJob;
    private final JobLauncher jobLauncher;
    private final JobRepository jobRepository;
    private final JobLauncherTestUtils jobLauncherTestUtils;

    // 构造函数注入Spring管理的Bean
    public BatchJobController(@Qualifier("batch-job_update") Job batchJob,
                              JobLauncher jobLauncher,
                              JobRepository jobRepository,
                              JobLauncherTestUtils jobLauncherTestUtils) {
        this.batchJob = batchJob;
        this.jobLauncher = jobLauncher;
        this.jobRepository = jobRepository;
        this.jobLauncherTestUtils = jobLauncherTestUtils;
        
        // 初始化TestUtils（仅需一次，无需每次请求重复设置）
        this.jobLauncherTestUtils.setJob(batchJob);
        this.jobLauncherTestUtils.setJobLauncher(jobLauncher);
        this.jobLauncherTestUtils.setJobRepository(jobRepository);
    }

    @PostMapping("/execute-batch")
    public ResponseEntity<String> executeBatch(@RequestParam List<String> jobParametersList) {
        try {
            JobParameters jobParameters = getJobParameters(jobParametersList);
            // 直接启动任务，无需每次操作上下文
            JobExecution jobExecution = jobLauncherTestUtils.launchJob(jobParameters);
            return ResponseEntity.ok("Batch job completed with status: " + jobExecution.getStatus());
        } catch (Exception e) {
            return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)
                    .body("Failed to execute batch job: " + e.getMessage());
        }
    }

    // 你的getJobParameters方法保持不变
    private JobParameters getJobParameters(List<String> jobParametersList) {
        // 实现逻辑...
    }
}

3. 优化连接池配置（可选但推荐） #

检查你的数据源连接池配置，确保参数合理，避免因连接池过小导致耗尽。比如使用HikariCP（Spring Boot默认）的话，在application.properties中配置：

# HikariCP连接池配置
spring.datasource.hikari.maximum-pool-size=20
spring.datasource.hikari.minimum-idle=5
spring.datasource.hikari.idle-timeout=300000
spring.datasource.hikari.connection-timeout=20000

4. 考虑直接使用JobLauncher而非JobLauncherTestUtils（可选） #

JobLauncherTestUtils主要用于单元测试场景，在API接口中可以直接使用JobLauncher启动任务，减少不必要的封装：

JobExecution jobExecution = jobLauncher.run(batchJob, jobParameters);

问题根源解释 #

你之前的代码每次请求都新建Spring上下文，虽然调用了context.close()，但Spring Batch的JobRepository依赖的数据源连接池，其资源无法被完全销毁（比如连接池中的连接可能没有被正确归还给数据库）。多次请求后，数据库的连接槽被耗尽，就会抛出remaining connection slots are reserved的异常。复用Spring Boot的全局上下文后，所有资源由Spring统一管理，任务执行完成后连接会正确归还给连接池，避免资源泄漏。

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