Java使用quartz实现定时任务示例详解

Java quartz定时任务 Java quartz 2022-11-13 14:11:15 735人浏览独家记忆

Python 官方文档：入门教程 => 点击学习

摘要

目录正文配置文件pom定时任务和触发器定时任务的业务代码正文最近新到了一个项目，用到定时任务的地方是真滴多。就稍微研究了一下，来做个demo。其实定时任务使用很广泛也很方便，之

正文

最近新到了一个项目，用到定时任务的地方是真滴多。

就稍微研究了一下，来做个demo。

其实定时任务使用很广泛也很方便，之前做的人事管理项目，就会定期执行定时任务计算工资，对于一个saas服务来说，即时的计算所有员工的工资有点奢侈，所以在每周末计算一次就ok了。

国外有的公司是一周发一次工资，所以当时的逻辑是一周算一次。在国内就一月一次很ok了。在当时的report服务中，也是定时任务同步数据到Birt服务，然后展现数据。

现在的项目中使用的就更多了。把一些耗费性能的，数据即时性不强的都可以用定时任务在服务器负载不高的时候进行计算。比如半夜计算商城用户的积分，半夜计算银行用户行为产生的积分。银行系统半夜计算罚息复利等。都是定时任务很好的应用例子。

下来我们举一个列子来实现一个定时任务。

配置文件

sue.spring.quartz.cron=*/5 * * * * ?

pom

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

定时任务和触发器

package com.luke.demo.schedule;
import org.quartz.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class QuartzConfig {
    @Value("${sue.spring.quartz.cron}")
    private String testCron;
    
    @Bean
    public JobDetail quartzTestDetail() {
        JobDetail jobDetail = JobBuilder.newJob(QuartzTestJob.class)
                //添加认证信息
                .withIdentity("quartzTestDetail", "QUARTZ_TEST")
                .build();
        return jobDetail;
    }
    
    @Bean
    public Trigger quartzTestJobTrigger() {
        //执行频率
        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(testCron);
        //创建触发器
        Trigger trigger = TriggerBuilder.newTrigger()
                .forJob(quartzTestDetail())
                //添加认证信息
                .withIdentity("quartzTestJobTrigger", "QUARTZ_TEST_JOB_TRIGGER")
                //添加执行规则
                .withSchedule(cronScheduleBuilder)
                .build();
        return trigger;
    }
}

定时任务的业务代码

这里的QuartzTestJob如下，方法executeInternal里就是需要定时执行的任务。

public class QuartzTestJob extends QuartzJobBean {
    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        System.out.println("现在是"+ new Date());
    }
}

当项目启动起来之后，就会按照设定的频率输出如下：