在Spring批处理中创建迭代流程步骤

问题描述：

我正在做一个流程步骤，需要在不同的时刻重复相同的步骤。直到我们有RepeatStatus.FINISHED，它不会重复同一步骤，但是在其他步骤之后执行上一步。我们已经完成了一个简化的模型来尝试它，但它也不起作用。在Spring批处理中创建迭代流程步骤

Job.xml：

<job id="job1" xmlns="http://www.springframework.org/schema/batch"> 
    <step id="job1Step1" next="decision1"> 
     <tasklet ref="tasklet1" /> 
    </step> 

    <decision id="decision1" decider="decider1"> 
     <next on="1" to="job1Step1"/> 
     <next on="2" to="job1Step2"/> 
     <next on="3" to="job1Step3"/> 
    </decision> 

    <step id="job1Step2" next="decision2"> 
     <tasklet ref="tasklet2" /> 
    </step> 

    <decision id="decision2" decider="decider2"> 
     <next on="1" to="job1Step1"/> 
     <next on="2" to="job1Step2"/> 
     <next on="3" to="job1Step3"/> 
    </decision> 

    <step id="job1Step3" next="job1Step1"> 
     <tasklet ref="tasklet3" /> 
    </step> 
</job>

豆类：

<bean id="decider1" class="Decider1"/> 
<bean id="decider2" class="Decider2"/> 

<bean id="tasklet1" class="Tasklet1"/> 
<bean id="tasklet2" class="Tasklet2"/> 
<bean id="tasklet3" class="Tasklet3"/>

然后，还有Java类的模型：

任务蕾类模型：

public class TaskletN implements Tasklet { 

    protected static Log log = LogFactory.getLog(TaskletN.class); 

    @Override 
    public RepeatStatus execute(StepContribution stepCont, ChunkContext chunkContext) throws Exception { 
     log.info("Passo per TASKLET_N"); 
     return null; 
    } 

}

决胜局类型号：

public class DeciderM implements JobExecutionDecider { 

protected static Log log = LogFactory.getLog(DeciderM.class); 

    public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecution) { 
     String prova = "M+1"; 
     log.info("Estic a DECIDER_M i vaig al STEP: " + prova); 
     return new FlowExecutionStatus(prova); 
    } 

}

而这就是问题所在。第一次没事了，但第二次和其他时候，直接决定是步骤。

Passo per TASKLET_1 
Estic a DECIDER_1 i vaig al STEP: 2 
Passo per TASKLET_2 
Estic a DECIDER_2 i vaig al STEP: 3 
Passo per TASKLET_3 
Estic a DECIDER_1 i vaig al STEP: 2 
Estic a DECIDER_2 i vaig al STEP: 3 
Estic a DECIDER_1 i vaig al STEP: 2 
Estic a DECIDER_2 i vaig al STEP: 3 
Estic a DECIDER_1 i vaig al STEP: 2 
... (bug)

答

有一个在

How to run a step in a loop in Spring Batch : Updated

描述了类似的问题看看我的评论我的回答这个问题下：

这是行不通的。 SpringBatch并不打算在单个作业启动期间多次执行特定步骤。该框架保留了该步骤及其读写器的几个内部状态。您需要在运行时切入实例化的作业结构，并以某种方式重置该步骤以及读者和作者的状态。但是这很丑陋，而且很脏。绝对不是你想做的事情。

在Spring批处理中创建迭代流程步骤

相关推荐