스프링 배치 3.0 이상 버전을 이용하므로 @EnableBatchProcessing이 필요하지 않다

기본 배치 어플리케이션

지난번에 만든 스프링배치 프로젝트 활용

lombok 설정

과정

• Tasklet 구현체 생성
• @Configuration 을 통해서 생성할 Batch Bean을 스프링에 등록한다.
• Job, Step을 생성하고 빈에 등록
• 실행 결과 확인

Tasklet 구현체 생성

Tasklet → Step 내에서 구성되고 실행되는 도메인 객체, 단일 task를 수행하기 위해 사용된다.

import lombok.extern.slf4j.Slf4j;
import org.springframework.batch.core.StepContribution;
import org.springframework.batch.core.scope.context.ChunkContext;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.beans.factory.InitializingBean;

@Slf4j
public class GreetingTasklet implements Tasklet, InitializingBean {

    @Override
    public RepeatStatus execute(StepContribution contribution,
                                ChunkContext chunkContext) throws Exception{
        log.info("======================Taks Execute======================");
        log.info("GreetingTask: {}, {}", contribution, chunkContext);
        
        return RepeatStatus.FINISHED;
    }
    
    @Override
    public void afterPropertiesSet() throws Exception{
        log.info("====================== After Properties Sets()=====================");
    }
}

• Tasklet, InitializingBean 인터페이스 구현
• Tasklet → execute()
  • StepContribution , ChunkContext 를 파라미터로 받음
  • RepeatStatus 를 반환한다.
    • FINISHED : tasklet 종료
    • CONTINUABLE : 계속 태스크 수행
    • continueIf(condition) : 조건에 따라 종료/지속 결정
• InitializingBean → afterPropertiesSet()
  • Task를 수행 시 프로퍼티를 설정하고 난 뒤에 수행되는 메서드.
  • 없어도 됨

@Configuration 을 통해서 생성할 배치 빈을 스프링에 등록하기

@Slf4j
@Configuration
public class BasicTaskJobConfiguration {
    
}