Spring Batch 5双数据源配置：@EnableBatchProcessing用法及版本最佳实践对比

1. 如何在Spring Batch 5中配置两个数据源？ #

• 先在配置类中定义两个DataSource Bean，明确区分业务数据源和Batch元数据数据源：

  @Configuration
  public class DataSourceConfig {
      // 业务数据源，标记@Primary确保业务组件默认注入此数据源
      @Bean
      @Primary
      public DataSource businessDataSource() {
          return DataSourceBuilder.create()
              .url("jdbc:mysql://localhost:3306/business_db")
              .username("user")
              .password("pass")
              .driverClassName("com.mysql.cj.jdbc.Driver")
              .build();
      }
  
      // Batch元数据专用数据源
      @Bean
      public DataSource batchMetadataDataSource() {
          return DataSourceBuilder.create()
              .url("jdbc:mysql://localhost:3306/batch_metadata_db")
              .username("user")
              .password("pass")
              .driverClassName("com.mysql.cj.jdbc.Driver")
              .build();
      }
  }
  

• 再配置Batch核心组件，指定使用元数据数据源：

  @Configuration
  public class BatchCoreConfig {
      // Batch专用事务管理器
      @Bean
      public PlatformTransactionManager batchTransactionManager(@Qualifier("batchMetadataDataSource") DataSource batchDataSource) {
          return new DataSourceTransactionManager(batchDataSource);
      }
  
      // 配置JobRepository，绑定元数据数据源和专用事务管理器
      @Bean
      public JobRepository jobRepository(@Qualifier("batchMetadataDataSource") DataSource batchDataSource, PlatformTransactionManager batchTransactionManager) throws Exception {
          JobRepositoryFactoryBean factoryBean = new JobRepositoryFactoryBean();
          factoryBean.setDataSource(batchDataSource);
          factoryBean.setTransactionManager(batchTransactionManager);
          factoryBean.setDatabaseType("MYSQL");
          return factoryBean.getObject();
      }
  }
  

2. 如何借助@EnableBatchProcessing注解并扩展默认配置来使用双数据源？ #

Spring Batch 5中@EnableBatchProcessing不再自动注册全量默认Bean，推荐通过实现BatchConfigurer来定制核心组件：

• 自定义BatchConfigurer，显式指定元数据数据源、事务管理器等核心组件：

  @Configuration
  @EnableBatchProcessing
  public class CustomBatchConfigurer implements BatchConfigurer {
      private final DataSource batchMetadataDataSource;
  
      // 通过@Qualifier注入元数据数据源
      public CustomBatchConfigurer(@Qualifier("batchMetadataDataSource") DataSource batchMetadataDataSource) {
          this.batchMetadataDataSource = batchMetadataDataSource;
      }
  
      @Override
      public JobRepository getJobRepository() throws Exception {
          JobRepositoryFactoryBean factoryBean = new JobRepositoryFactoryBean();
          factoryBean.setDataSource(batchMetadataDataSource);
          factoryBean.setTransactionManager(getTransactionManager());
          factoryBean.setDatabaseType("MYSQL");
          return factoryBean.getObject();
      }
  
      @Override
      public PlatformTransactionManager getTransactionManager() {
          return new DataSourceTransactionManager(batchMetadataDataSource);
      }
  
      @Override
      public JobLauncher getJobLauncher() throws Exception {
          SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
          jobLauncher.setJobRepository(getJobRepository());
          jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
          return jobLauncher;
      }
  
      @Override
      public JobExplorer getJobExplorer() throws Exception {
          JobExplorerFactoryBean factoryBean = new JobExplorerFactoryBean();
          factoryBean.setDataSource(batchMetadataDataSource);
          return factoryBean.getObject();
      }
  }
  

• 业务代码中需要使用业务数据源时，通过@Qualifier("businessDataSource")注入即可，Batch核心组件会自动使用元数据数据源。

3. 该版本的双数据源最佳实践与之前版本差异是否较大？ #

整体差异不算巨大，但核心配置逻辑有明显优化：

• Spring Batch 4及更早版本：@EnableBatchProcessing会自动注册默认核心组件，默认绑定@Primary数据源。实现双数据源需要覆盖默认BatchConfigurer，或通过@EnableBatchProcessing(dataSourceRef = "...")指定元数据数据源，依赖隐式规则容易出现配置冲突。
• Spring Batch 5：
  • 不再强制依赖@Primary数据源，推荐显式实现BatchConfigurer来绑定元数据专用数据源，彻底分离业务与Batch元数据的数据源配置，降低冲突概率。
  • @EnableBatchProcessing默认行为更轻量化，不会自动创建冗余Bean，配置灵活性更高。
  • 最佳实践更强调显式区分数据源职责，不再依赖隐式注入规则，配置逻辑更清晰可控。

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