Spring Boot 3.3.5中Spring Batch多数据源配置及禁止自动执行任务问题

问题背景 #

基于Spring Boot 3.3.5开发Spring Batch应用，有两个核心需求：

• 把Spring Batch元数据数据库和主应用数据库分离
• 禁止任务在应用启动时自动执行，仅通过编程方式手动触发

已尝试配置spring.batch.job.enabled=false，但任务仍会自动启动，配置存在问题。

现有配置代码 #

多数据源配置（DataSourceFactory） #

@Configuration
@Profile({"!test"})
public class DataSourceFactory {

  @Bean
  @BatchDataSource
  public DataSource h2Datasource() {
    return new EmbeddedDatabaseBuilder()
          .setType(EmbeddedDatabaseType.H2)
          .addScript("classpath:org/springframework/batch/core/schema-drop-h2.sql")
          .addScript("/org/springframework/batch/core/schema-h2.sql")
          .build();
  }

  @Bean
  @BatchTransactionManager
  public PlatformTransactionManager batchTransactionManager() {
    return new JdbcTransactionManager(h2Datasource());
  }

  @Bean
  @Primary
  @ConfigurationProperties("spring.datasource")
  public DataSourceProperties oracleDatasourceProperties() {
    return new DataSourceProperties();
  }

  @Bean
  @Primary
  @ConfigurationProperties("spring.datasource.hikari")
  public DataSource oracleDatasource() {
    return oracleDatasourceProperties().initializeDataSourceBuilder().build();
  }

  @Bean
  @Primary
  public PlatformTransactionManager transactionManager() {
    return new JdbcTransactionManager(oracleDatasource());
  }

}

任务配置（NotificationJobConfig） #

@Configuration
@RequiredArgsConstructor
public class NotificationJobConfig {
    private final JobRepository jobRepository;
    ...
    
    @Bean
    public Job notificationJob() {
    return new JobBuilder(NOTIFICATION_JOB, jobRepository)
          ...
          .build();
    }
}

任务执行服务（JobServiceImpl） #

@Service
@Slf4j
public class JobServiceImpl implements JobService {

  @Autowired
  private JobLauncher jobLauncher;

  @Autowired
  @Qualifier(NotificationJobConfig.NOTIFICATION_JOB)
  private Job notificationJob;

  @Override
  public void runNotification() {
    try {
      JobParameters jobParameters = new JobParametersBuilder().addLocalDateTime("timestamp", LocalDateTime.now()).toJobParameters();
      jobLauncher.run(notificationJob, jobParameters);
    } catch (Exception e) {
      log.error("Error starting notification job: {}", e.getMessage(), e);
    }
  }
}

尝试过的方案与问题 #

方案1：添加@EnableBatchProcessing配置类 #

@Configuration
@EnableBatchProcessing
public class BatchConfig {
    
}

报错信息：

Field jobLauncher in it.coop.coopitalia.rs.service.JobServiceImpl required a bean named 'dataSource' that could not be found.

方案2：继承DefaultBatchConfiguration替代@EnableBatchProcessing #

@Configuration
public class BatchConfig extends DefaultBatchConfiguration {

  @Autowired
  @BatchDataSource
  private DataSource batchDatasource;

  @Autowired
  @BatchTransactionManager
  private PlatformTransactionManager batchTransactionManager;

  @Override
  protected DataSource getDataSource() {
    return batchDatasource;
  }

  @Override
  protected PlatformTransactionManager getTransactionManager() {
    return this.batchTransactionManager;
  }

  @Bean
  public JobLauncher jobLauncher() {
    TaskExecutorJobLauncher jobLauncher = new TaskExecutorJobLauncher();
    try {
      jobLauncher.setJobRepository(jobRepository());
      jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
      jobLauncher.afterPropertiesSet();
    } catch (Exception e) {
      e.printStackTrace();
    }
    return jobLauncher;
  }

}

问题：任务仍会在应用启动时自动执行，spring.batch.job.enabled=false未生效。

解决思路与修正配置 #

1. 核心问题：自动启动逻辑未彻底禁用 #

Spring Boot 3.x中，使用DefaultBatchConfiguration时，默认的JobLauncherApplicationRunner会自动触发Job，即使配置了spring.batch.job.enabled=false也可能被覆盖，需要显式禁用这个Runner。

2. 修正BatchConfig配置 #

@Configuration
public class BatchConfig extends DefaultBatchConfiguration {

    @Autowired
    @BatchDataSource
    private DataSource batchDataSource;

    @Autowired
    @BatchTransactionManager
    private PlatformTransactionManager batchTransactionManager;

    @Override
    protected DataSource getDataSource() {
        return batchDataSource;
    }

    @Override
    protected PlatformTransactionManager getTransactionManager() {
        return batchTransactionManager;
    }

    // 覆盖默认JobLauncher，确保关联正确的JobRepository
    @Override
    public JobLauncher jobLauncher() throws Exception {
        TaskExecutorJobLauncher jobLauncher = new TaskExecutorJobLauncher();
        jobLauncher.setJobRepository(jobRepository());
        jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
        jobLauncher.afterPropertiesSet();
        return jobLauncher;
    }

    // 关键：禁用自动启动Job的ApplicationRunner
    @Override
    public JobLauncherApplicationRunner jobLauncherApplicationRunner(JobLauncher jobLauncher, JobExplorer jobExplorer) {
        JobLauncherApplicationRunner runner = super.jobLauncherApplicationRunner(jobLauncher, jobExplorer);
        runner.setEnable(false); // 强制禁用自动启动
        return runner;
    }
}

3. 确认配置文件参数 #

确保application.properties/application.yml中正确设置：

spring.batch.job.enabled=false

或YAML格式：

spring:
  batch:
    job:
      enabled: false

4. 排查额外触发逻辑 #

检查代码中是否存在其他自动触发Job的逻辑：

• NotificationJobConfig或其他类中是否有@PostConstruct注解的方法调用任务执行
• 是否有@Scheduled注解的定时任务在启动时触发
• 其他组件是否在应用初始化阶段调用了JobServiceImpl.runNotification()

5. 验证数据源事务隔离 #

当前DataSourceFactory中已正确区分主数据源（@Primary）和Batch数据源（@BatchDataSource），以及对应的事务管理器，这部分配置无需修改，确保Batch组件使用的是专用数据源即可。

总结 #

• 任务自动启动的核心原因是JobLauncherApplicationRunner未被禁用，需在BatchConfig中显式设置其enabled=false
• 配合配置文件的spring.batch.job.enabled=false双重保障
• 排查代码中是否存在手动触发Job的初始化逻辑

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