在生产环境中，在spring批处理应用程序中使用哪种事务管理器最好？

Question

您能告诉我生产中的Spring批处理应用程序应该使用哪个事务管理器吗？我使用的是无资源事务管理器。没事吧？在从外部Oracle DB读取数据时，我遇到了这个问题

[org.springframework.scheduling.support.TaskUtils$LoggingErrorHandler]（pool-3130-thread-1）计划任务中出现意外错误：组织。springframework。交易CannotCreateTransactionException:无法为事务打开JDBC连接；嵌套的例外是java。sql。SQLRecoverableException:关闭连接

@Bean
    public ResourcelessTransactionManager resourcelessTransactionManager() {
        return new ResourcelessTransactionManager();
    }

    @Bean
    public MapJobRepositoryFactoryBean mapJobRepositoryFactory(
            ResourcelessTransactionManager txManager) throws Exception {

        //LOGGER.info("Inside mapJobRepositoryFactory method");
        MapJobRepositoryFactoryBean factory = new MapJobRepositoryFactoryBean(txManager);
        factory.setTransactionManager(txManager);
        factory.setIsolationLevelForCreate("ISOLATION_READ_UNCOMMITTED");
        factory.afterPropertiesSet();

        return factory;
    }

    @Bean
    public JobRepository jobRepository(
            MapJobRepositoryFactoryBean factory) throws Exception {

        //LOGGER.info("Inside jobRepository method");
        return factory.getObject();
    }

    @Bean
    public ThreadPoolTaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(5);
        taskExecutor.setMaxPoolSize(10);
        taskExecutor.setQueueCapacity(30);
        return taskExecutor;
    }

    @Bean
    public JobLauncher jobLauncher(JobRepository jobRepository,ThreadPoolTaskExecutor taskExecutor) {

        //LOGGER.info("Inside jobLauncher method");
        SimpleJobLauncher launcher = new SimpleJobLauncher();
        launcher.setTaskExecutor(taskExecutor);
        launcher.setJobRepository(jobRepository);
        final SimpleAsyncTaskExecutor simpleAsyncTaskExecutor = new SimpleAsyncTaskExecutor();
        launcher.setTaskExecutor(simpleAsyncTaskExecutor);
        return launcher;
    }

Answer 1

正如您在问题中所说，您使用的是Oracle DB，因此您很可能不需要ResourcesTransansActionManager。

您当前的代码所做的是将作业元数据存储到基于映射的内存结构中，我猜您不会在生产环境中这样做，而是将作业元数据存储在数据库中，以便以后进行分析、重新启动等

在Spring Batch中，有两种事务——一种是针对业务数据和方法的事务，另一种是针对作业存储库的事务，假设您希望从文件中读取、写入文件，并希望将作业元数据存储到MapJobRepository中，那么您的代码就可以正常工作了。

但是一旦定义了数据源，就不能使用ResourcesTransactionManager。事实上，对于数据库，您不需要自己定义任何事务管理器，但Spring面向块的批处理将自行处理，并将作业元数据存储到数据库中。