Spring Batch (Java-конфигурации) шаг выполнения после jobExeuctionDecider

Question

Я пытаюсь настроить поток в весеннем пакете с использованием Java-конфигурации, этот поток в основном должен сделать это:

1. Выполнение инициализации шаг (который добавляет запись в базу данных),

2. затем выполнить решающий проверить существование файла,

2.1. Если файлы существуют, он выполнит задание на загрузку (это другой поток с параллельной связкой шагов)

3. Выполнение этапа завершения (который добавляет запись в базу данных), это должно всегда выполняться, даже если 2.1 не был выполнен.

Я попытался сделать эту конфигурацию, но шаг отделки никогда не работает:

 Flow flow = new FlowBuilder<SimpleFlow>("commonFlow") 
      .start(stepBuilderFactory.get("initStep").tasklet(initTasklet).build()) 
      .next(decider) 
       .on(FlowExecutionStatus.COMPLETED.getName()) 
        .to(splitFlow) 
       .from(decider).on("*") 
        .end() 
    .next(stepBuilderFactory.get("finishStep").tasklet(finishTasklet).build()) 
      .end(); 

Я могу заставить его работать делать, как показано ниже, но это не так элегантно всего:

Step finishStep = stepBuilderFactory.get("finishStep").tasklet(finishTasklet).build(); 

    Flow flow = new FlowBuilder<SimpleFlow>("commonFlow") 
      .start(stepBuilderFactory.get("initStep").tasklet(initTasklet).build()) 
      .next(decider) 
       .on(FlowExecutionStatus.COMPLETED.getName()) 
        .to(splitFlow) 
        .next(finishStep) 
       .from(decider).on("*") 
        .to(finishStep) 
      .end(); 

Кто-нибудь знает, как правильно выполнить шаг после принятия решения с помощью java-config?

Answer 1

Похоже, что это делается намного сложнее, чем должно быть. Вам не нужно настраивать поток или принимать решения. Это ОЧЕНЬ простая работа и работа.

Простейший вариант - использовать Spring Integration для обнаружения подарков файла и запуска задания.

Следующим простейшим вариантом является только проверка работы кварца или CRON для файла и запуск пакетного задания.

И последнее, но не менее важное: вы можете запустить задание, и если ItemReader не сможет найти файл (ы), просто проглотите исключение. Или установите прослушиватель FileItemReader для проверки файлов на нем перед методом.