배치의 도메인 용어

• Job

  • 하나의 배치 작업 단위
  • 여러 step 이 존재하고, step 안에 tasklet, reader & processor & writer 묶음이 존재함

  

• Step

  • 배치 비즈니스 로직을 처리하는 기능을 구현하는 곳
  • 배치로 실제 처리하고자 하는 기능과 설정을 모두 포함한다. → Job 내부에서 step 간의 순서 흐름 처리를 제어할 필요가 있다!

• Item

  • 작업에 사용하는 데이터 (= db 의 한 row 에 해당)
  • ItemReader : Step 에 한 항목씩 검색한다. (모든 항목이 소진된 경우 null 반환)
  • ItemProcessor : 비즈니스 처리를 담당. (유효하지 않은 항목으로 판단될 경우 null 반환)
  • ItemWriter : 여러 출력 항목을 나타낸다. → ItemReader/ItemProcessor 와 같이 널을 자동으로 반환해주기 때문에 Optional 로 한번 더 감싸는 동작은 하지 않아도 된다!

Basic Batch Test

@Slf4j
@Configuration
@RequiredArgsConstructor
@EnableBatchProcessing
public class BatchConfig {

	@Bean
	public Job simpleJob(JobRepository jobRepository, Step simpleStep1) {
		return new JobBuilder("simpleJob", jobRepository)
			.start(simpleStep1)
			// .incrementer(new RunIdIncrementer())
			.build();
	}

	@Bean
	public Step simpleStep1(JobRepository jobRepository,
		Tasklet myTasklet,
		PlatformTransactionManager transactionManager
	) {
		return new StepBuilder("simpleStep1", jobRepository)
			.tasklet(myTasklet, transactionManager)
			.build();
	}

	@Bean
	public Tasklet myTasklet() {
		return (contribution, chunkContext) -> {
			log.info(">>>>> This is myTasklet running");
			return RepeatStatus.FINISHED;
		};
	}

}

구현 시 필요한/사용되는 툴

JobRepository

• Job, Step 구현을 위한 CRUD 작업을 제공

JobLauncher

• Job 을 시작하기 위한 간단한 인터페이스
• 구현시 JobRepository 에서 유효한 JobExecution 을 획득하고 Job 을 실행한다. → Spring Batch 사용 시 제공받음
• 배치를 위한 메타 데이터를 자동으로 제공함 (관련 테이블이 6개 정도 생성됨) → 비즈니스 로직에 좀 더 집중할 수 있게 도와줌