Spring批处理中每个作业的Jobrepository数据源不同？

Question

如果我有两个作业，每个作业都写入不同的数据源，那么在它使用的数据源中写入Spring批处理元数据（jobExecution、结果、...）是有意义的。然而，Spring批处理似乎指示您有一个“主要”数据源用于该元数据。

我定义了两个数据源，都没有标记为主数据源，应用程序无法启动：

Field dataSource in org.springframework.batch.core.configuration.annotation.AbstractBatchConfiguration required a single bean, but 2 were found:
    - firstDataSource: defined by method 'firstDataSource' in class path resource [secret/DataSourceConfig.class]
    - secondDataSource: defined by method 'secondDataSource' in class path resource [secret/DataSourceConfig.class]


Action:

Consider marking one of the beans as @Primary, updating the consumer to accept multiple beans, or using @Qualifier to identify the bean that should be consumed

我尝试创建两个配置，每个配置都扩展DefaultBatchConfigrer：

@Configuration
@EnableBatchProcessing
public class MyJobConfiguration extends DefaultBatchConfigurer {

    @Autowired
    public JobBuilderFactory jobBuilderFactory;

    @Bean
    public Job my_job(@Qualifier("somestep") Step step) {
        return jobBuilderFactory.get("my_job")
                .start(step)
                .build();
    }

    @Bean
    @Profile("my_job")
    public JobExecution launchMyJob(@Qualifier("my_job") Job job, JobLauncher jobLauncher) throws JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException {
        Map<String, JobParameter> params = new HashMap<>();
        params.put("Time", new JobParameter(new SimpleDateFormat("yyyy/MM/dd HH:mm:ss").format(new Date())));
        return jobLauncher.run(job, new JobParameters(params));
    }

    @Override
    @Autowired
    public void setDataSource(@Qualifier("firstDataSource") DataSource dataSource) {
        super.setDataSource(dataSource);
    }
}

另一个完全相同，只是工作和数据源不同。

那么，为什么spring仍然试图创建AbstractBatchConfiguration，而我显然想通过扩展DefaultBatchConfigurer来实现这一点呢？

更多堆栈跟踪：

Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'org.springframework.batch.core.configuration.annotation.SimpleBatchConfiguration': Unsatisfied dependency expressed through field 'dataSource'; nested exception is org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type 'javax.sql.DataSource' available: expected single matching bean but found 2: firstDataSource,secondDataSource
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:587) ~[spring-beans-5.0.5.RELEASE.jar:5.0.5.RELEASE]
    at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:91) ~[spring-beans-5.0.5.RELEASE.jar:5.0.5.RELEASE]

Answer 1

Spring Batch的SimpleBatchConfiguration是通过@EnableBatchProcess引入的。它使用BatchConfigrer来提供它需要添加到Application ationContext中的组件。您真正想要做的是创建一个BatchConfigrer，它在正确的时间提供正确的DataSource。然后SimpleBatchConfiguration将使用您的配置程序创建的组件将它们添加到Application ationContext中。

Answer 2

你是说在你的项目中使用多个数据源吗？

这里有一个例子供你参考

https://github.com/michaelliao/springcloud/tree/master/data-multidatasource