1.Quartz的介绍
Quartz是Job scheduling（作业调度）领域的一个开源项目，Quartz既可以单独使用也可以跟spring框架整合使用，在实际开发中一般会使用后者。使用Quartz可以开发一个或者多个定时任务，每个定时任务可以单独指定执行的时间，例如每隔1小时执行一次、每个月第一天上午10点执行一次、每个月最后一天下午5点执行一次等。
官网：http://www.quartz-scheduler.org/
2.Quartz的使用步骤
1.
webapp骨架
2.修改pom.xml文件
引入需要的三方库
3.自定义一个任务类
调用任务类，普通类普通方法
4.增加spring-jobs.xml文件
配置任务对象、调度对象，调度工厂
5.修改web.xml文件
容器启动，加载spring配置文件
3.Quartz的使用演示
本案例基于Quartz和spring整合的方式使用。具体步骤：
（1）创建maven子模块工程health-jobs，骨架webapp
（2）修改pom.xml文件
1 <?xml version="1.0" encoding="UTF-8"?> 2 3 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 5 <parent> 6 <artifactId>itcast_health</artifactId> 7 <groupId>com.itheima.health</groupId> 8 <version>1.0-SNAPSHOT</version> 9 </parent> 10 <modelVersion>4.0.0</modelVersion> 11 12 <artifactId>health-jobs</artifactId> 13 <packaging>war</packaging> 14 15 <name>health-jobs</name> 16 17 <properties> 18 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 19 <maven.compiler.source>1.7</maven.compiler.source> 20 <maven.compiler.target>1.7</maven.compiler.target> 21 </properties> 22 <dependencies> 23 24 <dependency> 25 <groupId>com.itheima.health</groupId> 26 <artifactId>health_common</artifactId> 27 <version>1.0-SNAPSHOT</version> 28 </dependency> 29 <dependency> 30 <groupId>org.springframework</groupId> 31 <artifactId>spring-webmvc</artifactId> 32 </dependency> 33 <dependency> 34 <groupId>org.springframework</groupId> 35 <artifactId>spring-tx</artifactId> 36 </dependency> 37 <dependency> 38 <groupId>org.quartz-scheduler</groupId> 39 <artifactId>quartz</artifactId> 40 </dependency> 41 <dependency> 42 <groupId>org.quartz-scheduler</groupId> 43 <artifactId>quartz-jobs</artifactId> 44 </dependency> 45 <dependency> 46 <groupId>redis.clients</groupId> 47 <artifactId>jedis</artifactId> 48 </dependency> 49 <dependency> 50 <groupId>org.springframework</groupId> 51 <artifactId>spring-context-support</artifactId> 52 </dependency> 53 <dependency> 54 <groupId>com.qiniu</groupId> 55 <artifactId>qiniu-java-sdk</artifactId> 56 </dependency> 57 </dependencies> 58 <build> 59 <finalName>health-jobs</finalName> 60 <plugins> 61 <plugin> 62 <groupId>org.apache.tomcat.maven</groupId> 63 <artifactId>tomcat7-maven-plugin</artifactId> 64 <configuration> 65 <path>/</path> 66 <port>9003</port> 67 </configuration> 68 </plugin> 69 </plugins> 70 </build> 71 </project>
main下创建java目录 (刷新maven工程)，然后创建com.itheima.health.jobs包，然后新建一个任务调度类ClearImageJob，任务内容暂时做普通打印即可。
/**
* 定时任务：在这里定义你想要完成的功能
*public class ClearImageJob {
/**
* 定义清理图片的任务
*/
public void clearImageJob(){
System.out.println("clearImageJob......");
}
}
（4）创建配置文件spring-jobs.xml，配置自定义Job、任务描述、触发器、调度工厂等
-
自动扫包
-
注册任务对象
-
注册JobDetail
-
定义触发器
-
定义调度工厂
在main下创建resources目录，刷新maven后，在目录下创建spring-jobs.xml
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xmlns:context="http://www.springframework.org/schema/context" 5 xsi:schemaLocation="http://www.springframework.org/schema/beans 6 http://www.springframework.org/schema/beans/spring-beans.xsd 7 http://www.springframework.org/schema/context 8 http://www.springframework.org/schema/context/spring-context.xsd"> 9 10 <!--自动扫包,后续注入jedis到任务调度类--> 11 <context:component-scan base-package="com.itheima.health"/> 12 <!--注册一个定义任务对象--> 13 <bean id = "clearImgJob" class="com.itheima.health.jobs.ClearImageJob"/> 14 <!-- 注册JobDetail,作用是负责通过反射调用指定的Job --> 15 <bean id="clearImgJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> 16 <!--注入对象--> 17 <property name="targetObject" ref="clearImgJob"/> 18 <!--注入方法--> 19 <property name="targetMethod" value="clearImageJob"/> 20 </bean> 21 <!--注册一个触发器，指定任务触发的时间（间隔）--> 22 <bean id="jobTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> 23 <property name="jobDetail" ref="clearImgJobDetail"/> 24 <property name="cronExpression"> 25 <!-- 每隔10秒执行一次任务 0/10 * * * * ? --> 26 <!-- 每隔2分钟执行一次任务 0 0/2 * * * ? --> 27 <!-- 每天凌晨2点执行一次任务 0 0 2 * * ? --> 28 <value>0/10 * * * * ?</value> 29 </property> 30 </bean> 31 <!--注册一个统一调用工厂，通过这个调度工厂调度任务--> 32 <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> 33 <property name="triggers"> 34 <list> 35 <ref bean="jobTrigger"/> 36 </list> 37 </property> 38 </bean> 39 </beans>
（5）修改web.xml，容器启动时，加载spring配置文件
1 <!DOCTYPE web-app PUBLIC 2 "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" 3 "http://java.sun.com/dtd/web-app_2_3.dtd" > 4 5 <web-app> 6 <display-name> Jobs Web Application</display-name> 7 <context-param> 8 <param-name>contextConfigLocation</param-name> 9 <param-value>classpath:spring-*.xml</param-value> 10 </context-param> 11 <listener> 12 <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> 13 </listener> 14 </web-app>
执行上面main方法观察控制台，可以发现每隔10秒会输出一次，说明每隔10秒自定义Job被调用一次。
上面的入门案例中我们指定了一个表达式：0/10 * * * * ?
这种表达式称为cron表达式，通过cron表达式可以灵活的定义出符合要求的程序执行的时间。
4.
本节基于Quartz定时任务，通过计算redis两个集合的差值找出所有的垃圾图片，就可以将垃圾图片清理掉。
实现流程：
1.
需要进行差值计算
2.
修改为每天凌晨2点执行任务
3.
增加删除方法
4.
进行差值计算，对差值结果就是需要清理的图片
操作步骤：
(1) 配置spring-redis.xml
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> 5 <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"> 6 <property name="maxTotal"> 7 <value>200</value> 8 </property> 9 <property name="minIdle"> 10 <value>50</value> 11 </property> 12 <property name="testOnBorrow" value="true"/> 13 <property name="testOnReturn" value="true"/> 14 </bean> 15 <bean id="jedisPool" class="redis.clients.jedis.JedisPool"> 16 <constructor-arg name="poolConfig" ref="jedisPoolConfig"/> 17 <constructor-arg name="host" value="127.0.0.1"/> 18 <constructor-arg name="port" value="6379"/> 19 </bean> 20 </beans>
(2) 修改spring-jobs.xml，调度时间改为每天凌晨2点执行
0 0 2 * * ?
1 <!--注册一个触发器，指定任务触发的时间（间隔）--> 2 <bean id="jobTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> 3 <property name="jobDetail" ref="clearImgJobDetail"/> 4 <property name="cronExpression"> 5 <!--每隔10秒执行一次任务 0/10 **** ？--> 6 <!--每隔2分钟执行一次任务 0 0/2 *** ？--> 7 <!--每天凌晨2点执行一次任务 0 0 2 ** ？--> 8 <value>0 0 2 * * ?</value> 9 </property> 10 </bean>
（3）增加七牛工具类，删除不用的文件
1 /** 2 * 七牛云工具类 3 */ 4 public class QiniuUtils { 5 public static String accessKey = "fhuiPBXFTZIgJdtZGuMtCUJ3zSrT7k3AHmVNE4UA"; 6 public static String secretKey = "zKKxCW_HjQmwtl4JI80nMT0Ve2V7VZDbqT4zt_tT"; 7 public static String bucket = "itcast_health"; 8 9 /** 10 * 删除文件 11 * @param fileName 服务端文件名 12 */ 13 public static void deleteFileFromQiniu(String fileName){ 14 //构造一个带指定Zone对象的配置类 15 Configuration cfg = new Configuration(Zone.zone0()); 16 String key = fileName; 17 Auth auth = Auth.create(accessKey, secretKey); 18 BucketManager bucketManager = new BucketManager(auth, cfg); 19 try { 20 bucketManager.delete(bucket, key); 21 } catch (QiniuException ex) { 22 //如果遇到异常，说明删除失败 23 System.err.println(ex.code()); 24 System.err.println(ex.response.toString()); 25 } 26 } 27 // 测试上传与删除 28 public static void main(String args[]) throws Exception{ 29 // 测试删除 30 //deleteFileFromQiniu("f5eee75c0c5d4eeda1c5c49bee766603"); 31 } 32 }
（4）修订ClearJob定时任务类
1 /** 2 * 定时任务：清理垃圾图片 3 */ 4 public class ClearJob { 5 @Autowired//idea自动识别，xml文件顶部出现的context中勾选全部xml文件，就能正常识别了 6 private JedisPool jedisPool; 7 //清理图片 8 public void clearImageJob(){ 9 //计算redis中两个集合的差值，获取垃圾图片名称 10 Set<String> set = jedisPool.getResource() 11 .sdiff(RedisConst.SETMEAL_PIC_RESOURCES, 12 RedisConst.SETMEAL_PIC_DB_RESOURCES); 13 Iterator<String> iterator = set.iterator(); 14 while(iterator.hasNext()){ 15 String pic = iterator.next(); 16 //删除图片服务器中的图片文件 17 QiniuUtils.deleteFileFromQiniu(pic); 18 //删除redis中的数据 19 jedisPool.getResource().srem(RedisConst.SETMEAL_PIC_RESOURCES,pic); 20 } 21 } 22 }