春季启动数据连接未发布

Question

我使用XML文件配置了一个批处理作业。我创建了一个新的Spring Boot应用程序，并依赖于此批处理作业。本春季启动应用程序的目的是使用API​​（用于测试目的）运行批处理作业。 让我分享我的实施。

我面临的问题是，

<batch:job id="batch-job_update" parent="baseJob">
        <batch:step id="batch_update.step01">
            <batch:tasklet transaction-manager="transactionManager">
                <batch:chunk
                        reader="batchReader"
                        processor="batchProcessor"
                        writer="batchWriter"
                        commit-interval="1">
                </batch:chunk>
            </batch:tasklet>
        </batch:step>
    </batch:job>

在Spring Boot控制器中，我通过将此XML文件加载到上下文中，

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("path/to/batch-job-config.xml");

Job job = context.getBean("batch-job_update, Job.class);
JobRepository jobRepository = context.getBean("jobRepositoryBeanName", JobRepository.class);
JobLauncher jobLauncher = context.getBean("jobLauncherBeanName", JobLauncher.class);
jobLauncherTestUtils.setJob(job);
jobLauncherTestUtils.setJobLauncher(jobLauncher);
jobLauncherTestUtils.setJobRepository(jobRepository);
JobParameters jobParameters = getJobParameters(jobParametersList);
JobExecution jobExecution = jobLauncherTestUtils.launchJob(jobParameters);

context.close();

我面临的问题是，在运行批处理时创建的DB连接未关闭，并且由于我是我AM使用大量测试用例运行此API，连接耗尽后，我会得到以下例外，

28-06-2022 10:01:38.476 [http-nio-7788-exec-3] ERROR org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/].[dispatcherServlet].log - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'jobRepository': Invocation of init method failed; nested exception is org.springframework.jdbc.support.MetaDataAccessException: Could not get Connection for extracting meta-data; nested exception is org.springframework.jdbc.CannotGetJdbcConnectionException: Failed to obtain JDBC Connection; nested exception is java.sql.SQLException: Cannot create PoolableConnectionFactory (FATAL: remaining connection slots are reserved for non-replication superuser connections)] with root cause
org.postgresql.util.PSQLException: FATAL: remaining connection slots are reserved for non-replication superuser connections

有人可以帮我吗？提前致谢

Answer 1

这是因为您正在为每个请求为API创建一个新的Spring应用程序上下文。您可以将批处理应用程序上下文添加到Spring Boot应用程序中，然后将作业和作业启动器注入控制器，类似：

@RestController
public class JobLaunchingController {

    @Autowired
    private Job job;

    @Autowired
    private JobLauncher jobLauncher;

    @RequestMapping(value = "/", method = RequestMethod.POST)
    @ResponseStatus(HttpStatus.ACCEPTED)
    public void launch(@RequestParam("name") String name) throws Exception {
        JobParameters jobParameters = new JobParametersBuilder()
                        .addString("name", name)
                        .toJobParameters();
        this.jobLauncher.run(job, jobParameters);
    }
}

这将使用主要应用程序上下文的同一数据库连接池关闭。