定时任务 Scheduled quartz

在项目应用中往往会用到任务定时器的功能，比如某某时间，或者多少多少秒然后执行某个骚操作等。
spring 支持多种定时任务的实现，其中不乏自身提供的定时器。
接下来介绍一下使用 spring 的定时器和使用 quartz 定时器。

前言

spring 自身提供了定时任务，为什么还要使用 quartz 呢？

使用 spring 自带的定时任务可以很简单很方便的完成一些简单的定时任务，没错，这里提到的是简单，因此我们想动态的执行我们的定时任务是非常困难的。然而使用 quartz 却可以很容易的管理我们的定时任务，很容易动态的操作定时任务。

1、 使用spring的定时器

spring 自带支持定时器的任务实现，其可通过简单配置来使用到简单的定时任务。

@Component
@Configurable
@EnableScheduling
public class ScheduledTasks{/*** 方式一* 每6秒执行一次**/@Scheduled(fixedRate = 6000)public void reportCurrentByCron(){System.out.println ("Scheduling Tasks Examples By Cron: The time is now " + dateFormat ().format (new Date ()));}/*** 方式二* 每6秒执行一次**/@Scheduled(cron = "*/6 * *  * * * ")public void reportCurrentByCron(){System.out.println ("Scheduling Tasks Examples By Cron: The time is now " + dateFormat ().format (new Date ()));}}
参数说明

@Scheduled 参数可以接受两种定时的设置，一种是我们常用的 cron="/6 * * * ?"，一种是 fixedRate = 6000，两种都可表示固定周期执行定时任务。

fixedRate说明

  • @Scheduled(fixedRate = 6000)：上一次开始执行时间点之后 6 秒再执行。
  • @Scheduled(fixedDelay = 6000)：上一次执行完毕时间点之后 6 秒再执行。
  • @Scheduled(initialDelay=1000, fixedRate=6000)：第一次延迟 1 秒后执行，之后按 fixedRate 的规则每 6 秒执行一次。

cron说明

cron 一定有七位数，最后一位是年，SpringBoot 定时方案只需要设置六位即可:

  • 第一位, 表示秒, 取值是0 ~ 59
  • 第二位, 表示分. 取值是0 ~ 59
  • 第三位, 表示小时, 取值是0 ~ 23
  • 第四位, 表示天/日, 取值是0 ~ 31
  • 第五位, 表示月份, 取值是1 ~ 12
  • 第六位, 表示星期, 取值是1 ~ 7, 星期一，星期二…， 还有 1 表示星期日
  • 第七位, 年份, 可以留空, 取值是1970 ~ 2099

cron中,还有一些特殊的符号,含义如下:

  • (*) 星号，可以理解为每的意思，每秒、每分、每天、每月、每年…。
  • (?) 问号，问号只能出现在日期和星期这两个位置，表示这个位置的值不确定，每天 3 点执行，因此第六位星期的位置，是不需要关注的，就是不确定的值；同时，日期和星期是两个相互排斥的元素，通过问号来表明不指定值，比如 1 月 10 日是星期一，如果在星期的位置另指定星期二，就前后冲突矛盾了。
  • (-) 减号，表达一个范围，如在小时字段中使用“10 - 12”，则表示从 10 到 12 点，即 10、11、12。
  • (,) 逗号，表达一个列表值，如在星期字段中使用“1,2,4”，则表示星期一、星期二、星期四。
  • (/) 斜杠，如 x/y，x 是开始值，y 是步长，比如在第一位（秒），0/15 就是从 0 秒开始，每隔 15 秒执行一次，最后就是 0、15、30、45、60，另 */y，等同于 0/y。

举几个例子熟悉一下:

  • 0 0 3 * * ? ：每天 3 点执行；
  • 0 5 3 * * ? ：每天 3 点 5 分执行；
  • 0 5 3 ? * * ：每天 3 点 5 分执行，与上面作用相同；
  • 0 5/10 3 * * ?：每天 3 点的 5 分、15 分、25 分、35 分、45 分、55分这几个时间点执行；
  • 0 10 3 ? * 1：每周星期天，3 点 10 分执行，注，1 表示星期天；
  • 0 10 3 ? * 1#3：每个月的第三个星期，星期天执行，# 号只能出现在星期的位置。

ok，spring的定时器就像如上这么简单，涉及到的几个注解：

@EnableScheduling：标注启动定时任务。         
@Scheduled：  定义某个定时任务。

2、使用quartz实现定时任务

quartz 的设计者做了一个设计选择来从调度分离开作业。
quartz 中的触发器用来告诉调度程序作业什么时候触发，框架提供了一把触发器类型，但两个最常用的是 SimpleTrigger 和 CronTrigger。

SimpleTrigger 为需要简单打火调度而设计。典型地，如果你需要在给定的时间和重复次数或者两次打火之间等待的秒数打火一个作业，那么SimpleTrigger适合你。

另一方面，如果你有许多复杂的作业调度，那么或许需要CronTrigger。

什么是复杂调度？

当你需要在除星期六和星期天外的每天上午10点半执行作业时，那么应该使用CronTrigger。正如它的名字所暗示的那样，CronTrigger是基于Unix克隆表达式的。

开始之前需要了解的几个概念：

  • Job：是一个接口，只定义一个方法 execute（JobExecutionContext context），在实现接口的 execute 方法中编写所需要定时执行的 Job（任务），JobExecutionContext 类提供了调度应用的一些信息；Job 运行时的信息保存在 JobDataMap 实例中。
  • JobDetail：Quartz 每次调度 Job 时，都重新创建一个 Job 实例，因此它不接受一个 Job 的实例，相反它接收一个 Job 实现类（JobDetail，描述 Job 的实现类及其他相关的静态信息，如 Job 名字、描述、关联监听器等信息），以便运行时通过 newInstance() 的反射机制实例化 Job。
  • Trigger：是一个类，描述触发 Job 执行的时间触发规则，主要有 SimpleTrigger 和 CronTrigger 这两个子类，上边刚刚有提到。当且仅当需调度一次或者以固定时间间隔周期执行调度，SimpleTrigger 是最适合的选择；而 CronTrigger 则可以通过 Cron 表达式定义出各种复杂时间规则的调度方案：如工作日周一到周五的 15：00 ~ 16：00 执行调度等。
  • Scheduler：调度器就相当于一个容器，装载着任务和触发器，该类是一个接口，代表一个 Quartz 的独立运行容器，Trigger 和 JobDetail 可以注册到 Scheduler 中，两者在 Scheduler 中拥有各自的组及名称，组及名称是 Scheduler 查找定位容器中某一对象的依据，Trigger 的组及名称必须唯一，JobDetail 的组和名称也必须唯一（但可以和 Trigger 的组和名称相同，因为它们是不同类型的）。Scheduler 定义了多个接口方法，允许外部通过组及名称访问和控制容器中 Trigger 和 JobDetail。

上边的四个概念，建议通读一遍，结合下方代码，思路更清晰。

SpringBoot2.x 之后，完成了对 Quartz 自动化配置集成，省去了很多繁琐的配置，下面进入正题吧。

2.1、引入依赖
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

2.2、yml配置

spring:quartz:# 任务信息存储至？MEMORY（内存方式：默认）、JDBC（数据库方式）job-store-type: jdbcproperties:org:quartz:jobStore:misfireThreshold: 100

2.3、用于增删改查定时任务的Controller

/*** @author niceyoo*/
@Slf4j
@RestController
@Api(description = "定时任务管理接口")
@RequestMapping("/tmax/quartzJob")
public class TmaxQuartzJobController {/*** 定时任务service*/@Autowiredprivate QuartzJobService quartzJobService;/*** 调度器*/@Autowiredprivate Scheduler scheduler;@RequestMapping(value = "/add", method = RequestMethod.POST)@ApiOperation(value = "添加定时任务")public Result<Object> addJob(@ModelAttribute QuartzJob job){add(job.getJobClassName(),job.getCronExpression(),job.getParameter());quartzJobService.save(job);return new ResultUtil<Object>().setSuccessMsg("创建定时任务成功");}@RequestMapping(value = "/edit", method = RequestMethod.POST)@ApiOperation(value = "更新定时任务")public Result<Object> editJob(@ModelAttribute QuartzJob job){delete(job.getJobClassName());add(job.getJobClassName(),job.getCronExpression(),job.getParameter());job.setStatus(CommonConstant.STATUS_NORMAL);quartzJobService.update(job);return new ResultUtil<Object>().setSuccessMsg("更新定时任务成功");}@RequestMapping(value = "/pause", method = RequestMethod.POST)@ApiOperation(value = "暂停定时任务")public Result<Object> pauseJob(@ModelAttribute QuartzJob job){try {scheduler.pauseJob(JobKey.jobKey(job.getJobClassName()));} catch (SchedulerException e) {throw new TmaxException("暂停定时任务失败");}job.setStatus(CommonConstant.STATUS_DISABLE);quartzJobService.update(job);return new ResultUtil<Object>().setSuccessMsg("暂停定时任务成功");}@RequestMapping(value = "/resume", method = RequestMethod.POST)@ApiOperation(value = "恢复定时任务")public Result<Object> resumeJob(@ModelAttribute QuartzJob job){try {scheduler.resumeJob(JobKey.jobKey(job.getJobClassName()));} catch (SchedulerException e) {throw new TmaxException("恢复定时任务失败");}job.setStatus(CommonConstant.STATUS_NORMAL);quartzJobService.update(job);return new ResultUtil<Object>().setSuccessMsg("恢复定时任务成功");}@RequestMapping(value = "/delByIds/{ids}", method = RequestMethod.DELETE)@ApiOperation(value = "删除定时任务")public Result<Object> deleteJob(@PathVariable String[] ids){for(String id:ids){QuartzJob job = quartzJobService.get(id);delete(job.getJobClassName());quartzJobService.delete(job);}return new ResultUtil<Object>().setSuccessMsg("删除定时任务成功");}/*** 添加定时任务* @param jobClassName* @param cronExpression* @param parameter*/public void add(String jobClassName, String cronExpression, String parameter){try {//启动调度器scheduler.start();//构建job信息JobDetail jobDetail = JobBuilder.newJob(getClass(jobClassName).getClass()).withIdentity(jobClassName).usingJobData("parameter", parameter).build();//表达式调度构建器(即任务执行的时间) 使用withMisfireHandlingInstructionDoNothing() 忽略掉调度暂停过程中没有执行的调度CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression).withMisfireHandlingInstructionDoNothing();//按新的cronExpression表达式构建一个新的triggerCronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobClassName).withSchedule(scheduleBuilder).build();scheduler.scheduleJob(jobDetail, trigger);} catch (SchedulerException e) {log.error(e.toString());throw new TmaxException("创建定时任务失败");} catch (Exception e){throw new TmaxException("后台找不到该类名任务");}}/*** 删除定时任务* @param jobClassName*/public void delete(String jobClassName){try {scheduler.pauseTrigger(TriggerKey.triggerKey(jobClassName));scheduler.unscheduleJob(TriggerKey.triggerKey(jobClassName));scheduler.deleteJob(JobKey.jobKey(jobClassName));} catch (Exception e) {throw new TmaxException("删除定时任务失败");}}public static Job getClass(String classname) throws Exception {Class<?> class1 = Class.forName(classname);return (Job)class1.newInstance();}}
2.4、Job执行的任务类
@Slf4j
public class SampleJob implements Job {@Overridepublic void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {log.info(String.format("打印时间:"+ DateUtil.now()));}
}

4小步代码看完后，我们再来分析一波 quartz 的4个核心概念，先脑补一张图。

主要看 TmaxQuartzJobController 的 add() 方法

  • Job 为作业的接口，为任务调度的对象，在代码中体现为 <SampleJob.java>，代码中是由用户传递过来的类绝对路径；
  • JobDetail 用来描述 Job 的实现类及其他相关的静态信息，可以看到代码中通过 JobBuilder 的静态方法 newJob(Class jobClass) 生成 JobBuilder 实例，其中 jobClass 的获取采用反射机制；
  • Trigger 做为作业的定时管理工具，一个 Trigger 只能对应一个作业实例，而一个作业实例可对应多个触发器，代码中采用的是 CronTrigger，通过表达式调度构建器构建任务的执行时间，注意，任务的执行时间是由前台传递过来的 cron 表达式，然后按新的 cronExpression 表达式构建一个新的 trigger，TriggerBuilder.newTrigger().withIdentity(jobClassName) 表达了一个 Trigger 只能对应一个作业实例；
  • Scheduler 做为定时任务容器，是 Quartz 最上层的东西，它提携了所有触发器和作业，使它们协调工作，每个 Scheduler 都存有 JobDetail 和 Trigger 的注册，一个 Scheduler 中可以注册多个 JobDetail 和多个 Trigger。

最后，调用 Controller 层的任务添加方法 /add 完成全部，效果如下：

2019-05-23 00:38:38.455  INFO 19856 --- [eduler_Worker-1] club.sscai.tmax.quartz.jobs.SampleJob   : 打印时间:2019-05-24 09:38:38
2019-05-23 00:38:39.035  INFO 19856 --- [eduler_Worker-2] club.sscai.tmax.quartz.jobs.SampleJob   : 打印时间:2019-05-24 09:38:39
2019-05-23 00:38:40.752  INFO 19856 --- [eduler_Worker-3] club.sscai.tmax.quartz.jobs.SampleJob   : 打印时间:2019-05-24 09:38:40
2019-05-23 00:38:41.033  INFO 19856 --- [eduler_Worker-4] club.sscai.tmax.quartz.jobs.SampleJob   : 打印时间:2019-05-24 09:38:41
2019-05-23 00:38:42.640  INFO 19856 --- [eduler_Worker-5] club.sscai.tmax.quartz.jobs.SampleJob   : 打印时间:2019-05-24 09:38:42
2019-05-23 00:38:43.023  INFO 19856 --- [eduler_Worker-6] club.sscai.tmax.quartz.jobs.SampleJob   : 打印时间:2019-05-24 09:38:43

习惯在微信看技术文章，想要获取更多的Java资源的同学，可以关注微信公众号：niceyoo

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/414438.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

前端学习（2792）：下拉刷新

前端学习（2792）：下拉刷新

开启下拉刷新 延迟下拉刷新 解决下拉刷新 传递callback有就刷新 无就不刷新
阅读更多...
前端学习（2793）：完成联系我们页面和地图

前端学习（2793）：完成联系我们页面和地图

直接定义地图的样式
阅读更多...
Android 获取短信验证码，自动填充

Android 获取短信验证码，自动填充

1、申请权限 <uses-permission android:name"android.permission.RECEIVE_SMS" /> <uses-permission android:name"android.permission.READ_SMS" /> API>23动态申请权限 private static final String[] authBaseArr {//申请类型Manife…
阅读更多...
前端学习（2794）：实现拨打电话功能

前端学习（2794）：实现拨打电话功能

阅读更多...
前端学习（2795）：实现样式的左侧结构和样式

前端学习（2795）：实现样式的左侧结构和样式

阅读更多...
前端学习（2796）：实现左侧数据渲染和点击高亮

前端学习（2796）：实现左侧数据渲染和点击高亮

阅读更多...
spring-boot-starter-parent

spring-boot-starter-parent

一、你的项目 pom.xml 中有这段代码吗 <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.5.RELEASE</version><relativePath/> </parent>idea &…
阅读更多...
前端学习（2798）：实现图片预览的效果

前端学习（2798）：实现图片预览的效果

阅读更多...
项目集成Spring Security

项目集成Spring Security

前言 之前写的 涂涂影院管理系统 这个 demo 是基于 shiro 来鉴权的&#xff0c;项目前后端分离后&#xff0c;显然集成 Spring Security 更加方便一些&#xff0c;毕竟&#xff0c;都用 Spring 了&#xff0c;权限管理当然 Spring Security. 花了半天时间整理的笔记&#xff0…
阅读更多...
前端学习（2799）：实现资讯的结构和列表

前端学习（2799）：实现资讯的结构和列表

阅读更多...
android 使用AIDL实现进程间通讯

android 使用AIDL实现进程间通讯

一、创建服务端 1、首先创建AIDL文件 2、创建service&#xff0c;绑定AIDL接口 3、配置service <service android:name".AidlService"android:enabled"true"android:exported"true"><intent-filter android:priority"1000"&…
阅读更多...
大数据入门第二十天——scala入门（二）scala基础02

大数据入门第二十天——scala入门（二）scala基础02

一、 类、对象、继承、特质 1.类 Scala的类与Java、C的类比起来更简洁 定义&#xff1a; package com.jiangbei //在Scala中&#xff0c;类并不用声明为public。 //Scala源文件中可以包含多个类&#xff0c;所有这些类都具有公有可见性。 class Person {// 定义一个不可变的val…
阅读更多...
前端学习（2800）：实现news-item的封装

前端学习（2800）：实现news-item的封装

阅读更多...
SpringSecurity 整合 JWT

SpringSecurity 整合 JWT

项目集成Spring Security&#xff08;一&#xff09; 在上一篇基础上继续集成 JWT &#xff0c;实现用户身份验证。 前言 前后端分离项目中&#xff0c;如果直接把 API 接口对外开放&#xff0c;我们知道这样风险是很大的&#xff0c;所以在上一篇中我们引入了 Spring Securit…
阅读更多...
前端学习（2801）：传递id

前端学习（2801）：传递id

阅读更多...
Spring Security 认证执行流程

Spring Security 认证执行流程

本文基于 Spring Security 5.x 推荐阅读&#xff1a; 项目集成Spring Security SpringSecurity 整合 JWT 一、外层-正常登陆调用 项目启动后会自动寻找 UserDetailsService 实现类&#xff1b; 执行 UserDetailsService 的唯一方法 loadUserByName(String username) 并返回…
阅读更多...
ScrollView嵌套ViewPager，ViewPage动态设置高度，嵌套事件冲突——滑动冲突解决方法

ScrollView嵌套ViewPager，ViewPage动态设置高度，嵌套事件冲突——滑动冲突解决方法

1、创建自定义ViewPager public class ViewPagerForScrollView extends ViewPager {int myh0 ;boolean ifme false;public ViewPagerForScrollView(Context context) {super(context);Log.i("lgq","高度111 " );}public ViewPagerForScrollView(Context c…
阅读更多...
centos7下python3与python2共存并且开启py3虚拟环境

centos7下python3与python2共存并且开启py3虚拟环境

因为下载视频需要用到python3环境&#xff0c;今天在我的win上安装下载工具死活安装不上去&#xff0c;在大盘鸡上一下就安装成功了...可能在win上不兼容吧...无奈只能在大盘鸡上进行折腾了&#xff0c;顺便几个笔记 由于大盘鸡上好多程序基于python2的&#xff0c;所以就没法直…
阅读更多...
前端学习（2802）：完成资讯页面详情

前端学习（2802）：完成资讯页面详情

阅读更多...
前端学习（2803）：点击商品列表导航到商品详情页

前端学习（2803）：点击商品列表导航到商品详情页

阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023