[스프링] Spring Batch란? 기본 개념 및 구조

Spring Batch: 기본 개념과 주요 구성 요소

1. Spring Batch란?

Spring Batch는 대량의 데이터를 효율적으로 처리하기 위한 배치 처리 프레임워크입니다. Spring Framework를 기반으로 하며, 데이터 이동, 변환, 및 저장 작업을 처리하는 데 필요한 다양한 도구와 기능을 제공합니다. 반복적인 작업을 자동화하고, 대규모 작업을 안정적으로 수행하기 위해 설계되었습니다.

 

 

 

 

 

2. 배치 처리란?

배치 처리란 다음과 같은 대량 데이터를 한꺼번에 처리하는 프로세스를 말합니다:

• 대량 데이터 읽기
• 데이터 가공 및 처리
• 처리된 데이터 저장

배치 처리는 주로 정기적으로 실행되며, 예를 들어 월말 급여 계산, 거래 데이터 처리, 보고서 생성 등에 사용됩니다.

 

 

 

 

 

 

 

 

3. Spring Batch의 주요 구성 요소

Spring Batch는 다음과 같은 구성 요소를 기반으로 동작합니다:

1) Job

Job은 배치 작업의 최상위 구성 요소로, 하나 이상의 Step으로 구성됩니다. Job은 배치 처리의 실행 단위를 정의합니다.

 

 

 

2) Step

Step은 Job의 하위 구성 요소로, 특정 작업을 수행하는 단위를 정의합니다. Step은 주로 다음 단계로 구성됩니다:

• ItemReader: 데이터를 읽어오는 역할.
• ItemProcessor: 데이터를 가공하거나 변환.
• ItemWriter: 처리된 데이터를 저장.

 

 

 

3) ItemReader

파일, 데이터베이스, 또는 API와 같은 외부 소스로부터 데이터를 읽는 역할을 합니다.

 

 

 

 

4) ItemProcessor

읽어온 데이터를 원하는 형식으로 변환하거나 필터링합니다.

 

 

 

 

5) ItemWriter

처리된 데이터를 데이터베이스, 파일, 또는 다른 외부 시스템에 저장합니다.

 

 

 

 

 

 

4. Spring Batch의 실행 흐름

Spring Batch는 아래와 같은 순서로 실행됩니다:

1. JobLauncher가 Job을 시작.
2. Job이 하나 이상의 Step을 실행.
3. 각 Step은 ItemReader, ItemProcessor, ItemWriter를 호출하여 데이터를 처리.

 

 

 

 

 

 

5. Spring Batch 사용 예제

다음은 간단한 Spring Batch 예제입니다:

1) Configuration

import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@EnableBatchProcessing
public class BatchConfig {

    @Bean
    public Job exampleJob(JobBuilderFactory jobBuilderFactory, Step exampleStep) {
        return jobBuilderFactory.get("exampleJob")
                .start(exampleStep)
                .build();
    }

    @Bean
    public Step exampleStep(StepBuilderFactory stepBuilderFactory, ExampleTasklet tasklet) {
        return stepBuilderFactory.get("exampleStep")
                .tasklet(tasklet)
                .build();
    }
}

 

 

 

 

 

 

2) Tasklet 정의

import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.stereotype.Component;

@Component
public class ExampleTasklet implements Tasklet {
    @Override
    public RepeatStatus execute(org.springframework.batch.core.StepContribution contribution,
                                org.springframework.batch.repeat.ChunkContext chunkContext) throws Exception {
        System.out.println("Tasklet 실행 중...");
        return RepeatStatus.FINISHED;
    }
}

 

 

 

 

 

 

 

6. Spring Batch의 장점

• 확장성: 대량 데이터를 효율적으로 처리 가능.
• 유연성: 다양한 데이터 소스와 연동 가능.
• 에러 핸들링: 실패한 작업을 재시도하거나 중단된 지점부터 다시 실행 가능.
• 모니터링: 실행 상태와 로그를 통해 작업 상태 추적 가능.

 

 

 

 

 

 

 

7. 결론

Spring Batch는 대규모 데이터 처리 작업을 효율적으로 자동화하는 데 적합한 프레임워크입니다. 다양한 구성 요소와 유연한 설정을 통해 복잡한 배치 처리 요구를 충족시킬 수 있습니다. 데이터를 정기적으로 처리하거나 대규모 데이터 작업을 관리해야 하는 애플리케이션에서 필수적인 도구로 활용할 수 있습니다.