[Spring] Spring Batch 5 사용해보기

Spring Batch 5 

• 최소 Java 17 필요 
• @EnableBatchProcessing 어노테이션 권장 X 👉 사용할 시 autoConfiguration 일부 기능 사용 불가 

 

 

Spring Batch 초기 설정

spring:
  profiles:
    active: local
  batch:
    job:
      names: ${job.name:NONE}

---
spring:
  config:
    activate:
      on-profile: local
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/house
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: 
  jpa:
    show-sql: true
    generate-ddl: false
    hibernate:
      ddl-auto: none
  batch:
    jdbc:
      initialize-schema: ALWAYS

batch 관련해서 initialize-schema: ALWAYS로 설정하면 DB schema를 자동으로 생성한다. 

DB schema에는 실행정보와 상태정보 등을 저장해 스프링 배치의 실행 및 관리 목적으로 저장, 업데이트, 조회할 수 있는 기능을 제공한다. 

이 메타 테이블이 필수적으로 생성되어야 한다 !

생성 완료

---

✳️ Job 생성

• 기존 Spring Batch 4에서는 JobBuilderFactory를 사용해서 생성하였지만 Spring Batch 5에서는 deprecated 되었다.

 

• JobBuilder(String name, JobRepository jobRepository) 사용
• incrementer : Job 실행 횟수 일정하게 증가

@Bean("myJob")
public Job helloJob(JobRepository jobRepository, Step helloStep){
    return new JobBuilder("myJob", jobRepository)
            .incrementer(new RunIdIncrementer())
            .start(helloStep)
            .build();
}

 

✳️ Step 생성

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

 

 

✳️ Tasklet 생성

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

 

 

Spring Batch 실행 방식

• Quartz Scheduler
• CI 프로그램 이용 👉 Jenkins
  
  • 마스터에서 슬레이브로 명령을 전달해 배치 프로그램 실행
  • Jenkins에서 지원하는 스케줄링 기능을 통해 실행
• Spring Cloud Data Flow 
  • Kubernetes 클러스터 구축

 

 

 

실행시키기

🔹 인텔리제이로 실행시키기

job 이름을 myJob으로 설정해서 해당하는 job 탐색 후 실행 

 

 

 

🔹 터미널로 실행시키기

java -jar build/libs/spring-batch-0.0.1-SNAPSHOT.jar --job.name=myJob

 

 

 

 

참고자료

https://docs.spring.io/spring-batch/reference/schema-appendix.html

https://docs.spring.io/spring-batch/docs/5.0.4/reference/html/whatsnew.html