Quartz任务调度器

背景：
              近期项目中遇到跨区调拨商品的需求，比如A区和B区，需要判断A区或者B区某种sku是否需要从对方库调拨商品来补充货源，避免因缺失商品而出现订单延误，影响销售和对用户产生不良影响。

问题：
             数据量庞大，如果当查看的时候去获取数据，那么会严重影响系统的性能，甚至导致数据库和应用服务器无法响应。

解决方案：
            规定在某个时间点，最好是在晚上12点时系统自动获取需要调拨的数据，然后将数据存储到数据库中。晚上12点，用户访问量和系统的其它工作最少，这个时候启动一个定时线程来获取数据对系统的影响几乎没有。

采用技术：
         Quartz，Quartz是一个开源的作业调度框架，它完全由Java写成，并设计用于J2SE和J2EE应用中。它提供了巨大的灵活性而不牺牲简单性。可以使用这个框架来完成定时任务的调度。

使用步骤：
          1、编写业务处理模块。
                      该模块针对本需求，首先获取近期需要调度的sku列表，这是比较耗时的，因为需要查看近20天的
 进销存记录并统计发货数量。

其次判断发货量是否满足某种条件（条件为业务内容，条件准备比较复杂）来进行补货，当满足时，查看其它库区同种sku是否满足调拨条件。
                      再次记录两库的日均发货量。
当上述条件满足时，生成数据，如果不满足则跳过，进行下一个sku判断，直到所有sku处理完毕。
 
 Demo:
 业务处理模块：

?


1

2

3

4

5

6

7

8

package com.tgb.test;

public class BusinessJob {

    public void generateBusinessInfo(){

        System.out.println("业务数据产生完毕！");

    }

}

定时任务模块：

?


1

2

3

4

5

6

7

8

9

10

11

12

13

14

package com.tgb.test;

import org.quartz.Job;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

public class TimeJob implements Job {   

    

    //重写方法

    public void execute(JobExecutionContext context)throws JobExecutionException { 

        BusinessJob businessJob = new BusinessJob(); 

        businessJob.generateBusinessInfo();

    } 

}

定时调度模块：

?


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

package com.tgb.test;

import org.quartz.CronTrigger;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.quartz.impl.StdSchedulerFactory;

public class JobSchedule {

    private static Scheduler scheduler = null;

    private static final Object lock = new Object();

    

    

    public static Scheduler getSchedulerInstance(){

        if(scheduler == null){

            synchronized(lock){

                if(scheduler == null){

                    try {

                        scheduler = StdSchedulerFactory.getDefaultScheduler();

                    } catch (SchedulerException e) {

                        return null;

                    }

                }

            }

        }

        return scheduler;

    }

    

    /**

     * 添加任务

     * @param jobName任务名称

     * @param jobGroup任务组名称

     * @param jobClass任务类对象

     * @param cronExpress定时调度表达式

     */

    public void addJob(String jobName, String jobGroup, Class<!--?--> jobClass, String cronExpress){

        

        try{

            JobDetail jobDetail = new JobDetail(jobName, jobGroup, jobClass); 

            //创建触发器对象，并为它设置名称，组名称，及任务调度的时间参数 

            CronTrigger cronTrigger = new CronTrigger("trigger1", "triggerGroup"); 

            

            cronTrigger.setCronExpression(cronExpress);

             //配置JobDetail和Trigger对象 

            JobSchedule.getSchedulerInstance().scheduleJob(jobDetail, cronTrigger);

        }catch(Exception e){

            throw new RuntimeException(e);

        }

    }

    

    /**

     * 启动调度器

     */

    public void startScheduler(){

        try{

            if(!JobSchedule.getSchedulerInstance().isStarted()){

                JobSchedule.getSchedulerInstance().start();

            }

        }catch(Exception e){

            throw new RuntimeException(e);

        }

    }

    

    

    /**

     * 停止调度器

     */

    public void stopScheduler(){

        try{

            if(JobSchedule.getSchedulerInstance().isStarted()){

                JobSchedule.getSchedulerInstance().shutdown(true);

            }

        }catch(Exception e){

            throw new RuntimeException(e);

        }

    }

}

主线程入口：

?


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

package com.tgb.test;

public class TestMain {

    /**

     * @param args

     */

    public static void main(String[] args) {

        

        //构造定时模块

        TimeJob timeJob = new TimeJob(); 

        

        //构造调度管理者

        JobSchedule jobSchedule = new JobSchedule();

        

        //添加job

        jobSchedule.addJob("jobName", "jobGroup", timeJob.getClass(), "0 0 23 * * ?");

        

        //启动调度器

        jobSchedule.startScheduler();

        

        //关闭调度器

//      jobSchedule.stopScheduler();

    }

}

控制台输出：

时间： 2024-10-14 04:34:13

Quartz任务调度器的相关文章

.NET中Quartz任务调度器的简单应用实例

1.首先从NuGet中安装Quartz,安装最新版本就OK 2.新建一个Job类实现Quart中的IJob接口用于执行业务逻辑,代码如下: class CheckUpdateJob : IJob { public async Task Execute(IJobExecutionContext context) { //在此处实现业务 } } 3.新建一个任务执行类用于启动任务,代码如下: class JobController { //调度器 IScheduler scheduler; //调度

任务调度器quartz的使用

1.quartz的获取. 可參照:Quartz任务调度模型实例 2.开发思路: 要使用定时器quartz.先弄清楚三个概念:调度器.任务.触发器.开发也是依照这三个方面来开发, 1>写一个Job的实现类.里面是你自己要完毕的业务逻辑: 2>写Trigger的实现类,主要有SimpleTrigger和CronTrigger这两个子类.来决定调度方案: 当仅需触发一次或者以固定时间间隔周期运行,SimpleTrigger是最适合的选择: 而CronTrigger则能够通过Cron表达式定义出各种复

quartz任务调度学习一

1.实现定时任务的几种方式: crontab 命令 + sql语句 python脚本 + sql语句 spring + JDK Timer spring + Quartz 2.Quartz概述: Quartz是java领域中最著名的定时任务调度工具,具有以下特性: 强大的调度功能 灵活的应用方式 负载均衡 高可用特性 易于spring集成 3.基础概念: Quartz 任务调度的核心元素是 scheduler, trigger 和 job,其中 trigger 和 job 是任务调度的元数据,

Quartz任务调度实践

最近在写一个任务调度程序,需要每隔几秒查询数据库,并取出数据做一些处理操作.使用到了Quartz任务调度框架. 基本概念 Quartz包含几个重要的对象,分别为任务(Job),触发器(Trigger),调度器(Scheduler) Job:一个接口只有一个方法void execute(),我们需要执行的任务就需要实现这个接口,在execute中实现我们要做的事情. JobDetail:在Quartz执行每次执行Job时,都需要创建一个Job实例,所以它直接接受一个实现类以便运行时实例化,还需要一

Quartz任务调度快速入门

Quartz任务调度快速入门 概述 了解Quartz体系结构 Quartz对任务调度的领域问题进行了高度的抽象,提出了调度器.任务和触发器这3个核心的概念,并在org.quartz通过接口和类对重要的这些核心概念进行描述: ●Job:是一个接口,只有一个方法void execute(JobExecutionContext context),开发者实现该接口定义运行任务,JobExecutionContext类提供了调度上下文的各种信息.Job运行时的信息保存在JobDataMap实例中: ●Jo

Quartz任务调度快速入门（转）

概述 了解Quartz体系结构 Quartz对任务调度的领域问题进行了高度的抽象,提出了调度器.任务和触发器这3个核心的概念,并在org.quartz通过接口和类对重要的这些核心概念进行描述: ●Job:是一个接口,只有一个方法void execute(JobExecutionContext context),开发者实现该接口定义运行任务,JobExecutionContext类提供了调度上下文的各种信息.Job运行时的信息保存在 JobDataMap实例中: ●JobDetail:Quartz

Quartz任务调度2

注意: 不同的版本的jar包,具体的操作不太相同,但是思路是相同的:比如1.8.6jar包中,JobDetail是个类,直接通过构造方法与Job类关联.SimpleTrigger和CornTrigger是类:在2.2.1jar包中,JobDetail是个接口,SimpleTrigger和CornTrigger是接口 mavan工程引入的包: ? 1 2 3 4 5 6 7 8 9 10 11 <!-- 任务调度器相关包 -->     <dependency>           

Quartz任务调度

注意: 不同的版本的jar包,具体的操作不太相同,但是思路是相同的:比如1.8.6jar包中,JobDetail是个类,直接通过构造方法与Job类关联.SimpleTrigger和CornTrigger是类:在2.2.1jar包中,JobDetail是个接口,SimpleTrigger和CornTrigger是接口 mavan工程引入的包: <!-- 任务调度器相关包 --> <dependency>             <groupId>org.quartz-sc

quartz任务调度初次使用记录

近期公司开发的数据交换系统嵌入了quartz任务调度功能,大概了解了任务调度的整个流程,项目中需要用到它来进行定时任务操作,对数据定时检查以及及时交换. Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它可以与J2EE与J2SE应用程序相结合也可以单独使用.Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个Jobs这样复杂的程序.Jobs可以做成标准的Java组件或 EJBs.Quartz的最新版本为Quartz 2.2.1. 任务调度