흐름 정리하기
지난 시간에 스프링 부트가 DefaultBatchConfiguration를 통해 JobLauncherApplicationRunner 빈을 등록하고
JobLauncher의 run() 메서드를 호출하는 과정을 살펴보았습니다.
이번 시간에는 간단하게 JobRunner 부터 시작하여 Job의 execute가 실행되는 부분까지, 간단히 정리해보며
잡의 생명주기를 다시 따라가 보겠습니다.
JobRunner
JobRunner: JobLauncherApplicationRunner -> JobLauncher 과정
스프링 배치를 실행할 때
JobRunner를 사용하긴 하지만,JobRunner는 프레임워크가 제공하는 표준 모듈은 아닙니다.
각 시나리오마다 서로 다른 구현체가 필요하기 때문에 스프링 배치는JobRunner라는 인터페이스를 별도로 제공하지 않습니다.
JobLauncherApplicationRunner에서
protected void execute(Job job, JobParameters jobParameters) throws JobExecutionAlreadyRunningException,
JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException {
JobParameters parameters = getNextJobParameters(job, jobParameters);
JobExecution execution = this.jobLauncher.run(job, parameters);
if (this.publisher != null) {
this.publisher.publishEvent(new JobExecutionEvent(execution));
}
}위와 같이 JobLauncher의 run() 메서드를 실행합니다.
어떤 JobLauncher가 들어있을까
@Configuration(proxyBeanMethods = false)
@Import(ScopeConfiguration.class)
public class DefaultBatchConfiguration implements ApplicationContextAware {
...
@Bean
public JobLauncher jobLauncher() throws BatchConfigurationException {
TaskExecutorJobLauncher taskExecutorJobLauncher = new TaskExecutorJobLauncher();
taskExecutorJobLauncher.setJobRepository(jobRepository());
taskExecutorJobLauncher.setTaskExecutor(getTaskExecutor());
try {
taskExecutorJobLauncher.afterPropertiesSet();
return taskExecutorJobLauncher;
}
catch (Exception e) {
throw new BatchConfigurationException("Unable to configure the default job launcher", e);
}
...
/**
* Return the {@link TaskExecutor} to use in the the job launcher. Defaults to
* {@link SyncTaskExecutor}.
* @return the {@link TaskExecutor} to use in the the job launcher.
*/
protected TaskExecutor getTaskExecutor() {
return new SyncTaskExecutor();
}
}v5부터 생겨난 기본 설정 클래스인 DefaultBatchConfiguration에서 JobLauncher를 빈으로 등록해줍니다.
또한 JobLauncher는 org.springframework.core.task의 TaskExecutor에 대한 의존성이 있는데, 이것도 같은 클래스에서 생성해줍니다.
기본값은 SyncTaskExecutor입니다.
이 경우엔 Job은 JobLauncher와 동일한 스레드에서 실행되게 됩니다.
getter를 오버라이딩하면 비동기 TaskExecutor도 사용할 수 있습니다.
이러면 Job이 JobLauncher와 다른 스레드에서 실행 될 것입니다.
JobLauncher -> TaskExecutor -> Job
JobLauncher: TaskExecutorJobLauncher -> TaskExecutor: SyncTaskExecutor 과정
public class TaskExecutorJobLauncher extends SimpleJobLauncher {
@Override
public JobExecution run(Job job, JobParameters jobParameters) throws JobExecutionAlreadyRunningException,
JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException {
return super.run(job, jobParameters);
}TaskExecutorJobLauncher는 곧 삭제될 Deprecate 된 SimpleJobLauncher를 확장하고 있습니다.
run() 메서드에서 곧바로 SimpleJobLauncher의 run()을 호출합니다.
@Deprecated(since = "5.0.0", forRemoval = true)
public class SimpleJobLauncher implements JobLauncher, InitializingBean {
@Override
public JobExecution run(final Job job, final JobParameters jobParameters)
throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException,
JobParametersInvalidException {
...
try {
taskExecutor.execute(new Runnable() {
@Override
public void run() {
try {
if (logger.isInfoEnabled()) {
logger.info("Job: [" + job + "] launched with the following parameters: [" + jobParameters
+ "]");
}
job.execute(jobExecution);
...SimpleJobLauncher는 run() 메서드에서 TaskExecutor를 통해 Runnable을 실행합니다.
그리고 그 안에서 Job의 execute() 메서드가 호출됩니다.
정리
JobRunner(JobLauncherApplicationRunner)에서 JobLauncher의 run(잡, 파라미터)를 호출한다.
JobLauncher(TaskExecutorJobLauncher)에서는 TaskExecutor의 execute(Runnable)을 호출한다.
TaskExecutor(SyncTaskExecutor)는 오버라이딩 된 Runnable의 run() 메서드를 실행하면서 Job의 execute()를 호출한다.
JobRunner -> JobLauncher -> TaskExecutor -> Job
