分布式调度框架Quartz衍生出的三种任务类型,你用过几个?

知识改变命运,撸码使我快乐,2019年你的发迹线还好吗?

点赞再看,养成习惯

本篇文章对应源码码云(Gitee)仓库

https://gitee.com/minbox-projects/api-boot-chapter,您的Star是给我最大动力

前言

Quartz内部没有明确的任务类型的概念,在ApiBoot中对其进行封装后才确切的定义了这个概念,可以根据业务场景按需选择适合的任务类型来构建执行的任务。

系列文章

ApiBoot Quartz是以系列文章的形式更新,了解更多使用方法请访问如下链接:

ApiBoot内其他组件系列使用文章请访问:ApiBoot开源框架各个组件的系列使用文章汇总

衍生的任务类型

ApiBootQuartz集成封装后,提供了如下三种的任务类型:

  • OnceJob:一次性任务,仅执行一次
  • CronJob:使用Cron表达式定义任务周期
  • LoopJob:指定循环次数的任务

注意事项:任务类型是任务的执行方式类型,并不是创建任务的类型,创建任务都是通过继承QuartzJobBean来完成,同一个任务可以使用不同的类型执行。

演示项目

我们使用Idea创建一个SpringBoot项目,用于我们本章的演示项目,创建项目后添加ApiBoot Quartz相关的依赖到pom.xml文件内,如下所示:

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <!--ApiBoot Quartz-->
  <dependency>
    <groupId>org.minbox.framework</groupId>
    <artifactId>api-boot-starter-quartz</artifactId>
  </dependency>
</dependencies>
<dependencyManagement>
  <dependencies>
    <dependency>
      <groupId>org.minbox.framework</groupId>
      <artifactId>api-boot-dependencies</artifactId>
      <version>2.2.1.RELEASE</version>
      <type>pom</type>
      <scope>import</scope>
    </dependency>
  </dependencies>
</dependencyManagement>

示例任务

我们来创建一个本章演示所需要的任务类,如下所示:

/**
 * 示例任务
 *
 * @author 恒宇少年
 */
public class DemoJob extends QuartzJobBean {
    /**
     * logger instance
     */
    static Logger logger = LoggerFactory.getLogger(DemoJob.class);

    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        logger.info("这是一个示例任务,执行时间:{}", System.currentTimeMillis());
    }
}

当任务执行时就会在控制台输出任务执行的时间,继承自Spring提供的封装任务类QuartzJobBean,会自动扫描到DemoJob并通过反射创建实例后放入Ioc容器,具体的流程可以访问 这种方式整合Quartz你见过吗? 了解详情。

一次性任务

我们使用Once任务类型来执行上面创建的DemoJob示例任务,先上代码,如下所示:

/**
  * ApiBoot Quartz内置接口
  *
  * @see org.minbox.framework.api.boot.plugin.quartz.support.ApiBootQuartzServiceDefaultSupport
  */
@Autowired
private ApiBootQuartzService quartzService;

// 创建Once任务
quartzService.newJob(ApiBootOnceJobWrapper.Context().jobClass(DemoJob.class).wrapper());

我们只需要一行代码就可以来定义一个新的任务,在代码中出现了一个新面孔 ApiBootOnceJobWrapper

ApiBootOnceJobWrapper主要工作是来封装Once类型任务所需要的配置字段,内部通过Lombok提供的@Builder注解来实现,Once任务可配置的内容如下所示:

方法 默认值 描述
.jobClass(Class<? extends QuartzJobBean> jobClass) - 配置所执行的QuartzJobBean实现类类型
.jobKey(String jobKey) 随机UUID字符串 任务唯一key
.startAtTime(Date startAtTime) 当前时间 任务开始执行时间
.param(ApiBootJobParamWrapper param) - 任务执行时的参数列表封装对象

Cron表达式任务

Cron表达式来创建任务是比较灵活的,也是比较常用的方式,使用ApiBoot Quartz同样仅仅需要一行代码就可以实现,下面我们来定义每间隔一秒执行一次DemoJob内的任务逻辑,如下所示:

/**
  * ApiBoot Quartz内置接口
  *
  * @see org.minbox.framework.api.boot.plugin.quartz.support.ApiBootQuartzServiceDefaultSupport
  */
@Autowired
private ApiBootQuartzService quartzService;
// 创建Cron任务
quartzService.newJob(ApiBootCronJobWrapper.Context().jobClass(DemoJob.class).cron("0/1 * * * * ?").wrapper());

ApiBootCronJobWrapper 所做的工作与ApiBootOnceJobWrapper其实是一样的,都是用来采集Cron类型的任务所需要的配置字段,内部同样是通过Lombok提供的@Builder注解实现,Cron类型任务可配置的内容如下所示:

方法 默认值 描述
.jobClass(Class<? extends QuartzJobBean> jobClass) - 配置所执行的QuartzJobBean实现类类型
.jobKey(String jobKey) 随机UUID字符串 任务唯一key
.cron(String cron) - 任务执行时间的Cron表达式
.param(ApiBootJobParamWrapper param) - 任务执行时的参数列表封装对象

Loop循环任务

Loop类型的任务在开发中也是比较常用的,根据指定的循环次数以及每一次执行的间隔时间运行定时任务逻辑,当获取到期望的结果后还可以将任务自身进行删除,先来看看一个简单例子:

/**
  * ApiBoot Quartz内置接口
  *
  * @see org.minbox.framework.api.boot.plugin.quartz.support.ApiBootQuartzServiceDefaultSupport
  */
@Autowired
private ApiBootQuartzService quartzService;
// 创建Loop任务
quartzService.newJob(ApiBootLoopJobWrapper.Context().jobClass(DemoJob.class).loopIntervalTime(2000).repeatTimes(5).wrapper());

上面的定时任务会先执行1次后每间隔2000毫秒再执行5次,一共是执行6次,大家注意配置。

可以看到Loop类型的任务也提供了一个 ApiBootLoopJobWrapper 来封装任务执行所需要的配置字段,可配置的字段方法如下所示:

方法 默认值 描述
.jobClass(Class<? extends QuartzJobBean> jobClass) - 配置所执行的QuartzJobBean实现类类型
.jobKey(String jobKey) 随机UUID字符串 任务唯一key
.loopIntervalTime(int intervalTime) 1000 循环执行的间隔时间,单位:毫秒
.repeatTimes(int times) 0 循环执行次数
.startAtTime(Date startAtTime) 当前时间 任务开始执行时间
.param(ApiBootJobParamWrapper param) - 任务执行时的参数列表封装对象

如果不设置repeatTimes仅执行一次,效果与Once一样。

运行测试

在运行项目之前先来修改项目的XxxApplication入口类,我们期望在项目启动完成后就执行任务,那么我们直接实现CommandLineRunner接口来完成这一需求,如下所示:

/**
 * ApiBoot Quartz 三种任务类型示例
 */
@SpringBootApplication
public class ApibootQuartzJobTypesApplication implements CommandLineRunner {

    public static void main(String[] args) {
        SpringApplication.run(ApibootQuartzJobTypesApplication.class, args);
    }

    /**
     * ApiBoot Quartz内置接口
     *
     * @see org.minbox.framework.api.boot.plugin.quartz.support.ApiBootQuartzServiceDefaultSupport
     */
    @Autowired
    private ApiBootQuartzService quartzService;

    @Override
    public void run(String... args) throws Exception {
        // 一次性任务
        quartzService.newJob(ApiBootOnceJobWrapper.Context().jobClass(DemoJob.class).wrapper());

        // 循环执行任务,每隔2000毫秒执行一次,循环5次,一共执行6次
        quartzService.newJob(ApiBootLoopJobWrapper.Context().jobClass(DemoJob.class).loopIntervalTime(2000).repeatTimes(5).wrapper());

        // Cron表达式任务,间隔1秒执行一次
        quartzService.newJob(ApiBootCronJobWrapper.Context().jobClass(DemoJob.class).cron("0/1 * * * * ?").wrapper());
    }
}

启动项目后我们可以在控制台看到有任务执行时间输出,如下所示:

2019-12-24 14:56:05.046  INFO 3113 --- [eduler_Worker-1] o.minbox.chapter.apiboot.quartz.DemoJob  : 这是一个示例任务,执行时间:1577170565046
2019-12-24 14:56:05.046  INFO 3113 --- [eduler_Worker-2] o.minbox.chapter.apiboot.quartz.DemoJob  : 这是一个示例任务,执行时间:1577170565046
2019-12-24 14:56:05.047  INFO 3113 --- [eduler_Worker-3] o.minbox.chapter.apiboot.quartz.DemoJob  : 这是一个示例任务,执行时间:1577170565047
2019-12-24 14:56:06.005  INFO 3113 --- [eduler_Worker-4] o.minbox.chapter.apiboot.quartz.DemoJob  : 这是一个示例任务,执行时间:1577170566005
2019-12-24 14:56:07.002  INFO 3113 --- [eduler_Worker-5] o.minbox.chapter.apiboot.quartz.DemoJob  : 这是一个示例任务,执行时间:1577170567002
2019-12-24 14:56:07.042  INFO 3113 --- [eduler_Worker-6] o.minbox.chapter.apiboot.quartz.DemoJob  : 这是一个示例任务,执行时间:1577170567042
2019-12-24 14:56:08.003  INFO 3113 --- [eduler_Worker-7] o.minbox.chapter.apiboot.quartz.DemoJob  : 这是一个示例任务,执行时间:1577170568003
...

虽然任务已经执行了,但是由于是多种执行方式同时执行同一个任务,我们不好做出区分,针对这个问题可以使用ApiBoot Quartz提供的参数来解决。

敲黑板,划重点

ApiBoot Quartz所提供的功能已经可以满足日常开发所需要,而且比较灵活,可以通过ApiBoot Quartz提供的Wrapper封装类的方法进行自定义配置,任务的执行是子线程异步操作,不需要考虑会影响访问响应的效率问题

代码示例

如果您喜欢本篇文章请为源码仓库点个Star,谢谢!!!
本篇文章示例源码可以通过以下途径获取,目录为apiboot-quartz-job-types

作者个人 博客
使用开源框架 ApiBoot 助你成为Api接口服务架构师

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 219,589评论 6 508
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,615评论 3 396
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 165,933评论 0 356
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,976评论 1 295
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,999评论 6 393
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,775评论 1 307
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,474评论 3 420
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,359评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,854评论 1 317
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,007评论 3 338
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,146评论 1 351
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,826评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,484评论 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,029评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,153评论 1 272
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,420评论 3 373
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,107评论 2 356

推荐阅读更多精彩内容