패스트캠퍼스 챌린지 26일차 - Spring Batch 8

📌 spring-batch 8

✔️ JobExecutionListener

1. 인터페이스로 구현

• implements JobExecutionListner
• 구현 메서드
  • beforeJob(JobExecution)
  • afterJob(JobExecution)

2. 어노테이션 기반 구현

• @BeforeJob
• @AfterJob
• 인터페이스 방식과 동일하게 JobExecution을 파라미터로 받음

 

✔️ 정의한 Job 리스너 등록

jbf.get("testJob")
    .incrementer()
    .start(testStep())
    .listener(listener1.class)
    .listener(listener2.class)
    .build();

 

✔️ StepExecutionListener

1. 어노테이션 기반 구현

• @BeforeStep
• @AfterStep
• 파라미터로 StepExecution을 받는다.

 

✔️ 정의한 Step 리스너 등록

• Job 리스너 등록과 동일 

• sbf.get("testStep")
    ...
    ...
    .listener(listener3.class)
    .build()

 

✔️ Skip
step 수행 중 발생한 Exception에 대한 처리를 수행한다.

ex)

skip(NotFoundNameException.class), skipLimit(3)

• NotFoundNameException 발생 3번까지 skip 한다.
  (설정한 Exception을 n번까지 허용)
• NotFoundNameException 발생 4번부터는 배치작업을 중단한다.
  (해당 Step의 상태는 실패로 끝!)
• 에러 발생 전까지 데이터는 모두 처리된 상태로 남는다.
  (에러 발생전 데이터는 롤백되지 않고 정상처리 됨)

Step은 chunk 1개를 기준으로 트랜잭션이 동작한다.

 

ex) items=100, chunk=10

• 10번째 chunk에서 Exception이 발생한 경우 1-9까지는 정상처리(저장) 후 Job과 Step을 FAILED로 처리한다.
• 배치 재실행시 chunk 10부터 다시 처리할 수 있도록 배치를 만들어야 한다. (실패처리된 Job을 재실행한 경우)

 

✔️ Skip 예제

1. Person.name이 empty인 경우 NotFoundNameException
2. NotFoundNameException 3번 이상 발생한 경우 step 실패처리

지정한 예외발생에 대한 faultTolerant 횟수를 지정한다. (skipLimit)

 

✔️ faultTolerant

StepBuilderFactory().get("testStep")
    .faultTolerant()
    .skip(NotFoundNameException.class)
    .skilLimit(3)
    .build()

 

---

👍  수강인증

 

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

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