1

私の要件: バッチを定期的に呼び出すスケジューラを作成し、バッチ内で 2 つの手順が必要です。StepA が実行を開始し、結果に応じて StepB が呼び出されます。コンソール ログを見ると、stepA が数回、たとえばまったく同じタイミングで呼び出されていることがわかります。@Scheduled(fixedRate=60000) によると、1 分ごとに 1 つの呼び出しだけが必要です。スケジューリングを削除し、同様の問題に直面したため、この問題は Scheduller とは関係がないと思います。その他の関連する問題は、StepB が呼び出されないことです。customDecider ("...next(customDecider()") を作成し、JobExecutionDecider を返すプライベート メソッドを作成しようとしました。どちらもまったく効果がないようです。プール スレッドが原因であると推測されます。私がしなかったので、StepAのいくつかの「無限ループ」

BatchConfig.java

   /*@Bean
   public JobExecutionDecider customDecider() throws Exception{
          return new CustomDecider();
   }*/

   private JobExecutionDecider decider(boolean decision){
          return(jobExecution, stepExecution) -> new FlowExecutionStatus(decision ? "OK" : "FAILED");
   }


   @Bean
   public Job job(Step stepA, Step stepB) {
          return jobBuilderFactory.get("job1")
                       //.flow(stepA).on("FAILED").to(stepB).end().build();
                        .start(stepA)
                        .next(decider(true))
                        .on("FAILED")
                        .stop()
                        .from(stepA)
                        .next(stepB)
                        .build()
                        .build();

   }

   @Bean
   public Step stepA(ItemReader<String> readerA, ItemWriter<String> writerA) {
          return stepBuilderFactory.get("stepA").<String, String> chunk(1)
                       .reader(readerA)
                       .writer(writerA)
                       .allowStartIfComplete(true)
                       .build();

   }

   @Bean
   @StepScope
   public ItemReader<String> readerA() {
          return new CustomItemReaderA();

   }

   @Bean
   public ItemWriter<String> writerA() {
          return new CustomItemWriterA();

   }

   @Bean
   public Step stepB(ItemReader<String> readerB, ItemWriter<String> writerB) {
          return stepBuilderFactory.get("stepB").<String, String> chunk(1)
                       .reader(readerB)
                       .writer(writerB)
                       .allowStartIfComplete(true)
                       .build();

   }

   @Bean
   @StepScope
   public ItemReader<String> readerB() {
          return new CustomItemReaderB();

   }

   @Bean
   public ItemWriter<String> writerB() {
          return new CustomItemWriterB();

   }

CustomDecider.java

public class CustomDecider implements JobExecutionDecider  {


       @Override
       public FlowExecutionStatus decide(JobExecution jobExecution,
                     StepExecution stepExecution) {
              return new FlowExecutionStatus("OK");
       }

}

CustomItemReaderA 

public class CustomItemReaderA  implements ItemReader<String>{

       private static final Logger log = LoggerFactory.getLogger(CustomItemReaderA.class);
       @Override
       public String read() throws Exception, UnexpectedInputException,
                     ParseException, NonTransientResourceException {
              log.info("rA");
              return "A";
       }

}

CustomItemWriterA 
public class CustomItemWriterA  implements ItemWriter<String>  {

       private static final Logger log = LoggerFactory.getLogger(CustomItemWriterA.class);
       @Override
       public void write(List<? extends String> items) throws Exception {
              log.info("wA");

       }

}

CustomItemReaderB と CustomItemReaderB は Custom...A と同じで、log.info と return の間に A から B の文字に変わるだけです

コンソール ログ

2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.488  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.504  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemReaderA            : rA
2016-01-18 21:40:37.519  INFO 7340 --- [pool-2-thread-1] com.example.CustomItemWriterA            : wA
and so on ...

スケジューラー

@Component
public class QueueScheduler {

       private static final Logger log = LoggerFactory
                     .getLogger(QueueScheduler.class);

    private Job job;
    private JobLauncher jobLauncher;

    @Autowired
    public QueueScheduler(JobLauncher jobLauncher, @Qualifier("job") Job job){
        this.job = job;
        this.jobLauncher = jobLauncher;
   }



   @Scheduled(fixedRate=60000)
   public void runJob(){
          try{
       jobLauncher.run(job, new JobParameters());
          }catch(Exception ex){
                 log.info(ex.getMessage());
          }
   }
}
4

1 に答える 1

2

問題はあなたにありますCustomItemReaderA。データの「読み取り」をいつ停止するかをリーダーに伝える必要があります。以下のようにリーダーを変更すると、期待どおりに実行されます。

public class CustomItemReaderA implements ItemReader<String> {
    private static final Logger log = LoggerFactory
            .getLogger(CustomItemReaderA.class);
    private int readCount = 0;

    @Override
    public String read() throws Exception, UnexpectedInputException,
            ParseException, NonTransientResourceException {
        log.info("Inside CustomItemReaderA");
        if (readCount == 1) {
            return null;
        }
        readCount++;
        return "Read CustomItemReaderA";
    }
}
于 2016-01-19T06:52:37.573 に答える