JobOperator

JobOperator는 JobRegistry, JobExplorer, JobLauncher, JobRepository 클래스를 통해 Job의 InstanceId, ExecutionId, JobName을 이용하여 job을 제어하여 일반적인 모니터링 작업을 위해 사용한다.

JobOperator는 배치운영자가 의해 이루어지는 배치작업의 stopping, restarting, 또는 summarizing와 같은 모니터링 작업을 제공한다. Spring 배치는 JobOperator 인터페이스를 통해 아래의 작업의 유형을 제공한다.

public interface JobOperator {
 
	List<Long> getExecutions(long instanceId) throws NoSuchJobInstanceException;
 
	List<Long> getJobInstances(String jobName, int start, int count) throws NoSuchJobException;
 
        Set<Long> getRunningExecutions(String jobName) throws NoSuchJobException;
 
	String getParameters(long executionId) throws NoSuchJobExecutionException;
 
	Long start(String jobName, String parameters) throws NoSuchJobException, JobInstanceAlreadyExistsException, JobParametersInvalidException;
 
	Long restart(long executionId) throws JobInstanceAlreadyCompleteException, NoSuchJobExecutionException,
			NoSuchJobException, JobRestartException, JobParametersInvalidException;
 
	Long startNextInstance(String jobName) throws NoSuchJobException, JobParametersNotFoundException,
			JobRestartException, JobExecutionAlreadyRunningException, JobInstanceAlreadyCompleteException, 
                       UnexpectedJobExecutionException, JobParametersInvalidException;
 
	boolean stop(long executionId) throws NoSuchJobExecutionException, JobExecutionNotRunningException;
 
	String getSummary(long executionId) throws NoSuchJobExecutionException;
 
	Map<Long, String> getStepExecutionSummaries(long executionId) throws NoSuchJobExecutionException;
 
	Set<String> getJobNames();
 
}

JobOperator 인터페이스의 구현클래스로는 SimpleJobOperator가 제공된다. JobLauncher,JobRepository, JobExplorer 및 JobRegistry를 사용하여 아래의 기능들을 제공한다.

SimpleJobOperator클래스를 이용한 JobOperator의 설정은 아래와 같다. jobLauncher, jobExplorer, jobRepository, jobRegistry의 설정이 필수이다.

<bean id="jobOperator" class="org.springframework.batch.core.launch.support.SimpleJobOperator"
		p:jobLauncher-ref="jobLauncher" p:jobExplorer-ref="jobExplorer"
		p:jobRepository-ref="jobRepository" p:jobRegistry-ref="jobRegistry" />

• JobLauncher: 배치 작업을 실행한다.
• JobExplorer: Repository에 접근하여 배치작업에 대한 정보를 얻는다.
• JobRepository: 수행되는 Job에 대한 정보를 담고 있는 저장소이다.
• JobRegistry: 생성된 Job을 Map 형태로 추가, 삭제 등의 관리한다.

• 배치 Runner 예제
• http://static.springsource.org/spring-batch/reference/html/configureJob.html#JobOperator