패스트캠퍼스 챌린지 20일차 - Spring Batch 2

📌 spring-batch 2

✔️ 스프링 배치 아키텍처

• 스프링 배치는 Job타입의 Bean이 생성되면 JobLauncher에 의해 Job을 실행한다.

  private final JobBuilderFactory jbf;
  
  @Bean
  public Job helloJob() {
  	 return jbf.get("helloJob")
       			...
                  	...
                  .buld();
  }

• 실행된 Job은 Step 타입으로 등록된 Bean을 실행한다.

  private final StepBuilderFactory sbf;
  
  @Bean
  public Step helloStep() {
  	return sbf.get("helloStep")
              ...
              ...
          .build();
  }

 

✔️ Chunk & Task

Chunk

• 하나의 큰 덩어리의 작업을 n개로 나누어 실행한다.

Task

• 하나의 작업으로 실행한다.
• 처리 대상을 한 번에 실행해도 무리가 없는 경우 사용한다.

 

✔️ Chunk 기반 Step

ItemReader -> ItemProcessor -> ItemWriter

 

ItemReader

• 배치 처리 대상을 읽어서 ItemProcessor에게 전달한다.
• 배치 처리 대상 데이터를 파일 또는 DB에 접근하여 읽는다.

ItemProcessor

• ItemReader부터 받은 input에 대해 가공 및 필터링을 거쳐 ItemWriter에게 전달한다.
• ItemProcessor객체는 optional 하다. (해당 작업을 Reader 혹은 Writer에서 처리가능)

ItemWriter

• 배치 대상 객체, 배치 대상 데이터를 처리한다.
• DB update 혹은 이벤트 알림 등을 수행한다.

 

✔️ BATCH_JOB_EXCUTION_PARAM test

return jbf.get("helloJob")
        .incrementer(new RunIdIncrementer()) 
        .start(helloStep())
        .build();

new RunIdIncrementer()와 Job의 이름이 BATCH_JOB_EXCUTION_PARAM에 저장되는 것을 확인

 

✔️ Job 인스턴스의 생성 기준

Job이름과 Job parameters의 값을 기준으로 생성, 재실행, 재실행 실패가 결정된다.

• 하나의 Job은 같은 parameter로 실행할 수 없다.
• .incrementer(new RunIdIncrementer()) 와 같이 시퀀셜한 값을 파라미터로 주면 같은 이름의 Job 인스턴스를 생성 가능하다.

---

👍  수강인증

패스트캠퍼스 [직장인 실무교육]

본 포스팅은 패스트캠퍼스 환급 챌린지 참여를 위해 작성되었습니다.