[ Spring batch ] Job과 Step

📌 Job이란?

• Job은 배치 처리 과정을 하나의 단위로 만들어 포현한 객체.
• 전체 배치 처리에 있어 항상 최상단 계층에 있습니다.
• 최소 하나의 Step을 가져야 하며 엄청나게 복잡한 Job이 아닌 이상 2-10개의 Step을 권장한다

📌 Step이란?

• Step은 실직적인 배치 처리를 정의하고 제어 하는데 필요한 모든 정보가 있는 도메인 객체.
• job을 구성하는 독립된 작업의 단위.
• tasklet 기반 스텝과 chunk 기반 스텝이 있다.

tasklet

• 스텝이 중지될 때까지 exeute 메서드가 계속 반복하여 수행된다.
• 초기화, 저장, 프로시저 실행, 알림 전송 등과 같은 job에서 사용된다.

chunk

• ItemReader, ItemProcessor, ItemWriter라는 3개의 주요 부분으로 구성된다.
• ItemProcessor가 필수는 아니다.

📌 Job 실행

job을 실행하면 job은 각 step을 실행한다. 각 step이 실행되면 JobRepository는 현재 상태로 갱신된다.
즉 실행된 스텝, 현재 상태, 읽은 아이템 및 처리된 아이템 수 등이 모두 JobRepository에 저장된다.

💡 JobRepository

• 배치에 관련된 수치데이터(시작시간, 종료시간, 상태, 읽기/쓰기 횟수 등)뿐만 아니라 job의 상태를 관리 한다.
• 일반적으로 관계형 DB를 사용하여 배치 내의 주요 컴포넌트가 공유한다.

💡 JobLauncher

• Job.execute 메소드를 호출하여 job을 실행하는 역할을 담당한다.
• 잡의 재실행 가능 여부 검증, 잡의 실행방법, 파라미터 유효성 검증 등의 처리를 수행한다.

🔧 작동 원리

여러 아이템으로 이뤄진 청크의 처리가 스텝 내에서 완료된다.
⬇️
JobRepository 내에 있는 JobExecution 또는 StepExecution을 현재 상태로 갱신한다.
⬇️
step은 ItemReader가 읽은 아이템 목록을 따라간다.
⬇️
step이 각 청크를 처리할 때마다, JobRepository의 StepExecution의 step 상태가 업데이트된다.
⬇️
현재까지의 커밋 수, 시작 및 종료 시간, 기타 다른 정보 등이 JobRepositry에 저장된다.
⬇️
Job 또는 Step이 완료되면, JobRepository 내에 있는 JobExecution 또는 StepExecution이 최종 상태로 업데이트 된다.

❓ JobExecution과 StepExecution

💡 JobInstance

• Job의 논리적 실행이다.
• Job의 이름과 Job의 논리적 실행을 위해 제공되는 고유한 식별 파라미터 모음이다.
• 잡이 다른 파라미터로 실행될 때마다 새로운 JobInstance가 생성된다.
• JobInstance는 여러 개의 JobExecutions를 가질 수 있다.

💡 JobExecution

• Job의 실제 실행을 의미한다.
• Job을 구동할 때마다 매번 새로운 JobExecution을 얻게된다.
• JobExecution은 job이나 step이 진행될 때 변경된다. 잡 상태는 JobExecution의 ExecutionContext에 저장된다.

💡 StepExecution

• Step의 실제 실행을 나타낸다.
• 반면 StepInstance라는 개념은 존재하지 않는다.
• JobExecution은 여러 개의 StepExecution과 연관된다.

💡 ExecutionContext

• 배치 job의 세션이다.
• ExecutionContext가 담고 있는 모든 것들이 JobRepository에 저장되므로 안전하다.
• 웹 어플리케이션의 세션과 다른 점은 job을 다루는 과정에서 실제로 여러 개의 ExecutionContext가 존재할 수 있다.