Spring 4 일정 잡기 실행시 반복적 인 일괄 처리 서비스

Question

나는이 문제를 며칠간 풀려고했으나 만들 수 없었다. 저는 Spring 4에서 새로운 것이므로 경험이있는 사람이 저에게 어떻게하는지 알려줄 수 있습니다.

프레임 워크의 최신 버전으로 스프링 배치를 코딩하는 방법을 배우려고했습니다. 시작 튜토리얼을 따랐습니다. https://spring.io/guides/gs/batch-processing/

작업이 실행되면 주기적으로 실행하고 싶습니다. 따라서 예약 된 작업에갔습니다. https://spring.io/guides/gs/scheduling-tasks/

두 아이디어를 모두 정리하는 것이 쉬워 보입니다. 실제로는 불가능했습니다. 조금씩 읽었고 매번 jobExecution을 고유하게 만들기위한 코드를 추가했습니다. 여전히 코드 단계는 일단 완료되면 다시 실행되지 않습니다.

조금만 조사해 보았습니다. RepeatTemplate에 대해 읽었지 만 코드에 맞게 만드는 방법이 명확하지 않습니다. 여기에는 실행을위한 3 가지 관련 방법이 있습니다.

@Scheduled(cron="0 0/2 * * * ?") 
public void run() throws Exception { 
    System.out.println("Job Started at :" + new Date()); 

    JobParameters param = new JobParametersBuilder().addString("newsSyncJob", 
      String.valueOf(System.currentTimeMillis())).toJobParameters(); 

    NewsJobCompletionListener listener = new NewsJobCompletionListener(); 
    JobExecution execution = jobLauncher.run(newsSyncJob(listener), param); 

    System.out.println("Job finished with status :" + execution.getStatus()); 
} 


/** 
* Execution of the job 
* @param listener 
* @return 
*/ 
@Bean 
public Job newsSyncJob(NewsJobCompletionListener listener) { 
    log.debug("newsSyncJob execution started"); 
    this.init(); 
    return jobBuilderFactory.get("newsSyncJob") 
      .incrementer(new RunIdIncrementer()) 
      .listener(listener) 
      .flow(step1()) 
      .end() 
      .build(); 
} 

@Bean 
protected Step step1() { 
    return stepBuilderFactory.get("step1") 
      .<NewsSync, NewsSync> chunk(4) 
      .reader(filesReader()). 
      processor(newsProcessor()). 
      writer(stateWriter()). 
      build(); 
} 

모든 단계를 성공적으로 단계를 다시 실행하는 방법은 무엇입니까? 미리 감사드립니다.

Answer 1

M.Deinum의 의견을 듣고 조금 더 조사를했고 나 스스로 해결할 수있었습니다. 다음은 단계별 설명입니다.

newsSyncJob()은 번만 을 실행해야하기 때문에 구성이 잘못되었습니다. 작업을 빌드하고 bean은 싱글 톤으로 작성한 상태로 유지합니다. 원하는만큼 여러 번 실행할 수있는 싱글 톤. 단계 빈과 동일합니다. step1()은 싱글 톤 빈을 생성하기 위해 한 번만 호출됩니다. 작업의 일부로 작업이 실행될 때 실행될 수 있습니다 ... 까지까지 올바르게 구성되었습니다. 지금은 두 가지 방법은 다음과 같이 :

이제

@Bean 
public Job newsSyncJob() { 
    log.debug("Building batch newsSyncJob..."); 
    this.init(); 
    return jobBuilderFactory.get("newsSyncJob") 
      .incrementer(new RunIdIncrementer()) 
      .start(step1()) 
      .build(); 
} 

@Bean 
protected Step step1() { 
    return stepBuilderFactory.get("step1") 
      .<NewsSync, NewsSync> chunk(4) 
      .reader(filesReader()). 
      processor(newsProcessor()). 
      writer(stateWriter()). 
      build(); 
} 

, 이 단계는 우리가 작업를 실행할 때마다 실행하기 위해, 그 범위가 변경 될 필요가있다. 이 단계는 itemReader + itemProcessor + itemWriter으로 구성됩니다. 기본적으로 범위는 프로토 타입입니다. 이는 이전 실행 상태를 유지하고 다시 실행되지 않음을 의미합니다. 다시 실행하려면 범위를 단계 범위로 변경해야합니다. 코드는 다음과 같이 표시됩니다

@Bean 
@StepScope 
ItemReader<NewsSync> filesReader() { 
    return new NewsSyncReader(srcPath); 
} 

@Bean 
@StepScope 
ItemProcessor<NewsSync, NewsSync> newsProcessor() { 
    return new NewsSyncProcessor(jdbcTemplate, newsRepository); 
} 

@Bean 
@StepScope 
ItemWriter<NewsSync> stateWriter() { 
    return new NewsSyncWriter(jdbcTemplate); 
} 

이제 마무리로, 예약 된 호출은 이전 클래스에서 만든 콩의 의존성 주입을 사용하여 다른 클래스로 구성됩니다. 이런 식으로 :

@EnableScheduling 
@Service 
public class BatchScheduled { 

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

    @Autowired 
    private JobLauncher jobLauncher; 

    @Autowired 
    @Qualifier("newsSyncJob") 
    private Job newsJobSync; 

    /** 
    * Scheduled run of the batch 
    * @throws Exception 
    */ 
    @Scheduled(cron="0 0/2 * * * ?") 
    public void run() throws Exception { 
     log.info("newsJobSync started"); 
     System.out.println("Job Started at :" + new Date()); 

     JobParameters param = new JobParametersBuilder().addString("newsSyncJob", 
       String.valueOf(System.currentTimeMillis())).toJobParameters(); 

     JobExecution execution = jobLauncher.run(newsJobSync, param); 

     log.info("newsJobSync finished with status " + execution.getExitStatus()); 
    } 
} 

마지막으로 예약 된 표현식으로 실행되는 스프링 배치가 있습니다.