初识Quartz（一）

时间：2023-12-24 20:55:19

首先需要一个任务：

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 quartz_project;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
 * 一个简单的任务：打印Hello World
 *
 * @author caijw
 */
public class HelloJob implements Job {
     
    private static Logger _log = LoggerFactory.getLogger(HelloJob.class);
    @Override
    public void execute(JobExecutionContext ctx) throws JobExecutionException {
        //打印Hello World! - 当前日期
        _log.info("Hello World! - " + new Date());
    }
}

由上面代码可以看出，任务类要实现job接口，在execute方法中是任务的具体实现。

然后设定调度策略：

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
package quartz_project;
import java.util.Date;
import org.quartz.DateBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
 * 该例子将：
 * 1. 展示何如开始和结束quartz的调用器（scheduler），
 * 2. 展示在quartz中，调度器是如何运行作业（job）的。
 * 
 * @author caijw
 */
public class SimpleExample {
    public void run() throws Exception {
        Logger log = LoggerFactory.getLogger(SimpleExample.class);
         
        log.info("----- Initializing --------");
        //第一步我们必须获取一个调度器
        SchedulerFactory sf = new StdSchedulerFactory();
        Scheduler sched = sf.getScheduler();
         
        log.info("----- Initialization complete -------");
         
        //作业的执行时间（这里需要注意，下面详细说明）
        Date runTime = DateBuilder.evenMinuteDate(new Date());
         
        log.info("----- scheduling job --------");
         
        //创建一项作业
        JobDetail job = JobBuilder.newJob(HelloJob.class)
            .withIdentity("job1", "group1")
            .build();
         
        //创建一个触发器
        Trigger trigger = TriggerBuilder.newTrigger()
            .withIdentity("trigger1", "group1")
            .startAt(runTime).build(); //该触发器将在runTime时执行作业
         
        //告诉调度器使用该触发器来安排作业
        sched.scheduleJob(job, trigger);
        log.info(job.getKey() + " will run at: " + runTime);
         
        sched.start();//启动调度器
        log.info("------ started scheduler -------");
         
        log.info("------ waiting 65 seconds ------");
        try {
            Thread.sleep(65L * 1000L);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
         
        log.info("------- shutting down ------");
        sched.shutdown();//关闭调度器
         
        log.info("------- shutdown complete -------");
    }
}

注意：

1. Date runTime = DateBuilder.evenMinuteDate(new Date()); //当前时间的下一分钟

假如JVM在执行到这一句时，时间为17：23：22，那么runTime就是17：24：00

DateBuilder类似的方法：

初识Quartz（一）

2. 并不是把Job的实例注册到Scheduler中，而是JobDetail的实例。

3. Scheduler 实例被关闭之后你就不能调用它的 start() 方法了。这是因为 shutdown() 方法销毁了为 Scheduler 创建的所有的资源(线程，数据库连接等)。假如你在 shutdown() 之后调用 start()你将收到 SchedulerException 的异常。

4. Job 的实例要到该执行它们的时候才会实例化出来。每次 Job 被执行，一个新的 Job 实例会被创建（延迟加载的思想）。所以Job 不必担心线程安全性，因为同一时刻仅有一个线程去执行给定 Job 类的实例，甚至是并发执行同一 Job 也是如此。

Maven的配置文件：

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
<project xmlns="http://maven.apache.org/POM/4.0.0" 
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
                             http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>quartz_project</groupId>
    <artifactId>quartz_project</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>
    <name>quartz_project</name>
    <url>http://maven.apache.org</url>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.6.1</version>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.16</version>
        </dependency>
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.1.1</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.10</version>
            <scope>test</scope>
        </dependency>
    </dependencies>
     
</project>

单元测试类：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
package quartz_project;
import org.junit.Test;
/**
 * 单元测试
 * 
 * @author caijw
 */
public class SimpleExampleTest {
    @Test
    public void testRun() throws Exception {
        SimpleExample example = new SimpleExample();
        example.run();
    }
}

执行结果分析：

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
79
80
81
82
-------------------------------------------------------
 T E S T S
-------------------------------------------------------
Running quartz_project.SimpleExampleTest
[INFO] 25 一月 07:26:16.359 下午 main [quartz_project.SimpleExample]
----- Initializing --------
[INFO] 25 一月 07:26:16.437 下午 main [org.quartz.impl.StdSchedulerFactory]
Using default implementation for ThreadExecutor
[INFO] 25 一月 07:26:16.437 下午 main [org.quartz.simpl.SimpleThreadPool]
Job execution threads will use class loader of thread: main
[INFO] 25 一月 07:26:16.468 下午 main [org.quartz.core.SchedulerSignalerImpl]
Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl
[INFO] 25 一月 07:26:16.468 下午 main [org.quartz.core.QuartzScheduler]
Quartz Scheduler v.2.1.1 created.
[INFO] 25 一月 07:26:16.468 下午 main [org.quartz.simpl.RAMJobStore]
RAMJobStore initialized.
[INFO] 25 一月 07:26:16.468 下午 main [org.quartz.core.QuartzScheduler]
Scheduler meta-data: Quartz Scheduler (v2.1.1) 'DefaultQuartzScheduler' with instanceId 'NON_CLUSTERED'
  Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
  NOT STARTED.
  Currently in standby mode.
  Number of jobs executed: 0
  Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 10 threads.
  Using job-store 'org.quartz.simpl.RAMJobStore' - which does not support persistence. and is not clustered.
[INFO] 25 一月 07:26:16.468 下午 main [org.quartz.impl.StdSchedulerFactory]
Quartz scheduler 'DefaultQuartzScheduler' initialized from default resource file in Quartz package: 'quartz.properties'
[INFO] 25 一月 07:26:16.468 下午 main [org.quartz.impl.StdSchedulerFactory]
Quartz scheduler version: 2.1.1
[INFO] 25 一月 07:26:16.468 下午 main [quartz_project.SimpleExample]
----- Initialization complete -------
[INFO] 25 一月 07:26:16.484 下午 main [quartz_project.SimpleExample]
----- scheduling job --------
[INFO] 25 一月 07:26:16.500 下午 main [quartz_project.SimpleExample]
group1.job1 will run at: Sat Jan 25 19:27:00 CST 2014
[INFO] 25 一月 07:26:16.500 下午 main [org.quartz.core.QuartzScheduler]
Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED started.
[INFO] 25 一月 07:26:16.500 下午 main [quartz_project.SimpleExample]
------ started scheduler -------
[INFO] 25 一月 07:26:16.500 下午 main [quartz_project.SimpleExample]
------ waiting 65 seconds ------
[INFO] 25 一月 07:26:19.703 下午 Timer-0 [org.quartz.utils.UpdateChecker]
New Quartz update(s) found: 2.1.7 [http://www.terracotta.org/kit/reflector?kitID=default&pageID=QuartzChangeLog]
[INFO] 25 一月 07:27:00.031 下午 DefaultQuartzScheduler_Worker-1 [quartz_project.HelloJob]
Hello World! - Sat Jan 25 19:27:00 CST 2014
[INFO] 25 一月 07:27:21.500 下午 main [quartz_project.SimpleExample]
------- shutting down ------
[INFO] 25 一月 07:27:21.500 下午 main [org.quartz.core.QuartzScheduler]
Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED shutting down.
[INFO] 25 一月 07:27:21.500 下午 main [org.quartz.core.QuartzScheduler]
Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED paused.
[INFO] 25 一月 07:27:21.500 下午 main [org.quartz.core.QuartzScheduler]
Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED shutdown complete.
[INFO] 25 一月 07:27:21.500 下午 main [quartz_project.SimpleExample]
------- shutdown complete -------
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 65.39 sec
Results :

相关文章