定时任务组件Quartz

【目标】

定时任务组件Quartz

· 清除文件上传所产生的垃圾图片

【路径】

1:Quartz介绍

· 掌握场景(定时任务)

2:Quartz入门案例

· spring整合Quartz(spring中配置)

3:cron表达式(七子表达式)秒分时日月周年

4:cron表达式在线生成器

【讲解】

Quartz介绍

Quartz是Job scheduling(作业调度)领域的一个开源项目,Quartz既可以单独使用也可以跟spring框架整合使用,在实际开发中一般会使用后者。使用Quartz可以开发一个或者多个定时任务,每个定时任务可以单独指定执行的时间,例如每隔1小时执行一次、每个月第一天上午10点执行一次、每个月最后一天下午5点执行一次等。

官网:http://www.quartz-scheduler.org/

使用教程:https://www.w3cschool.cn/quartz_doc/

简单来说,就是可以帮助我们设置一个有规律的或者在某个具体的时间点干点想干的事的一个开源框架。

在使用Scheduler之前,需要实例化 scheduler实例化后,可以启动(start)、暂停(stand-by)、停止(shutdown)。

Quartz API的关键接口是:

· Scheduler:任务调度器,所有的任务都是从这里开始。

· Trigger:触发器,定义任务执行方式、间隔。

· JobDetail & Job : 定义任务具体执行的逻辑。

Scheduler的生命期,从SchedulerFactory创建它时开始,到Scheduler调用shutdown()方法时结束;Scheduler被创建后,可以增加、删除和列举Job和Trigger,以及执行其它与调度相关的操作(如暂停Trigger)。但是,Scheduler只有在调用start()方法后,才会真正地触发trigger(即执行job)

创建项目 quartz_demo 导入 maven 坐标:

 
    <dependencies>
 
        <!--引入Quartz的依赖-->
 
        <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>
 
    </dependencies>
 

Quartz 入门案例

①  创建QuartzTest

package com.newer.test;
 
import org.quartz.*;
 
import org.quartz.impl.StdSchedulerFactory;
 
public class QuartzTest {
 
    public static void main(String[] args) {
 
            try {
 
                //定义一个JobDetail
 
                JobDetail jobDetail = JobBuilder.newJob(HelloQuartz.class)
 
                        //定义name和group 给触发器一些属性 比如名字,组名。
 
                        .withIdentity("job1", "group1")
 
                        //job需要传递的内容 具体job传递参数。
 
                        .usingJobData("name", "newer")
 
                        .build();
 
                //定义一个Trigger
 
                Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1")
 
                        //加入 scheduler之后立刻执行 立刻启动
 
                        .startNow()
 
                        //定时 ,每隔1秒钟执行一次 以某种触发器触发。
 
                        .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1)
 
                                //重复执行
 
                                .repeatForever()).build();
 
                //创建scheduler
 
                Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
 
                scheduler.scheduleJob(jobDetail, trigger);
 
                // Scheduler只有在调用start()方法后,才会真正地触发trigger(即执行job)
 
                scheduler.start(); //运行一段时间后关闭
 
                try {
 
                    Thread.sleep(8000);
 
                } catch (InterruptedException e) {
 
                    e.printStackTrace();
 
                }
 
                //Scheduler调用shutdown()方法时结束
 
                scheduler.shutdown();
 
            } catch (Exception e) {
 
                e.printStackTrace();
 
            }
 
    }
 
}

②  创建HelloQuartz

package com.newer.test;
 
import org.quartz.Job;
 
import org.quartz.JobDetail;
 
import org.quartz.JobExecutionContext;
 
import java.util.Date;
 
public class HelloQuartz implements Job {
 
    public void execute(JobExecutionContext jobExecutionContext) {
 
        JobDetail detail = jobExecutionContext.getJobDetail();
 
        String name = detail.getJobDataMap().getString("name");
 
        System.out.println("my job name is  " + name + " at " + new Date());
 
    }
 
}

执行程序

Spring 整合 Quartz

【路径】

1:创建maven工程quartz_demo,打包方式为war,导入jar包

2:自定义一个Job

3:提供Spring配置文件applicationContext-jobs.xml,配置自定义Job、任务描述、触发器、调度工厂等

4:web.xml中定义

5:启动tomcat完成测试

【讲解】

本案例基于Quartz和spring整合的方式使用。具体步骤:

(1)创建maven工程quartz-demo,打包方式为war,导入Quartz和spring相关坐标,pom.xml文件如下

导入jar包

 
<?xml version="1.0" encoding="UTF-8"?>
 
<project xmlns="http://maven.apache.org/POM/4.0.0"
 
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 
    <modelVersion>4.0.0</modelVersion>
 
    <groupId>com.newer</groupId>
 
    <artifactId>quartz-demo</artifactId>
 
    <version>1.0-SNAPSHOT</version>
 
    <packaging>war</packaging>
 
    <dependencies>
 
        <dependency>
 
            <groupId>org.springframework</groupId>
 
            <artifactId>spring-context-support</artifactId>
 
            <version>5.0.2.RELEASE</version>
 
        </dependency>
 
        <dependency>
 
            <groupId>org.springframework</groupId>
 
            <artifactId>spring-tx</artifactId>
 
            <version>5.0.2.RELEASE</version>
 
        </dependency>
 
        <dependency>
 
            <groupId>org.springframework</groupId>
 
            <artifactId>spring-web</artifactId>
 
            <version>5.0.2.RELEASE</version>
 
        </dependency>
 
        <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>
 
    </dependencies>
 
    <build>
 
        <plugins>
 
            <plugin>
 
                <groupId>org.apache.tomcat.maven</groupId>
 
                <artifactId>tomcat7-maven-plugin</artifactId>
 
                <configuration>
 
                    <!-- 指定端口 -->
 
                    <port>8080</port>
 
                    <!-- 请求路径 -->
 
                    <path>/</path>
 
                </configuration>
 
            </plugin>
 
        </plugins>
 
    </build>
 
</project>
 

(2)自定义一个Job

 
package com.newer.quartz;
 
// 任务调度类
 
public class JobDemo {
 
    // 提供方法(备份数据库,清理日志,清理图片)
 
    public void run(){
 
        // 完成业务
 
        System.out.println(new Date());
 
    }
 
}
 

(3)提供Spring配置文件applicationContext-jobs.xml,配置自定义Job、任务描述、触发器、调度工厂等

【路径】

1:创建JobDetail对象,作用是负责通过反射调用指定的Job,注入目标对象,注入目标方法

2:注册一个触发器,指定任务触发的时间

3:注册一个统一的调度工厂,通过这个调度工厂调度任务

 
<?xml version="1.0" encoding="UTF-8"?>
 
<beans 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/beans
 
                  http://www.springframework.org/schema/beans/spring-beans.xsd
 
                  http://www.springframework.org/schema/context
 
                  http://www.springframework.org/schema/context/spring-context.xsd">
 
    <!-- 注册自定义Job -->
 
    <bean id="jobDemo" class="com.newer.quartz.JobDemo"></bean>
 
    <!-- 1:创建JobDetail对象,作用是负责通过反射调用指定的Job,注入目标对象,注入目标方法 -->
 
    <bean id="jobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
 
        <!-- 注入目标对象 -->
 
        <property name="targetObject" ref="jobDemo"/>
 
        <!-- 注入目标方法 -->
 
        <property name="targetMethod" value="run"/>
 
    </bean>
 
    <!-- 2:注册一个触发器,指定任务触发的时间 -->
 
    <bean id="myTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
 
        <!-- 注入JobDetail -->
 
        <property name="jobDetail" ref="jobDetail"/>
 
        <!-- 指定触发的时间,基于Cron表达式(0/10表示从0秒开始,每10秒执行一次) -->
 
        <property name="cronExpression">
 
            <value>0/10 * * * * ?</value>
 
        </property>
 
    </bean>
 
    <!-- 3:注册一个统一的调度工厂,通过这个调度工厂调度任务 -->
 
    <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
 
        <!-- 注入多个触发器 -->
 
        <property name="triggers">
 
            <list>
 
                <ref bean="myTrigger"/>
 
            </list>
 
        </property>
 
    </bean>
 
</beans>
 

(4)web.xml中定义

启动web,自动加载spring容器。

 
<?xml version="1.0" encoding="UTF-8"?>
 
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 
         xmlns="http://java.sun.com/xml/ns/javaee"
 
         xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
 
         id="WebApp_ID" version="3.0">
 
    <listener>
 
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
 
    </listener>
 
    <context-param>
 
        <param-name>contextConfigLocation</param-name>
 
        <param-value>classpath:applicationContext-jobs.xml</param-value>
 
    </context-param>
 
</web-app>
 

执行Tomcat观察控制台,可以发现每隔10秒会输出一次,说明每隔10秒自定义Job被调用一次。

 

4.3. cron表达式(七子表达式)

上面的入门案例中我们指定了一个表达式:0/10 * * * * ?

这种表达式称为cron表达式,通过cron表达式可以灵活的定义出符合要求的程序执行的时间。本小节我们就来学习一下cron表达式的使用方法。如下图:

 

cron表达式分为七个域,之间使用空格分隔。其中最后一个域(年)可以为空。每个域都有自己允许的值和一些特殊字符构成。使用这些特殊字符可以使我们定义的表达式更加灵活。

下面是对这些特殊字符的介绍:

逗号(,):指定一个值列表,例如使用在月域上1,4,5,7表示1月、4月、5月和7月

横杠(-):指定一个范围,例如在时域上3-6表示3点到6点(即3点、4点、5点、6点)

星号(*):表示这个域上包含所有合法的值。例如,在月份域上使用星号意味着每个月都会触发

斜线(/):表示递增,例如使用在秒域上0/15表示每15秒

问号(?):只能用在日和周域上,但是不能在这两个域上同时使用。表示不指定,例如想在每月的20日触发调度,不管20日到底是星期几,则只能使用如下写法: 13 13 15 20 * ?, 其中最后一位只能用?,而不能使用 *,如果使用 * 表示不管星期几都会触发,实际上并不是这样。

井号(#):只能使用在周域上,用于指定月份中的第几周的哪一天,例如6#3,意思是某月的第三个周五 (6=星期五,3意味着月份中的第三周)

L:某域上允许的最后一个值。只能使用在日和周域上。当用在日域上,表示的是在月域上指定的月份的最后一天。用于周域上时,表示周的最后一天,就是星期六

W:W 字符代表着工作日 (星期一到星期五),只能用在日域上,它用来指定离指定日的最近的一个工作日

4.3.1 常用表达式例子

 
10 0 2 1 * ? *   表示在每月的1日的凌晨2点执行任务
 
20 15 10 ? * MON-FRI   表示周一到周五每天上午10:15执行作业
 
30 0 10,14,16 * * ?   每天上午10点,下午2点,4点
 
40 0 12 ? * WED    表示每个星期三中午12点
 
  (50 0 12 * * ?   每天中午12点触发
 
  (60 15 10 ? * *    每天上午10:15触发
 
  (70 15 10 * * ?     每天上午10:15触发
 
  (80 15 10 * * ? *    每天上午10:15触发
 
  (90 15 10 * * ? 2005    2005年的每天上午10:15触发
 
  (100 * 14 * * ?     在每天下午2点到下午2:59期间的每1分钟触发
 
  (110 0/5 14 * * ?    在每天下午2点到下午2:55期间的每5分钟触发
 
  (120 0/5 14,18 * * ?     在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
 
  (130 0-5 14 * * ?    在每天下午2点到下午2:05期间的每1分钟触发
 
  (140 10,44 14 ? 3 WED    每年三月的星期三的下午2:10和2:44触发
 
  (150 15 10 ? * MON-FRI    周一至周五的上午10:15触发
 
  (160 15 10 15 * ?    每月15日上午10:15触发
 
  (170 15 10 L * ?    每月最后一天的上午10:15触发
 
  (180 15 10 ? * 6L    每月的最后一个星期五上午10:15触发
 
  (190 15 10 ? * 6L 2002-2005   2002年至2005年的每月的最后一个星期五上午10:15触发
 
  (200 15 10 ? * 6#3   每月的第三个星期五上午10:15触发
 
  (210 15 10 ? 6L 2002-2006   表示2002-2006年的每个月的最后一个星期五上午10:15执行作
 
  (220 0/30 9-17 * * ?   朝九晚五工作时间内每半小时
 

4.4. cron表达式在线生成器

前面介绍了cron表达式,但是自己编写表达式还是有一些困难的,我们可以借助一些cron表达式在线生成器来根据我们的需求生成表达式即可。

http://cron.qqe2.com/

 

【小结】

1:Quart介绍

· 掌握场景(定时任务)

2:Quartz入门案例

· spring整合Quartz(spring中配置)

3:cron表达式

4:cron表达式在线生成器