如何在Spring批处理中动态定义多个作业？

Question

@Configuration
@EnableBatchProcessing
public class DynamicJobConfigurer extends DefaultBatchConfigurer implements InitializingBean {

    @Autowired
    private JobBuilderFactory jobBuilderFactory;
    @Autowired
    private JobRegistry jobRegistry;
    @Autowired
    private DataSource dataSource;
    @Autowired
    private CustomJobDefinitionService customJobDefinitionService;

    private Flow injectedFlow1;
    private Flow injectedFlow2;

    public void setupJobs() throws DuplicateJobException {

        List<JobDefinition> jobDefinitions = customJobDefinitionService.getAllJobDefinitions();

        for (JobDefinition jobDefinition : jobDefinitions) {

            Job job = null;
            if (jobDefinition.getType() == 1) {
                job = jobBuilderFactory.get(jobDefinition.getName())
                        .start(injectedFlow1).build()
                        .build();
            } else if (jobDefinition.getType() == 2) {
                job = jobBuilderFactory.get(jobDefinition.getName())
                        .start(injectedFlow2).build()
                        .build();
            }

            if (job != null) {
                jobRegistry.register(new ReferenceJobFactory(job));
            }
        }
    }

    @Override
    public void afterPropertiesSet() throws Exception {
        setupJobs();
    }

    public void setInjectedFlow1(Flow injectedFlow1) {
        this.injectedFlow1 = injectedFlow1;
    }

    public void setInjectedFlow2(Flow injectedFlow2) {
        this.injectedFlow2 = injectedFlow2;
    }
}

我在XML中定义了注入的流，如下所示：

<batch:flow id="injectedFlow1">

    <batch:step id="InjectedFlow1.Step1" next="InjectedFlow1.Step2">
        <batch:flow parent="InjectedFlow.Step1" />
    </batch:step>

    <batch:step id="InjectedFlow1.Step2">
        <batch:flow parent="InjectedFlow.Step2" />
    </batch:step>

</batch:flow>

因此，正如您所看到的，我实际上是从InitializingBean的afterPropertiesSet()方法启动setupJobs()方法（用于动态创建这些作业定义）。我不确定这是对的。它正在运行，但我不确定是否有一个不同的入口点更适合于这个目的。老实说，我也不知道@configuration注释的意义是什么。

当前遇到的问题是，当我从JobRegistry调用Register()时，它会引发以下IllegalStateException:

若要使用默认的BatchConfigurer，上下文必须包含一个以上的数据源（found 2）。

注意：我的项目实际上定义了两个数据源。第一个是默认的dataSource bean，它连接到Spring批处理使用的数据库。第二个数据源是一个外部数据库，这第二个包含我定义作业列表所需的所有信息。但是主要的一个确实使用了默认名称“DataSource”，所以我不太确定我还可以如何告诉它使用这个名称。

Answer 1

首先，我不推荐使用XML和Java配置的组合。只使用一个，最好是Java一个，因为将XML配置转换为Java配置并不费力。（除非你有一些很好的理由去做--你没有解释）

我并没有单独使用Spring Batch，因为我一直将它与Spring Boot一起使用，并且我有一个项目，在该项目中我定义了多个作业，它对于您所展示的类似代码总是很好地工作。

对于您的问题，有一些类似于这样或这样的答案，它们基本上试图说明您需要编写自己的BatchConfigurer，而不是依赖于默认的BatchConfigurer。

使用Spring Boot，您应该尝试分离作业定义和作业执行。您应该首先尝试只定义作业并初始化Spring上下文，而不启用作业(Spring.batch.job.enabled=false)

在Spring Boot main方法中，当您使用-SpringApplication.run(Application.class,args）；...启动应用程序时，您将得到ApplicationContext CTX

现在，您可以从这个上下文中获取相关的bean，通过从属性或命令行等获取名称来启动指定作业&使用joblauncher.run(...)方法。

你可以参考我的这个答案，如果愿意订购的工作执行。您还可以使用Java编写作业调度程序。

重点是，您分离了作业构建/bean配置和作业执行的关注点。

挑战