Répéter l'Étape x fois dans Spring Batch

Je suis à l'aide de Spring Batch 3.0.3 configuré avec l'annotation pour créer un lot de travail qui se répète d'une étape d'un nombre indéterminé de fois.

Ma première étape sera lu en mémoire une liste des éléments utilisés lors de la répétition de l'étape. Je voudrais répéter les étapes pour effectuer une itération à travers ce travail d'étendue de liste.

Comment puis-je configurer mon travail à exécuter la même opération x fois? J'ai vu des exemples en xml d'une étape de spécification de l'étape suivante à exécuter. Je suis en train de penser que je pouvais le point deux pas les uns des autres dans une boucle infinie jusqu'à ce que la liste a été réitéré. Serait-il et est-il un moyen de le faire avec des annotations? Ci-dessous mon fichier de configuration principal avec un code qui ne fonctionnait pas.

@ComponentScan(excludeFilters = @Filter(IgnoreDuringScan.class))
@EnableAutoConfiguration
@EnableBatchProcessing
@Loggable
public class BatchCrudConfiguration
{
    @Bean
    public Job batchCRUDJob(JobBuilderFactory jobBuilderFactory, Step[] processSheetSteps)
    {
        JobBuilder jobBuilder = jobBuilderFactory.get("batchCRUDJob").incrementer(new RunIdIncrementer());
        FlowBuilder<FlowJobBuilder> jobFlowBuilder = jobBuilder.flow(processSheetSteps[0]);
        for (int i = 1; i < processSheetSteps.length; i++)
        {
            jobFlowBuilder = jobFlowBuilder.next(processSheetSteps[i]);
        }
        return jobFlowBuilder.end().build();
    }

    @Bean
    public Step[] processSheetSteps(
            StepBuilderFactory stepBuilderFactory,
            RawDataReader[] readers,
            DelegatingWriter writer,
            DelegatingProcessor processor,
            @Value("${batchcrud.chunkSize}") int chunkSize)
    {
        int numberOfReaders = readers.length;
        Step[] steps = new Step[numberOfReaders];
        for (int i = 0; i < numberOfReaders; i++)
        {
            steps[i] = stepBuilderFactory.get("processSheet" + i + "Step").<RawData, DataItem>
                    chunk(chunkSize).reader(readers[i]).processor(processor).writer(writer).build();
        }
        return steps;
    }
Si vous incluez votre configuration, nous pouvons fournir plus de réponse concrète.
Vous ne serait pas arriver à être le Michael Minella qui a écrit le livre Spring Batch je lisais la nuit dernière? J'ai ajouté un peu de code.
Si le livre que vous êtes en train de lire est Pro Spring Batch...je suis.
Donc, il n'y a pas assez de code pour moi d'obtenir une compréhension complète de ce que vous essayez de faire. Mais, à partir d'un niveau élevé, si vous voulez répéter une étape, alors vous devriez être capable de l'écrire comme une boucle. Créer l'étape 1 pour charger votre liste. Étape 2 les processus d'un élément dans la liste. L'étape 2 a un auditeur qui détermine s'il y a plus d'éléments à traiter dans la liste. Si oui, puis il renvoie le code de sortie qui correspond à revenir à la même étape. Si non, puis il renvoie le code de sortie pour continuer dans le flux (ou à la fin du travail).
Merci pour la réponse. Comment pourrais-je le code de l'étape 2 de répéter lui-même, sans l'aide de xml? Serait l'auditeur être de classe JobExecutionDecider? Renvoyer un tableau des étapes de mon beau bean ne semble pas fonctionner.

OriginalL'auteur Chris Oppedal | 2015-03-26

  1. 8

    La façon dont j'avais cette approche est le suivant:

    1. Première étape des charges de la liste.
    2. Deuxième étape du processus d'un élément dans la liste.
    3. La deuxième étape a une StepExecutionListener qui évalue s'il y a plus d'éléments dans la liste de processus. Si oui, il renvoie un ExitStatus qui correspond à la même étape. Sinon, elle retourne un ExitStatus que les cartes à la fin de l'emploi ou de continuer le travail (basée sur le reste de l'écoulement).

    Par exemple:

    StepExecutionListener 

    public class MyListener {

    @Autowired
    private List myItems;

    @AfterStep
    public ExitStatus afterStep(StepExecution stepExecution) {
        if(myItems.size() > 0) {
            return new ExitStatus("CONTINUE");
        }
        else {
            return new ExitStatus("FINISHED");
        }
    }
}

    De Configuration De Travail

    ...
@Bean
public Step step1() {...}

@Bean
public MyListener listener() {..}

@Bean
public Step step2(MyListener listener) {
    return stepBuilder.get("step2")
                .tasklet(myTasklet()) //Replace this piece as needed
                .listener(listener).build();
}

@Bean
public Job job1(Step step1, Step step2) {
    return jobBuilder.get("job1")
                     .start(step1)
                     .next(step2).on("CONTINUE").to(step2).on("FINISHED").end()
                     .build();
}
...

    Remarque je n'ai pas testé ce code, donc il peut y avoir des fautes de frappe, etc.

    Je vous remercie. Cela fonctionne parfaitement si vous ajoutez un autre appel à la fin() dans le Travail de haricot.
    Donc, si je veux continuer de step1, puis-je appeler ce .next(step2).on("CONTINUE").to(step1).on("FINISHED").end()?
    comment faire de multiples step2 exécution en parallèle au lieu de sequencially dans ce cas, j'ai la liste des éléments dans la liste qui peuvent être exécutées en parallèle
    J'ai essayé et pour obtenir "org.springframework.lot.de base.travail.SimpleStepHandler - Dupliquer l'étape [etape 2] détecté dans l'exécution de job=[pouvant]. Si l'étape échoue, les deux seront exécutés de nouveau sur redémarrer." dans le journal. Avez-vous aussi ce problème? Est-il un moyen de le réparer?
    Moi aussi, je suis à la recherche de moyens pour s'exécuter en parallèle.

    OriginalL'auteur Michael Minella