ExecutionContext

• 배치 처리는 특성상 상태를 가지고 있다.

  • 현재 어떤 스텝이 실행되고 있는지 알아야 한다.
  • 해당 스텝이 처리한 레코드 개수도 알아야 한다.

• ExecutionContext 는 기본적으로 배치 잡의 세션이다.

  • ExecutionContext는 간단한 키-값 쌍을 보관하는 도구에 불과하다.
  • 그러나 ExecutionContext는 잡의 상태를 안전하게 보관하는 방법을 제공한다.

• 알아두어야 할 점은 잡을 다루는 과정에서 실제로 여러 개의 ExecutionContext가 존재할 수 있다는 점이다.

  • JobExecution처럼 각 StepExecution도 마찬가지로 ExecutionContext를 가진다.

  • 이렇게 함으로써 적절한 수준(개별 스텝용 데이터 또는 잡 전체용 글로벌 데이터)으로 데이터 사용 범위를 지정할 수 있다.

    

• ExecutionContext는 데이터를 저장하는 “안전한” 방법을 제공한다. ExecutionContext가 담고 있는 모든 것이 JobRepository에 저장되므로 안전하다.

ExecutionContextPromotionListener

• StepExecution의 Execution Context에 있는 키를 JobExecution의 ExecutionContext로 승격

• 이는 스텝 간에 공유할 데어터가 있지만 첫 번째 스텝이 성공했을 때만 공유하게 하고 싶을 때 유용하다.

  

  • promotionListner는 스텝이 성공적으로 완료 상태로 종료된 이후에 스텝의 ExecutionContext에서 "name" 키를 찾으면 잡의 ExecutionContext에 복사한다.
  • "name” 키를 찾지 못하더라도 기본적으로 아무 일도 일어나지 않지만 리스너가 예외를 발생하도록 구성할 수도 있다.

스텝 알아보기

• 잡이 전체적인 처리를 정의한다면 스텝은 잡의 구성 요소를 담당한다.
• 스텝은 독립적이고 순차적으로 배치 처리를 수행한다. 스텝을 배치 프로세서라고 부른다.
• 스텝은 모든 단위 작업의 조각이다.
  • 자체적으로 입력을 처리하고, 자체적인 처리기를 가 질 수 있으며, 자체적으로 출력을 처리한다.
• 트랜잭션은 스텝 내에서 이뤄진다.
• 스텝은 서로 독립되도록 의도적으로 설계됐다.

태스크릿 처리와 청크 처리 비교

• 태스크릿(Tasklet) 모델
  • Tasklet 인터페이스를 사용해 개발자는 Tasklet.execute() 메서드가 RepeatStatus.FINISHED를 반환할 때까지 트랜잭션 범위 내에서 반복적으로 실행되는 코드 블록을 만들 수 있다.
• 청크(Chunk) 기반 처리 모델

  • 청크 기반 스텝은 최소한 2~3개의 주요 컴포 넌트(ItemReader, 필수는 아닌 ItemProcessor, ItemWriter)로 구성된다.

  • 스프링 배치는 이러한 컴포넌트를 사용해 레코드를 청크 또는 레코드 그룹 단위로 처리한다.

  • 각 청크는 자체 트랜잭션으로 실행되며, 처리에 실패했다면 마지막으로 성공한 트랜잭션 이후부터 다시 시작할 수 있다.

  • ItemReader는 청크 단위로 처리할 모든 레코드를 반복적으로 메모리로 읽어온다.

  • 두 번째 루프는 ItemProcessor에서 일어난다. 필수 구성 요소는 아니지만 ItemProcessor를 구성했다면, 메모리로 읽어들인 아이템은 반복적으로 Item Processor를 거쳐간다.

  • 마지막으로 한 번에 기록할 수 있는 ItemWriter를 호출하면서 모든 아이템을 전달한다. ItemWriter의 단일 호출은 물리적 쓰기를 일괄적으로 처리함으로써 I/O 최적화를 이룬다.

    

태스크릿 스텝 구성

• 첫번째, Tasklet 인터페이스의 execute 메서드를 구현하는 방법

  • RepeatStatus.CONTINUABLE은 스프링 배치에게 해 당 태스크릿을 다시 실행하라고 말하는 것이다.

• 두번째, CallableTaskletAdapter 구현

  • 이 어댑터는 스텝의 특정 로직을 해당 스텝이 실행되는 스레드가 아닌 다른 스레드에서 실행하고 싶을 때 사용한다
  • 스탭이 실행되는 스레드와 별개의 스레드에서 실행되지만, 그렇다고 해서 스텝과 병렬로 실행되지는 않는다.
  • 단점
    • 굳이?

  

• 세번째, MethodlnvokingTaskletAdapter 구현

  • 이 구현체를사용하면 기존에 존재하던 다른클래스 내의 메서드를 잡 내의 태스크릿처럼 실행할수 있다.

  • 예를들어 배치 잡내에서 한번만 실행하고 싶은 로직을 어떤 서비스가 이미 갖고 있다고 가정해보자.

  • 해당 메서드 호출을 래핑할 뿐인 Tasklet 인터페이스의 구현체를 만드는 대신, MethodinvokingTaskletAdapter를 사용해 해당 메서드를 호출할 수 있다.

  • 단점

    • 메서드명을 리플렉션으로 호출한다.

    

• 네번째, SystemCommandTasklet

  • 이 태스크릿은 시스템 명령을 실행할 때 사용한다.
  • 지정한 시스템 명령은 비동기로 실행된다. 그래서 타임아웃 값(밀리초 단위임)이 중요하다.
  • interruptOnCancel 애트리뷰트의 사용 여부는 선택 사항으로, 잡이 비정상적으로 종료될 때 시스템 프로세스와 관련된 스레드를 강제로 종료할지 여부를스프링 배치에게 알려주는데 사용한다.

  

  • SystemCommandTasklet을 사용하면 시스템 명령 실행 시, 영향을 줄 수 있는 여러 파라미터를 구성할 수 있다.