[QUARTZ] 스프링 환경에서 즉시실행 하기.

 

 

 

-

JAVA BATCH로 편한걸로 꼽자면 QUARTZ 를 빼놓을 수가 없지..  암암.. 그렇고 말고. 

BATCH는 혼자서 도는게 맞지만 경우에 따라 즉시 실행을 해줘야 하는 경우도 있다. 

가령, 초기 데이터를 가져온다던지....

설정부터 스프링에서 즉시 실행하는 방법까지 알아보자. 

 

context-schedule.xml

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd "> <!-- bean 설정 --> <bean id="batchExcutor" class="com.test.BatchExecutor" /> <!-- bean Job 설정 --> <bean id="ifTest001" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject" ref="batchExcutor"/> <property name="targetMethod" value="IF_TEST_001"/> <property name="arguments"> <map> <entry key="serviceId" value="PARAM_IF_TEST_001" /> </map> </property> </bean> <!-- cronExpression 정의 --> <bean id="ifTest001Trigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail" ref="ifTest001" /> <property name="cronExpression" value="0 0 0 4 * ?"/> </bean> <!-- 실행 --> <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="jobDetails"> <list> <ref bean="ifTest001"/> </list> </property> <property name="triggers"> <list> <ref bean="ifTest001Trigger"/> </list> </property> <property name="quartzProperties"> <props> <prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop> <prop key="org.quartz.threadPool.threadCount">3</prop> <prop key="org.quartz.threadPool.threadPriority">4</prop> <prop key="org.quartz.jobStore.class">org.quartz.simpl.RAMJobStore</prop> <prop key="org.quartz.jobStore.misfireThreshold">60000</prop> </props> </property> </bean> </beans>

 

BatchExecutor.java

package com.test.batch; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.MediaType; import org.springframework.scheduling.quartz.QuartzJobBean; public class BatchExecutor extends QuartzJobBean{ private final Logger log = LoggerFactory.getLogger(BatchExecutor.class); @Override protected void executeInternal(JobExecutionContext arg0) throws JobExecutionException { long time = System.currentTimeMillis(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd HH:mm:ss"); log.debug("executeInternal 1 (5 second): current time = " + sdf.format(time)); } /** * 테스트 배치. * 실행주기 : 1일 * @throws Exception */ private void IF_TEST_001(LinkedHashMap serviceParams) throws Exception { String serviceId = (String)serviceParams.get("serviceId"); // if(log.isDebugEnabled()){this.initText(context);} long time = System.currentTimeMillis(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd HH:mm:ss"); log.debug("specificMin 13:55 (1 minute): current time = " + sdf.format(time)); } }

 

즉시 실행은 한참을 찾아봤는데 생각보다 간단하다.  

SchedulerFactoryBean 을 AUTOWIRED 시켜준 후, XML에 설정된 실행할 배치의 BEAN JOB ID 로 JOBKEY 를 생성 한 후, 스케쥴러의 triggerJob 을 실행하면 해당하는 스케쥴러가 즉시 동작하게 된다. 

예를 들면. vo.setBatchId("ifTest001") 를 해주고 manualBatchExecute를 실행하게 되면 해당하는 ifTest001 배치가 바로 실행된다. 

즉시실행 메서드

@Autowired SchedulerFactoryBean schedulerBean; /** * 지정된 트리거를 수동으로 시작시킨다. */ @ServiceIdMapping("MANUAL_BATCH_EXECUTE") public Object manualBatchExecute(BatchVo vo) { // 1~4번까지만 String result = ""; try{ JobKey jobKey = new JobKey(vo.getBatchId()); Scheduler scheduler = schedulerBean.getScheduler(); scheduler.triggerJob(jobKey); }catch(Exception e){ log.error(e.getMessage()); } return result; }

-

무료통화/무료문자를 포인트로 전환해서 기프티콘, 상품권으로 바꾸자.

http://bbokkun.tistory.com/23

공감버튼을 누르는것은 돈이 들지 않습니다. 한 번씩 꾹! 클릭! 부탁드려요.