logo
搜索
我的图书馆

发文章

发文工具

其他工具

留言交流
搜索
分享

【原】spring boot 2.0 quartz 轻松实现定时任务和作业调度

 算法与编程之美 2020-08-08

https://blog.csdn.net/asd1098626303/article/details/80831114

最近在做一个彩票相关的项目，主要涉及到不定时开奖，不定时封盘，原本打算使用springboot 自带的Schedule进行这一系列的工作，由于不能自动的添加定时任务，所以使用quartz，spring boot 2.0集成了quartz，所以决定尝试下quartz用于实现作业调度。

 做的时候查看了很多资料，都写的花里胡哨的，要么就是做的东西太完整了，要么就是完全不能理解，要么就是很早以前的做法了，让人很头晕，所以说做个很简单明了的教程，说一下如何使用

https://docs./spring-boot/docs/2.0.3.RELEASE/reference/htmlsingle/#boot-features-quartz

 build.gradle:

uildscript {

       ext  {

              springBootVersion  = '2.0.3.RELEASE'

       }

       repositories  {

              maven{  url 'http://maven.aliyun.com/nexus/content/groups/public'}

       }

       dependencies  {

              classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")

       }

}

apply plugin: 'java'

apply plugin: 'idea'

apply plugin: 'org.springframework.boot'

apply plugin: 'io.spring.dependency-management'

group = 'com.zhu'

version = '0.0.1-SNAPSHOT'

sourceCompatibility = 1.8

repositories {

       maven{  url 'http://maven.aliyun.com/nexus/content/groups/public'}

}

dependencies {

       compile('org.springframework.boot:spring-boot-starter-web')

       compile('org.springframework.boot:spring-boot-starter-quartz')

       testCompile('org.springframework.boot:spring-boot-starter-test')

}

build.gradle中引入spring-boot-starter-quartz

之后如果没什么特殊需求的话，根本不需要任何的花里胡哨的配置，直接编码。

创建 ScheduleService.java，用于创建定时任务，这里动态的创建了两个定时任务，每隔1秒和每隔2秒运行。创建时需要新建JobDetail（任务）以及CronTrigger（定时任务触发器） ，并且scheduler.scheduleJob(jobDetail,cronTrigger);把任务添加到任务队列中。

package com.zhu.zqjc.schedule;

import  com.zhu.zqjc.bean.enums.FootballStatus;

import com.zhu.zqjc.dao.FootBallMatchDao;

import com.zhu.zqjc.entity.FootBallMatch;

import org.quartz.*;

import  org.springframework.beans.factory.annotation.Autowired;

import  org.springframework.stereotype.Service;

import org.springframework.web.bind.annotation.GetMapping;

import java.time.LocalDateTime;

import  java.time.format.DateTimeFormatter;

import java.util.List;

@Service

public class ScheduleService {

     @Autowired

     private Scheduler scheduler;

     public void testScheduleTask() throws SchedulerException {

         for (int i = 1; i < 3; i++) {

         JobDetail jobDetail = JobBuilder.newJob(TestSchedule.class)

                 .withIdentity("updateMatch"+i, "updateMatch")

                .withDescription("定时比赛Id为"+i)

                .build();

         //cron表达式 表示每隔i秒执行

         CronScheduleBuilder scheduleBuilder =  CronScheduleBuilder.cronSchedule(String.format("0/%d * * * * ?  ",i))

                .withMisfireHandlingInstructionDoNothing();

         CronTrigger cronTrigger = TriggerBuilder.newTrigger()

                 .withIdentity("updateMatch"+i, "updateMatch")

                .withDescription("定时比赛Id为"+i)

                 .withSchedule(scheduleBuilder)

                 .startNow().build();

         scheduler.scheduleJob(jobDetail,cronTrigger);

         }

     }

}

TestSchedule.java 定时任务的执行类，在executeInternal函数中执行定时任务的逻辑

package com.zhu.zqjc.schedule;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

import org.springframework.scheduling.quartz.QuartzJobBean;

public class TestSchedule  extends QuartzJobBean {

     /**

      * Execute the actual job. The job data map will already have been

      * applied as bean property values by execute. The contract is

      * exactly the same as for the standard Quartz execute method.

      *

      * @param context

      * @see #execute

      */

     @Override

     protected void executeInternal(JobExecutionContext context) throws  JobExecutionException {

         System.out.println("定时任务执行 " +  context.getJobDetail().getDescription());

     }

}

StartListen.java 执行定时任务

package com.zhu.zqjc.listener;

import  com.zhu.zqjc.bean.enums.FootballStatus;

import com.zhu.zqjc.conf.SystemConf;

import com.zhu.zqjc.dao.FootBallMatchDao;

import com.zhu.zqjc.entity.FootBallMatch;

import  com.zhu.zqjc.schedule.ScheduleService;

import com.zhu.zqjc.schedule.UpdateMatchSchedule;

import org.quartz.*;

import  org.springframework.beans.factory.annotation.Autowired;

import  org.springframework.beans.factory.annotation.Value;

import  org.springframework.boot.context.event.ApplicationReadyEvent;

import org.springframework.context.ApplicationListener;

import  org.springframework.stereotype.Component;

import weixin.popular.support.TokenManager;

import java.util.Arrays;

import java.util.List;

/**

 *  Created by zhu yingzhi on 2018/6/6.

 *  @author  yingzhi zhu

 *

 */

@Component

public class StartListen implements  ApplicationListener<ApplicationReadyEvent> {

     @Autowired

     private ScheduleService scheduleService;

     @Override

     public void onApplicationEvent(final ApplicationReadyEvent event) {

         try {

             scheduleService.testScheduleTask();

         } catch (Exception e) {

            e.printStackTrace();

         }

     }

}

运行效果：

拓展阅读：

深入理解遗传算法(一)

深入理解遗传算法(二)

从1到100求和学算法思维（一）

从1到100求和学算法思维（二）

从1到100求和学算法思维（三）

从1到100求和学算法思维（四）

从1到100求和学算法思维（五）

从1到100求和学算法思维（六）

 where2go 团队

微信号：算法与编程之美          

    转藏 分享 献花（0）

    来自： 算法与编程之美 > 《待分类》

    举报/认领

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多