没有重新执行Spring批处理步骤（缓存）

Question

我正在做一个包括Spring批处理的项目，在复制代码片段之前，我要简单地总结一下这项工作是如何使用cron的。

1. cron在我的项目上调用restapi（@PostMapping（“/jobs/external/{jobName}”）
2. 在post方法中，我获取作业并执行它
3. 在每次执行中，我都应该执行一个步骤
4. 该步骤包含一个读卡器（对弹性API的外部rest调用以获取文档）和一个处理器

现在我的问题是：在catalina.out中，我可以按照cron中的配置，每隔10分钟看到cron的其余调用。但是，该步骤似乎并不是每10分钟调用一次弹性，批处理进程总是具有相同的数据集，这些数据集在tomcat重启期间调用批处理时读取一次。

工作Restapi：

@PostMapping("/jobs/external/{jobName}")
@Timed
public ResponseEntity start(@PathVariable String jobName) throws BatchException {
    log.info("LAUNCHING JOB FROM EXTERNAL : {}, timestamp : {}", jobName, Instant.now().toString());
    try {
        Job job = jobRegistry.getJob(jobName);
        JobParametersBuilder builder = new JobParametersBuilder();
        builder.addDate("date", new Date());
        return Optional.of(jobLauncher.run(job, builder.toJobParameters()))
            .map(BatchExecutionVM::new)
            .map(exec -> ResponseEntity
                .ok()
                .headers(HeaderUtil.createAlert("jobManagement.started", jobName))
                .body(exec))
            .orElseGet(() -> ResponseEntity.badRequest().build());
    } catch (NoSuchJobException aEx) {
        log.warn(JOB_NOT_FOUND, aEx);
        throw new BatchException();
    } catch (JobInstanceAlreadyCompleteException | JobExecutionAlreadyRunningException | JobRestartException aEx) {
        log.warn("Job execution error.", aEx);
        throw new BatchException();
    } catch (JobParametersInvalidException aEx) {
        log.warn("Job parameters are invalid.", aEx);
        throw new BatchException();
    }
}

作业配置：

@Bean
public Job usualJob() {
    return jobBuilderFactory
        .get("usualJob")
        .incrementer(new SimpleJobIncrementer())
        .flow(readUsualStep())
        .end()
        .build();
}

@Bean
public Step readUsualStep() {
    // TODO: simplifier on n'a pas besoin de chunk
    return stepBuilderFactory.get("readUsualStep")
        .allowStartIfComplete(true)
        .<AlertDocument, Void>chunk(25)
        .readerIsTransactionalQueue()
        .reader(rowItemReader())
        .processor(rowItemProcessor())
        .build();
}
@Bean
public ItemReader<AlertDocument> rowItemReader() {
    return new UsualItemReader(usualService.getLastAlerts());
}
@Bean
public UsualMapRowProcessor rowItemProcessor() {
    return new UsualMapRowProcessor();
}

我不知道为什么通常只调用ervice.getLastAlerts（）一次，而不是每10分钟调用一次。

Answer 1

多亏了M. Deina，这基本上是解决方案：

    @Bean
@StepScope
public ItemReader<AlertDocument> rowItemReader() {
    return new UsualItemReader(usualService.getLastAlerts());
}

使用stepScope注释对StepBean进行注释将使其重新实例化每个步骤。