任务调度之Quartz

略

Quartz的使用

开启一个简单的Quartz

//任务调度器工厂
SchedulerFactory sf = new StdSchedulerFactory();
//通过工厂得到调度器
Scheduler scheduler = sf.getScheduler();
//打开
scheduler.start();
//关闭
scheduler.shutdown();

加上任务

SchedulerFactory sf = new StdSchedulerFactory();
Scheduler scheduler = sf.getScheduler();
//任务内容(什么事)
JobDetail job = JobBuilder.newJob(HelloJob.class).withIdentity("job1", "group1").build();
//任务时间(什么时间)
Trigger trigger = TriggerBuilder
  .newTrigger()
  .withIdentity("trigger1", "group1")
  .startNow()
  .withSchedule(SimpleScheduleBuilder
                .simpleSchedule()
                .withIntervalInSeconds(5)
                .repeatForever())
  .build();

/*
//1.5秒一次
		Trigger trigger = TriggerBuilder
                .newTrigger()
                .forJob("job1", "group1")
                .startNow()
				.withSchedule(SimpleScheduleBuilder
                        .repeatSecondlyForever(5))
                .build();
//2.22:52一次
		Trigger trigger = TriggerBuilder
                .newTrigger()
                .forJob("job1", "group1")
                .startNow()
				.withSchedule(CronScheduleBuilder
                        .dailyAtHourAndMinute(22, 52))
                .build();
//3.每个星期天*****
		Trigger trigger = TriggerBuilder
                .newTrigger()
                .forJob("job1", "group1")
                .startNow()
				.withSchedule(CronScheduleBuilder
                        .cronSchedule("0 1 23 ? * SUN"))
                .build();
*/

//什么时间做什么事
scheduler.scheduleJob(job, trigger);
//开始任务
scheduler.start();

任务的具体内容Job接口的具体实现

public class HelloJob implements Job {

  private Logger logger = LoggerFactory.getLogger(this.getClass());

  public void execute(JobExecutionContext context) throws JobExecutionException {
    logger.info("hello,quartz!");
  }

}

结合Spring来使用

1. 导包

   <dependency>
     <groupId>org.quartz-scheduler</groupId>
     <artifactId>quartz</artifactId>
     <version>2.2.1</version>
   </dependency>
   <dependency>
     <groupId>org.quartz-scheduler</groupId>
     <artifactId>quartz-jobs</artifactId>
     <version>2.2.1</version>
   </dependency>

2. applicationContext.xml

   <!-- 扫描Service注解 -->
   <context:component-scan base-package="com.yuda" />
   <!-- 具体任务内容 -->
   <bean id="helloJob" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">  
     <property name="jobClass" value="com.yuda.job.HelloJob"/>  
     <property name="jobDataAsMap">  
       <map>  
         <entry key="timeout" value="5"/>
       </map>  
     </property>  
   </bean> 
   
   <bean class="org.springframework.scheduling.quartz.JobDetailFactoryBean" id="promotionJob">
     <property name="jobClass" value="com.yuda.quartz.PromotionJob"/>
   </bean>
   
   <!-- ======================== 调度触发器 ======================== -->
   <!-- 什么时间做什么事 -->
   <bean id="cronTriggerBean" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
     <property name="jobDetail" ref="helloJob"></property>
     <property name="cronExpression" value="0 54 * * * ?"></property>
   </bean>
   <!-- 60秒一次 -->
   <bean class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean" id="simpleTrigger">
     <property name="jobDetail" ref="promotionJob"/>
     <property name="startDelay" value="0"/>
     <property name="repeatInterval" value="60000"/>
   </bean>
   
   <!-- ======================== 调度工厂 ======================== -->
   <!-- 任务调度主入口 -->
   <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
     <property name="jobFactory" ref="jobFactory" />
     <property name="triggers">
       <list>
         <ref bean="cronTriggerBean" />
   	  <ref bean="simpleTrigger" />
       </list>
     </property>
   </bean>

3. JobFactory

   为了把QuartzJobBean转换为一个bean,为了让service可以注入到JobBean中

   import org.quartz.spi.TriggerFiredBundle;
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
   import org.springframework.scheduling.quartz.AdaptableJobFactory;
   import org.springframework.stereotype.Service;
   
   @Service("jobFactory")
   public class JobFactory extends AdaptableJobFactory {
   
   	@Autowired
   	private AutowireCapableBeanFactory capableBeanFactory;
   
   	@Override
   	protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
   		// 调用父类的方法
   		Object jobInstance = super.createJobInstance(bundle);
   		// 进行注入
   		capableBeanFactory.autowireBean(jobInstance);
   		return jobInstance;
   	}
   
   }

   注意:该类的写法固定

4. 具体任务内容(继承QuartzJobBean类)

   import org.quartz.JobExecutionContext;
   import org.quartz.JobExecutionException;
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.scheduling.quartz.QuartzJobBean;
   
   import com.yuda.service.HelloService;
   
   public class HelloJob extends QuartzJobBean {
   
   	@Autowired
   	private HelloService helloService;
   
   	@Override
   	protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
   		helloService.sayHello();
   	}
   }

   jobFactory的具体作用就是把上述类声明为一个Spring管理的bean,只有这样,private HelloService helloService 才可以被自动装配到HelloJob中.