Rurony's Training Gym

Spring Bean을 Injection하여 사용자 접근 통계의 하루 누적치 통계를 수행하기 위한 Scheduler 사용 예제. 

1. Quartz 라이브러리 추가 (maven dependency 사용)
jar download url : http://mvnrepository.com/artifact/quartz/quartz/1.5.2

2. Service Class
Quartz Class에 Injection할 Service Bean.

public class StatServiceImpl implements StatService, ApplicationContextAware {

[...]

public void insertStat(String date) {

                //해당날짜의 log select.

StatBean stat = logDao.getLogStatByDate(date);

if (logger.isInfoEnabled()) {

logger.info(date + " Date Stat : " + stat.toString());

}

int checkStat = statDao.checkStat(date);

if (checkStat > 0) {

statDao.updateStat(stat);    //통계 update

if (logger.isInfoEnabled()) {

logger.info(date + " Date Stat Update");

}

} else {

statDao.insertStat(stat);    //통계 insert

if (logger.isInfoEnabled()) {

logger.info(date + " Date Stat Insert");

}

}

String accessLogDir = "/accessLog/";

String address = constantVo.getUrlContext() + "/admin/store/accessStat/dayStat?offsetDate=" + date;

String localFileName = context.getServletContext().getRealPath(constantVo.getDataUrl() + accessLogDir + date + ".html");

                //해당날짜의 접속통계 페이지를 HTML로 download

int downOk = downloadURL(address, localFileName);

if (downOk == 1) {

if (logger.isInfoEnabled()) {

logger.info(date + " Date Page Download");

}

logDao.deleteLog(date);    //해당날짜의 log delete

if (logger.isInfoEnabled()) {

logger.info(date + " Date Log Delete");

}

}

}

[...]

}

3. Quartz Class
@Inject, @Autowired로 Injection이 안되는 것 같음? 아래 Spring Bean 설정에서 Bean을 선언 하여 사용.

public class StatInsert extends QuartzJobBean {

private StatService statService; //could not autowired

public void setStatService(StatService statService) {

this.statService = statService;

}

protected void executeInternal(JobExecutionContext arg0) throws JobExecutionException {

[...]

statService.insertStat(date);

}

}

4. Spring Bean 설정
Spring Quartz Scheduler는 interval time 동작 방식과 cron tab 동작 방식이 있음.
접속 통계 누적 Scheduler는 cronExpression을 통한 매일 0시 5분에 실행 하도록 구현.
Injection할 Service Bean(들)은 jobDataAsMap의 entry로 등록하여 사용.

<!-- Service Bean -->
<bean id="statService" class="com.rurony.format.access.service.StatServiceImpl" />

<!-- Spring Quartz Scheduler Bean Setting -->

<!-- Simple Quartz Scheduler -->

<!--
<bean id="simpleQuartzJob" class="org.springframework.scheduling.quartz.JobDetailBean">

<property name="jobClass" value="com.rurony.format.schedule.StatInsert"/>

<property name="jobDataAsMap">

<map>

<entry key="statService">

<ref local="statService"/>

</entry>

</map>

</property>

</bean>

<bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">

<property name="jobDetail" ref="simpleQuartzJob"/>

<property name="startDelay" value="6000"/>

<property name="repeatInterval" value="6000"/>

</bean>
-->

<!-- Cron Quartz Scheduler -->

<!-- Scheduler Bean -->

<bean id="cronQuartzJob" class="org.springframework.scheduling.quartz.JobDetailBean">

<property name="jobClass" value="com.rurony.format.schedule.StatInsert" />

<property name="jobDataAsMap">

<map>

<entry key="statService">

<ref local="statService"/>

</entry>

</map>

</property>

</bean>

<!-- Scheduler Trigger cronExpression setting -->

<bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">

<property name="jobDetail" ref="cronQuartzJob"/>

<!-- <property name="cronExpression" value="1 * * * * ?"/> -->

<!-- <property name="cronExpression" value="0 30 9 * * ?"/> -->

<property name="cronExpression" value="0 5 0 * * ?"/> <!-- 매일 0시 5분 0초 에 실행 -->

</bean>

<!-- Scheduler Trigger  -->

<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

<property name="triggers">

<list>

<!-- <ref bean="simpleTrigger"/> -->

<ref bean="cronTrigger"/>

</list>

</property>

<property name="quartzProperties">

<props>

<prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop>

    <prop key="org.quartz.threadPool.threadCount">5</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>