인프런 커뮤니티 질문&답변

안녕하세요 선생님, 개인적으로 이 강의를 다 보고,

혼자서 이것저것 해보고 있는데, 뭔가 이해가 안되는 현상이 있어서 질문드립니다.

일단 제가 작성한 아주 간단한 Batch 코드를 먼저 공유하겠습니다. (Spring boot 3 + Spring Batch core 5 버전입니다.)

```java

package coding.toast.batch.job.reader.config;

import coding.toast.batch.job.reader.listener.EmptyReadFailureListener;
import lombok.RequiredArgsConstructor;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.job.builder.JobBuilder;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.step.builder.StepBuilder;
import org.springframework.batch.item.support.ListItemReader;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.PlatformTransactionManager;

import java.util.List;

@Configuration
@RequiredArgsConstructor
public class CustomItemStreamConfig {
    private final JobRepository jobRepository;
    private final PlatformTransactionManager transactionManager;
    
    @Bean
    public Job customItemStreamConfigJob() {
       return new JobBuilder("customItemStreamConfigJob", jobRepository)
          .start(customItemStreamConfigStep())
          .next(simpleStep2())
          .build();
    }
    
    private Step simpleStep2() {
       return new StepBuilder("simpleStep", jobRepository)
          .tasklet((contribution, chunkContext) -> {
             System.out.println("이게 나오면 안됩니다!");
             return RepeatStatus.FINISHED;
          }, transactionManager).build();
    }
    
    @Bean
    public Step customItemStreamConfigStep() {
       return new StepBuilder("customItemStreamConfigStep", jobRepository)
          .<Integer, Integer>chunk(5, transactionManager)
          .reader(new ListItemReader<>(List.of())) // 고의적으로 비워놨습니다!
          .writer(chunk -> {
             chunk.getItems().forEach(System.out::println);
          })
          .listener(emptyReadFailureListener())
          .build();
    }
    
    @Bean
    public EmptyReadFailureListener emptyReadFailureListener() {
       return new EmptyReadFailureListener();
    }
}

여기서 EmptyReadFailureListener 타입의 인스턴스를 빈으로 등록하고, 이를 Step 의 listener 로 등록했습니다.

이 리스너의 역할은 ItemReader 로 부터 읽은 것이 아무것도 없을 때 Step 이 FAILED 되도록 하기 위한 것입니다.

자세한 내용은 아래와 같습니다.

package coding.toast.batch.job.reader.listener;

import org.springframework.batch.core.*;

public class EmptyReadFailureListener implements StepExecutionListener {
	@Override
	public ExitStatus afterStep(StepExecution stepExecution) {
		if (stepExecution.getReadCount() > 0) {
			return stepExecution.getExitStatus();
		} else {
			return ExitStatus.FAILED.addExitDescription("exit Because Of No Item Read");
		}
	}
}

위처럼 작성했습니다.

저는 위의 Job 을 실행하면...

1. Job 의 BatchStatus 와 ExitStatus 모두 FAILED 가 된다.

2. simpleStep 은 이전 Step 에서 ExitStatus Failed 가 됐으므로 실행되지 않는다.

    

... 하지만 정확히 정반대의 결과가 나왔습니다 😅😅

batch_job_execution 테이블의 결과:

batch_step_execution 테이블의 결과:

보시는 바와 같이 Job 자체는 Completed 로 끝이 났습니다.

또한 실행되지 않았으면 했던 두번째 step(=simpleStep) 도 실행이 되버리더라구요...

질문:
1. 왜 이렇게 동작하는 걸까요? 혹시 ExitStatus 에 대해서 뭔가 잘못 알고 있는 걸까요?

2. 그리고 이를 해결하기 위해서는 EmptyReadFailureListener 를 어떻게 고치면 좋을까요?
아니면 혹시 더 좋은 방법이 있을까요??