Quartz

Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目，它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个，百个，甚至是好几万个Jobs这样复杂的程序。Jobs可以做成标准的Java组件或 EJBs。Quartz的最新版本为Quartz 2.3.0。Quartz 是一个完全由 Java 编写的开源作业调度框架，为在 Java 应用程序中进行作业调度提供了简单却强大的机制。

Quartz 可以与 J2EE 与 J2SE 应用程序相结合也可以单独使用。

Quartz 允许程序开发人员根据时间的间隔来调度作业。

Quartz 实现了作业和触发器的多对多的关系，还能把多个作业与不同的触发器关联。Scheduler：调度容器

Job：Job接口类，即被调度的任务

JobDetail：Job的描述类，job执行时的依据此对象的信息反射实例化出Job的具体执行对象。

Trigger：触发器，存放Job执行的时间策略。用于定义任务调度时间规则。

JobStore： 存储作业和调度期间的状态

Calendar：指定排除的时间点(如排除法定节假日)

Quartz框架的使用思路job - 任务 - 你要做什么事？

Trigger - 触发器 - 你什么时候去做？

Scheduler - 任务调度 - 你什么时候需要去做什么事？

Job

Job 是一个接口，只有一个方法void execute(JobExecutionContext context)，开发者实现接口来定义任务。JobExecutionContext类提供了调度上下文的各种信息。Job 运行时的信息保存在JobDataMap实例中。

JobDetailImpl 类 / JobDetail 接口

JobDetailImpl类实现了JobDetail接口，用来描述一个 job，定义了job所有属性及其 get/set 方法。

Trigger

是一个类，描述触发Job执行的时间触发规则。主要有SimpleTrigger和CronTrigger这两个子类。当仅需触发一次或者以固定时间间隔周期执行，SimpleTrigger是最适合的选择；而CronTrigger则可以通过Cron表达式定义出各种复杂时间规则的调度方案：如每早晨9:00执行，周一、周三、周五下午5:00执行等；

Calendarorg.quartz.Calendar和java.util.Calendar不同，它是一些日历特定时间点的集合(可以简单地将org.quartz.Calendar看作java.util.Calendar的集合——java.util.Calendar代表一个日历时间点，无特殊说明后面的Calendar即指org.quartz.Calendar)。

一个Trigger可以和多个Calendar关联，以便排除或包含某些时间点。假设，我们安排每周星期一早上10:00执行任务，但是如果碰到法定的节日，任务则不执行，这时就需要在Trigger触发机制的基础上使用Calendar进行定点排除。

Scheduler调度器，代表一个Quartz的独立运行容器，好比一个『大管家』，这个大管家应该可以接受Job， 然后按照各种Tigger去运行，Trigger和JobDetail可以注册到Scheduler中，两者在Scheduler中拥有各自的组及名称，组及名称是Scheduler查找定位容器中某一对象的依据，Trigger的组及名称必须唯一，JobDetail的组和名称也必须唯一(但可以和Trigger的组和名称相同，因为它们是不同类型的)。

Scheduler定义了多个接口方法，允许外部通过组及名称访问和控制容器中Trigger和JobDetail。

Scheduler 可以将 Trigger 绑定到某一 JobDetail 中，这样当 Trigger 触发时，对应的 Job 就被执行。可以通过 SchedulerFactory创建一个 Scheduler 实例。

Scheduler 拥有一个 SchedulerContext，它类似于 ServletContext，保存着 Scheduler 上下文信息，Job 和 Trigger 都可以访问 SchedulerContext 内的信息。

SchedulerContext 内部通过一个 Map，以键值对的方式维护这些上下文数据，SchedulerContext 为保存和获取数据提供了多个 put() 和 getXxx() 的方法。可以通过Scheduler# getContext()获取对应的SchedulerContext实例；

ThreadPoolScheduler 使用一个线程池作为任务运行的基础设施，任务通过共享线程池中的线程提高运行效率。

quartz Cron表达式Cron 表达式是一个字符串，分为 6 或 7 个域，每一个域代表一个含义

Cron 有如下两种语法格式：

(1)Seconds Minutes Hours Day Month Week Year

(2)Seconds Minutes Hours Day Month Week

corn 从左到右(用空格隔开)：秒 分 小时 月份中的日期 月份 星期中的日期 年份

字段含义：

Cron表达式范例周一至周五的上午10:15触发 0 15 10 ? * 2-6

表示在每月的1日的凌晨2点调整任务 0 0 2 1 * ?

表示在每月的1日的凌晨2点调整任务 0 0 2 1 * ?

朝九晚五工作时间内每半小时 0 */30 9-16/1 * * ?

每天上午10点，下午2点，4点 0 0 10,14,16 * * ?

表示每个星期三中午12点 0 0 12 ? * 4

在每天下午2点到下午2:59期间的每1分钟触发 0 * 14 * * ?

在每天下午2点到下午2:05期间的每1分钟触发 0 0-5/1 14 * * ?

在每天下午2点到下午2:55期间的每5分钟触发0 0-55/5 14 * * ?

在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发 0 0-55/5 14,18 * * ?

注意：“?”字符只在日期域和星期域中使用。它被用来指定“非明确的值”。

例如：

想在每月的20日触发调度0 0 0 20 * ?，只能使用如下写法：0 0 0 20 * ?。其中最后一位只能用？，而不能使 用*，因为*表示不管星期几都会触发恰好与20冲突。

scheduled定时任务器案例

1. scheduled基于配置方式

job类

public class JobDemo {

@Scheduled(cron="*/1 * * * * ?")

public void method(){

System.out.println(new Date());

}

}

applicationContext-task.xml

xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:context="http://www.springframework.org/schema/context"

xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/taskhttp://www.springframework.org/schema/task/spring-task.xsd">

测试类

public class ScheduledTest {

public static void main(String[] args) throws IOException {

new ClassPathXmlApplicationContext("classpath:applicationContext-task.xml");

System.in.read();

}

}

scheduled基于注解方式

job类

@Component

@EnableScheduling //告诉spring这是个定时任务类public class JobDemo {

@Scheduled(cron="*/1 * * * * ?")

public void method(){

System.out.println(new Date());

}

}

applicationContext-task.xml

xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:context="http://www.springframework.org/schema/context"

xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/taskhttp://www.springframework.org/schema/task/spring-task.xsd">

测试类

public class ScheduledTest {

public static void main(String[] args) throws IOException {

new ClassPathXmlApplicationContext("classpath:applicationContext-task.xml");

System.in.read();

}

}

Quartz框架的使用

修改ego的pom.xml

... ...

2.2.2

.......

org.quartz-scheduler

quartz

${quartz.version}

修改ego-order-web的pom.xml

......

org.quartz-scheduler

quartz

job类

public class JobDemo implements Job{

@Override

public void execute(JobExecutionContext context) throws JobExecutionException {

System.out.println(new Date()+"------------------------------------");

}

}

测试类

public class QuartzTest {

public static void main(String[] args) throws SchedulerException {

/*** job：任务类 做什么事* trigger：触发器 什么时候做* scheduled：任务调度容器 什么时候做什么事*/

//创建job对象JobDetail job = JobBuilder.newJob(JobDemo.class).build();

//创建trigger对象CronTrigger trigger = TriggerBuilder.newTrigger().withSchedule(

CronScheduleBuilder.cronSchedule("*/1 * * * * ?")).build();

//创建scheduled对象Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

scheduler.scheduleJob(job, trigger);

//启动scheduler.start();

}

}

Spring整合Quartz框架

job类

public class JobDemo2{

public void execute(){

System.out.println(new Date()+"------------------------------------");

}

}

applicationContext-task.xml

xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:context="http://www.springframework.org/schema/context"

xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/taskhttp://www.springframework.org/schema/task/spring-task.xsd">

测试类

public class QuartzTest2 {

public static void main(String[] args) throws IOException {

new ClassPathXmlApplicationContext("classpath:applicationContext-task.xml");

System.in.read();

}

}

ego项目关闭超时2天未付款的订单

1、 在订单系统中导入相关的依赖

2、 定义joba) 扫描订单表修改订单的状态为关闭状态，订单的结束时间、关闭时间、修改时间为当前时间

把订单中商品的库存数量加回去

扫描条件：状态是未付款 并且 创建时间 <= 当前之间 – 2天 并且 付款方式为在线支付的订单

3、 定义触发a) 理论上需要实时触发(性能问题)

b) 1分钟触发一次

job类

public class OrderQuartz {

@Autowired

private OrderService orderService;

/*** 关闭超时订单*/

public void closeTimeOutOrder(){

//1、查询超时订单 List tbOrderList = orderService.listOvertimeOrder();

//2、关闭超时订单：status、updatetime、endtime、closetime for (TbOrder tbOrder : tbOrderList) {

tbOrder.setStatus(6);

tbOrder.setUpdateTime(new Date());

tbOrder.setEndTime(new Date());

tbOrder.setCloseTime(new Date());

orderService.closeTimeOutOrder(tbOrder);

//3、把订单中商品的库存数量加回去List orderItemList = orderService.listOrderItem(tbOrder.getOrderId());

for (TbOrderItem tbOrderItem : orderItemList) {

orderService.addItemNum(tbOrderItem.getItemId(),tbOrderItem.getNum());

}

}

}

}

service

@Service

public class OrderServiceImpl implements OrderService {

@Autowired

private TbOrderMapper tbOrderMapper;

@Autowired

private TbOrderItemMapper tbOrderItemMapper;

@Autowired

private TbItemMapper tbItemMapper;

@Override

public List listOvertimeOrder() {

return tbOrderMapper.listOvertimeOrder();

}

@Override

public void closeTimeOutOrder(TbOrder tbOrder) {

tbOrderMapper.updateByPrimaryKeySelective(tbOrder);

}

@Override

public List listOrderItem(String orderId) {

TbOrderItemExample tbOrderItemExample = new TbOrderItemExample();

Criteria criteria = tbOrderItemExample.createCriteria();

criteria.andOrderIdEqualTo(orderId);

return tbOrderItemMapper.selectByExample(tbOrderItemExample);

}

@Override

public void addItemNum(String itemId, Integer num) {

TbItem item = tbItemMapper.selectByPrimaryKey(Long.parseLong(itemId));

//原库存+numitem.setNum(item.getNum()+num);

tbItemMapper.updateByPrimaryKeySelective(item);

}

mapper层

1.接口添加List listOvertimeOrder();

2.xml配置文件中添加查询语句

SELECT

*

FROM

tb_order

WHERE

create_time <= DATE_SUB(NOW(), INTERVAL 2 DAY)

AND STATUS = 1

applicationContext-task.xml

xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:context="http://www.springframework.org/schema/context"

xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/taskhttp://www.springframework.org/schema/task/spring-task.xsd">