Spring Batch - 개념, 구성요소

Spring Batch

Definition

유저 상호작용이 덜한 대용량 데이터 처리를 위한 경량, 포괄적인 배치 프레임워크

Pros

• 주기적인 배치 커밋
• 잡의 병렬적인 수행

Cons

• 역할을 분리함으로써 관심사의 분리도 이루어진다.

Archtiecture Layer

Application

• 직접 작성하는 비즈니스 로직 부분
• Job 구성
• Job, Step, Reader, Processor, Writer, Listener

Batch Core

• Job, Step 실행 제어 (JobLauncher, JobRepository 등)
• Chunk, Step, Flow 등 배치 실행 구조 정의

Batch Infrastructure

• 데이터 저장과 관리, 트랜잭션 처리 담당
• TransactionManager (트랜잭션 관리)
• JobRepository 테이블 (배치 메타데이터 저장용 테이블)

Domain

Job

인스턴스를 위한 컨테이너

• 이름 : Job을 식별하는 이름
• 스탭(Step) : Job을 구성하는 단계들 (데이터 읽기, 처리, 저장 등)
• 재시작 가능 여부 : 실패 시 재시작할 수 있는지 여부 설정

JobInstance

Job과 JobInstance는 마치 클래스와 인스턴스의 관계와 유사하다.

• Job: 실행 구조와 흐름을 정의한 ‘설계도’ 역할
• JobInstance: 실제로 실행되며, 각 실행마다 서로 다른 JobParameters(파라미터)를 가질 수 있다.
  • 동일한 Job이라도, JobParameter 값이 다르면 서로 다른 JobInstance로 구분된다.

예시

예를 들어, 같은 Job이라도

• JobParameter가 “2025-02-20”일 때 생성된 JobInstance와
• JobParameter가 “2025-02-21”일 때 생성된 JobInstance는

서로 다른 인스턴스로 취급된다.

이처럼 JobInstance는 Job + JobParameters로 구성되며,
같은 Job에서 실행돼도, JobParameters가 다르면 다른 실행으로 인식한다.

JobExecution

job를 실행하기 위한 하나의 접근 시도를 의미한다.

만약 execution이 실패한다면 jobinstance의 완료가 보장되지 않는다.

Step

job을 독립적이고 순차적인 단계로 구성할 수 있도록 단계

Job : Step = 1 : N 의 관계를 갖는다.

StepExecution

step을 수행하기 위한 하나의 시도. jobExecution과 유사

ItemReader

step 내에서 입력을 회수하기 위한 추상 클래스

만약 더이상 읽어들일 input이 없다면, null을 반환하도록 한다.

public interface ItemReader<T> {
    T read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException;
}

ItemWriter

step에서 출력을 추상화한 클래스

하나의 배치, 혹은 청크를 단위로 가진다.

public interface ItemWriter<T> {
    void write(Chunk<? extends T> items) throws Exception;
}

Processor

read-write 사이 단계에서 item들을 가공하는 역할

만약 write하고 싶은 데이터가 아니라면, null을 반환하도록 하는 방식으로 저장할 데이터를 스킵한다.

---

Reference

Spring.io Reference