quart简单使用

1、Job

表示一个工作，要执行的具体内容。此接口中只有一个方法

void execute(JobExecutionContext context)

2、JobDetail

JobDetail表示一个具体的可执行的调度程序，Job是这个可执行程调度程序所要执行的内容，另外JobDetail还包含了这个任务调度的方案和策略。

3、Trigger代表一个调度参数的配置，什么时候去调。

4、Scheduler代表一个调度容器，一个调度容器中可以注册多个JobDetail和Trigger。当Trigger与JobDetail组合，就可以被Scheduler容器调度了。

import org.quartz.*;

import org.quartz.impl.StdSchedulerFactory;

import java.util.Date;

/**

* quartz定时器测试

*/

public class MyJob implements Job {

public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {

System.out.println(new Date() + ": doing something...");

}

}

class Test {

public static void main(String[] args) {

//1、创建JobDetial对象

JobDetail jobDetail = new JobDetail();

//设置工作项

jobDetail.setJobClass(MyJob.class);

jobDetail.setName("MyJob_1");

jobDetail.setGroup("JobGroup_1");

//2、创建Trigger对象

SimpleTrigger strigger = new SimpleTrigger();

strigger.setName("Trigger_1");

strigger.setGroup("Trigger_Group_1");

strigger.setStartTime(new Date());

//设置重复停止时间，并销毁该Trigger对象

java.util.Calendar c = java.util.Calendar.getInstance();

c.setTimeInMillis(System.currentTimeMillis() + 1000 * 1L);

strigger.setEndTime(c.getTime());

strigger.setFireInstanceId("Trigger_1_id_001");

//设置重复间隔时间

strigger.setRepeatInterval(1000 * 1L);

//设置重复执行次数

strigger.setRepeatCount(3);

//3、创建Scheduler对象，并配置JobDetail和Trigger对象

SchedulerFactory sf = new StdSchedulerFactory();

Scheduler scheduler = null;

try {

scheduler = sf.getScheduler();

scheduler.scheduleJob(jobDetail, strigger);

//4、并执行启动、关闭等操作

scheduler.start();

} catch (SchedulerException e) {

e.printStackTrace();

}

// try {

// //关闭调度器

// scheduler.shutdown(true);

// } catch (SchedulerException e) {

// e.printStackTrace();

// }

}

}

//4、并执行启动、关闭等操作

scheduler.start();

scheduler.shutdown(true);

Thu Jul 23 10:11:50 CST 2009: doing something...

Process finished with exit code 0

1、scheduler是一个计划调度器容器（总部），容器里面可以盛放众多的JobDetail和trigger，当容器启动后，里面的每个JobDetail都会根据trigger按部就班自动去执行。

2、JobDetail是一个可执行的工作，它本身可能是有状态的。

3、Trigger代表一个调度参数的配置，什么时候去调。

4、当JobDetail和Trigger在scheduler容器上注册后，形成了装配好的作业（JobDetail和Trigger所组成的一对儿），就可以伴随容器启动而调度执行了。

5、scheduler是个容器，容器中有一个线程池，用来并行调度执行每个作业，这样可以提高容器效率。

// https://mvnrepository.com/artifact/org.quartz-scheduler/quartz

compile group: 'org.quartz-scheduler', name: 'quartz', version: '2.3.0'

<!-- 定义一个任务类 -->

<bean id="myJob" class="com.item1024.quartz.TimeTask"></bean>

<!-- jobDetail -->

<bean id="jobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">

<property name="targetObject" ref="myJob"></property>

<property name="targetMethod" value="racWallet"></property>

<property name="concurrent" value="false" /><!-- 作业不并发调度 false 任务未执行完不会执行下一个任务 -->

</bean>

<!-- 定义trigger 触发器 -->

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

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

<property name="cronExpression" value="*/10 * * * * ?"></property> <!-- 十秒一次 -->

</bean>

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

<property name="triggers">

<list>

<ref bean="cronTrigger"/>

</list>

</property>

</bean>

package com.item1024.quartz;

import com.item1024.bean.TransBean;

import com.item1024.constant.TylConstant;

import com.item1024.mapper.TransLogMapper;

import com.item1024.pojo.TransLog;

import com.item1024.service.OpCoinService;

import com.item1024.service.UserWalletRacService;

import javax.annotation.Resource;

import java.util.Date;

import java.util.List;

/**

* @author 阳十三

* @email [email protected]

* @blog http://www.item1024.com

* @date 2017/8/30

*/

public class TimeTask {

public void racWallet() {

System.out.println("交易任务开启: ");

}

}