黑马传智健康项目中遇到的技术,感觉这个解决思路挺新颖的,就记录下来了。用到了redis、Quartz以及cron定时计划等知识点。
什么是Quartz
Quartz
是OpenSymphony
开源组织在Job scheduling
领域又一个开源项目,完全由Java
开发,可以用来执行定时任务,类似于java.util.Timer
。但是相较于Timer
, Quartz
增加了很多功能:
持久性作业 - 就是保持调度定时的状态;
作业管理 - 对调度作业进行有效的管理;
Quartz组件使用场景
拿火车票购票来说,当你下单后,后台就会插入一条待支付的task(job)
,一般是30
分钟,超过30min
后就会执行这个job
,去判断你是否支付,未支付就会取消此次订单;当你支付完成之后,后台拿到支付回调后就会再插入一条待消费的task(job)
,Job
触发日期为火车票上的出发日期,超过这个时间就会执行这个job
,判断是否使用等
我在项目中使用Quartz的原因在于文件上传遇到的一些问题,问题描述:
在项目中有一个新增套餐功能,需要导入图片,这里导入图片成功后会自动上传到七牛云服务器中,那么如果我最后点击 “取消” 或者 “X” 新增的套餐数据就不会插入到数据库当中,但是图片已经上传到七牛云服务器上了,占用了资源空间,这里就需要我们按时去清理云服务器中的无用资源,释放空间。
(1)首先我们需要定义实现一个定时功能的接口,我们可以称之为Task(或Job),如定时发送邮件的task(Job),重启机器的task(Job),优惠券到期发送短信提醒的task(Job),实现接口如下:
(2)有了任务之后,还需要一个能够实现触发任务去执行的触发器,触发器Trigger最基本的功能是指定Job的执行时间,执行间隔,运行次数等。
(3)有了Job和Trigger后,怎么样将两者结合起来呢?即怎样指定Trigger去执行指定的Job呢?这时需要一个Schedule,来负责这个功能的实现。
上面三个部分就是Quartz
的基本组成部分:
Scheduler
JobDetail
Trigger
,包括SimpleTrigger
和CronTrigger
在继续介绍Quartz
之前,我们先来介绍一下cron
表达式
Cron
表达式是一个具有时间含义的字符串,字符串以5-6
个空格隔开,分为6~7
个域,格式为X X X X X X X
。其中X
是一个域的占位符。最后一个代表年份的域非必须,可省略。单个域有多个取值时,使用半角逗号,隔开取值。每个域可以是确定的取值,也可以是具有逻辑意义的特殊字符。每个域最多支持一个前导零。
cron表达式格式:
{秒数} {分钟} {小时} {日期} {月份} {星期} {年份(可为空)}
cron
表达式分为七个域,之间使用空格分隔。其中最后一个域(年)可以为空。每个域都有自己允许的值和一些特殊字符构成。使用这些特殊字符可以使我们定义的表达式更加灵活。
下面是对这些特殊字符的介绍:
逗号(,):指定一个值列表,例如使用在月域上1,4,5,7表示1月、4月、5月和7月
横杠(-):指定一个范围,例如在时域上3-6表示3点到6点(即3点、4点、5点、6点)
星号(*):表示这个域上包含所有合法的值。例如,在月份域上使用星号意味着每个月都会触发
斜线(/):表示递增,例如使用在秒域上0/15表示每15秒
问号(?):只能用在日和周域上,但是不能在这两个域上同时使用。表示不指定
井号(#):只能使用在周域上,用于指定月份中的第几周的哪一天,例如6#3,意思是某月的第三个周五 (6=星期五,3意味着月份中的第三周)
L:某域上允许的最后一个值。只能使用在日和周域上。当用在日域上,表示的是在月域上指定的月份的最后一天。用于周域上时,表示周的最后一天,就是星期六
W:W 字符代表着工作日 (星期一到星期五),只能用在日域上,它用来指定离指定日的最近的一个工作日
cron表达式在线生成器: http://cron.qqe2.com/
4.0.0 org.example quartz_demo 1.0-SNAPSHOT war quartz_demo Maven Webapp http://www.example.com UTF-8 1.8 1.8 org.springframework spring-context 5.0.2.RELEASE org.springframework spring-context-support 5.0.2.RELEASE org.springframework spring-tx 5.0.2.RELEASE org.springframework spring-web 5.0.2.RELEASE org.quartz-scheduler quartz 2.2.1 org.quartz-scheduler quartz-jobs 2.2.1 org.slf4j slf4j-simple 1.7.25 test
0/10 * * * * ?
Archetype Created Web Application contextConfigLocation classpath*:spring*.xml org.springframework.web.context.ContextLoaderListener
import org.springframework.context.support.ClassPathXmlApplicationContext;public class APP {public static void main(String[] args) {new ClassPathXmlApplicationContext("spring-jobs.xml");}
}
在1.2
小节Quartz
的使用场景中,我们已经描述了我们的需求,需要定时清除七牛云服务器上无用的照片资源。
我们使用redis
已经存储了上传到七牛云服务器上的照片名称集合SETMEAL_PIC_RESOURCES
,如下所示:
我们使用redis
已经存储了插入到数据库中的照片名称集合SETMEAL_PIC_DB_RESOURCES
,如下所示:
那么集合 SETMEAL_PIC_RESOURCES
和 SETMEAL_PIC_DB_RESOURCES
的差值即为需要在云服务器上清除的照片。
4.0.0 org.example health_parent 1.0-SNAPSHOT org.example health_jobs 1.0-SNAPSHOT war health_jobs Maven Webapp http://www.example.com UTF-8 1.8 1.8 org.example health_interface 1.0-SNAPSHOT org.quartz-scheduler quartz org.quartz-scheduler quartz-jobs org.apache.tomcat.maven tomcat7-maven-plugin 2.2 83 /
/*** 自定义Job,实现定时清理垃圾图片*/
public class ClearImgJob {@Autowiredprivate JedisPool jedisPool;public void clearImg(){//根据Redis中保存的两个set集合进行差值计算,获得垃圾图片名称集合Set set = jedisPool.getResource().sdiff(RedisConstant.SETMEAL_PIC_RESOURCES, RedisConstant.SETMEAL_PIC_DB_RESOURCES);if(set != null){for (String picName : set) {//删除七牛云服务器上的图片QiniuUtils.deleteFileFromQiniu(picName);//从Redis集合中删除图片名称jedisPool.getResource().srem(RedisConstant.SETMEAL_PIC_RESOURCES,picName);System.out.println(new Date());System.out.println("已经删除图片:" + picName);}}}
}
200 50
0/15 * * * * ?
Archetype Created Web Application contextConfigLocation classpath*:applicationContext*.xml org.springframework.web.context.ContextLoaderListener
成功进行2
次新增套餐,新增成功的图片名称保存在setmealPicDbResources
, 在redis
中显示如下:
添加图片后,进行4
次取消,新增失败和成功的图片名称保存在setmealPicResources
,在redis
中显示如下:
查看七牛云服务器发现,无论套餐是否新增成功,图片都成功上传到了七牛云服务器中,这样就造成了资源的浪费,如下图所示:
运行health_jobs
模块,开启定时清理垃圾图片,有运行结果可知未插入到数据库中的图片已经被删除。
刷新,再次查看七牛云服务器进行验证,发现已经删除成功。