2

我正在编写一个批处理应用程序，当我的应用程序逻辑发现问题并返回时，我想立即设置退出状态。

例如，我在作者的 write 方法中设置以下状态。

stepExecution.getJobExecution().setExitStatus(ExitStatus.FAILED);

尽管执行了上述语句，但在日志中收到以下消息并且退出代码似乎是成功的。

“批量执行成功！”

我可以知道如何正确设置退出代码吗？

有一些方法可以在 step 之后设置。

喜欢：

    @AfterStep
public ExitStatus afterStep(){
    //Test condition
    return new ExistStatus("CUSTOM EXIT STATUS");
}

但我不想坚持退出状态并在上述方法中设置退出状态。

4

3 回答 3

3

您应该正确拦截作业执行-

public void afterJob(JobExecution jobExecution){

    if( jobExecution.getStatus() == BatchStatus.COMPLETED ){

        jobExecution.setExitStatus(new ExitStatus("CUSTOM SUCCESS STATUS"));

    } else if(jobExecution.getStatus() == BatchStatus.FAILED){

       jobExecution.setExitStatus(new ExitStatus("CUSTOM FAILURE STATUS"));

    }

}
于 2013-08-05T17:45:59.360 回答
2

我有一个类似的问题，并在 5 分钟前解决了它。我有多个步骤在做“东西”和一个默认的“失败步骤”，当所有其他步骤抛出异常时会调用它。

引发异常的步骤将在“spring-batch”逻辑中被放弃，但我需要它们失败，以便我可以重新启动它们。因此，在尝试了侦听器并强制状态之后，我终于通过在调用“失败步骤”后更新废弃的步骤来使其工作。

所以我的“失败步骤”看起来像这样：

public class EnleveDossiersRejetesEtMAJSteps implements Tasklet {

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {

    /**some business logic code for my step, AND the code bellow*/

    if (chunkContext.getStepContext() != null && chunkContext.getStepContext().getStepExecution() != null) {
        Long jobExecutionId = chunkContext.getStepContext().getStepExecution().getJobExecutionId();

        batchTablesService.updateJobStepStatuses(jobExecutionId, BatchStatus.ABANDONED, BatchStatus.FAILED);
    }

    /** end the step like expected */
    return RepeatStatus.FINISHED;
    }
}

我的“batchTablesService”是我创建的一个服务类，它链接到一个简单地检索所有步骤的 DAO，然后对于所有“已放弃”的步骤，它将它们更新为“失败”。像这样：

@Override
public void updateJobStepStatuses(Long jobExecutionId, BatchStatus sInitial, BatchStatus sFinal) {
    log.debug("-- call updateJobStepStatuses(" + jobExecutionId + "," + sInitial + "," + sFinal + ")");

    List<BatchStepExecution> steps = getStepExecutions((int) (long) jobExecutionId, null);
    for (BatchStepExecution step : steps) {
        if (!step.getStatus().isEmpty() && step.getStatus().equalsIgnoreCase(sInitial.toString())) {
            step.setStatus(sFinal.toString());
            entityManager.merge(step);
        }
    }
}

祝你好运！

于 2016-02-29T09:20:33.477 回答
0

不需要自定义接口或类。看看这个 -

https://github.com/spring-projects/spring-boot/issues/14075

于 2019-02-13T12:51:29.200 回答