从控制器运行弹簧批处理作业答案

【问题标题】：run spring batch job from the controller从控制器运行弹簧批处理作业
【发布时间】：2015-04-18 10:25:47
【问题描述】：

我正在尝试从控制器运行我的批处理作业。它将由 cron 作业或通过访问特定链接来启动。我使用的是 Spring Boot，没有 XML 只是注释。

在我当前的设置中，我有一个包含以下 bean 的服务：

@EnableBatchProcessing
@PersistenceContext
public class batchService {

    @Bean
    public ItemReader<Somemodel> reader() {
        ...
    }

    @Bean
    public ItemProcessor<Somemodel, Somemodel> processor() {
        return new SomemodelProcessor();
    }

    @Bean
    public ItemWriter writer() {
        return new CustomItemWriter();
    }

    @Bean
    public Job importUserJob(JobBuilderFactory jobs, Step step1) {
        return jobs.get("importUserJob")
                .incrementer(new RunIdIncrementer())
                .flow(step1)
                .end()
                .build();
    }

    @Bean
    public Step step1(StepBuilderFactory stepBuilderFactory,       
            ItemReader<somemodel> reader,
            ItemWriter<somemodel> writer,
            ItemProcessor<somemodel, somemodel> processor) {

        return stepBuilderFactory.get("step1")
                .<somemodel, somemodel> chunk(100)
                .reader(reader)
                .processor(processor)
                .writer(writer)
                .build();
    }   
}

只要我将@Configuration 注释放在我的batchService 类的顶部，作业就会在我运行应用程序后立即开始。它成功地完成了，一切都很好。现在我正在尝试删除 @Configuration 注释并在需要时运行它。有没有办法从控制器触发它？

谢谢！

【问题讨论】：

这是一个关于同一主题的不错的教程 - javainuse.com/spring/bootbatch

标签： spring spring-mvc spring-boot spring-batch

【解决方案1】：

你需要在 src/main/resources 中创建一个 application.yml 文件并添加如下配置：

spring.batch.job.enabled: false

通过此更改，批处理作业将不会随着 Spring Boot 的启动而自动执行。特定链接时会触发批处理作业。

在此处查看我的示例代码： https://github.com/pauldeng/aws-elastic-beanstalk-worker-spring-boot-spring-batch-template

【讨论】：

或@SpringBootApplication(exclude = {BatchAutoConfiguration.class})

【解决方案2】：

您可以使用JobLauncher 以编程方式启动批处理作业，它可以注入您的控制器。有关更多详细信息，请参阅Spring Batch documentation，包括此示例控制器：

@Controller
public class JobLauncherController {

    @Autowired
    JobLauncher jobLauncher;

    @Autowired
    Job job;

    @RequestMapping("/jobLauncher.html")
    public void handle() throws Exception{
        jobLauncher.run(job, new JobParameters());
    }
}

【讨论】：

我以前见过 JobLauncher，但我不知道如何设置它以便它知道要运行的工作（在我的情况下 importUserJob 需要 2 个参数）。我是否必须创建 CustomJobLauncher bean，将其设置在那里，然后注入我的 CustomJobLauncher？目前，在按照您的建议注入 JobLauncher 之后，我得到 No qualifying bean of type [org.springframework.batch.core.launch.JobLauncher] found for dependency
只要你有一个用@EnableBatchProcessing注释的@Configuration类，就应该自动创建一个JobLauncher bean

【解决方案3】：

由于您使用的是 Spring Boot，因此您应该将 @Configuration 注释保留在其中，并将您的 application.properties 配置为在启动时不启动作业。您可以在此处的 Spring Boot 文档中阅读有关在启动时（或不启动）运行作业的自动配置选项的更多信息：http://docs.spring.io/spring-boot/docs/current-SNAPSHOT/reference/htmlsingle/#howto-execute-spring-batch-jobs-on-startup

【讨论】：