Java quartz定时任务

时间:2022-09-28 奔跑的毛球人气:0

正文

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

就稍微研究了一下，来做个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());
    }
}

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

当然也可以启动定时任务查询三方的返回结果，之前做车抵贷业务的风控系统的时候，请求了三方的数据，主动请求然后定时任务轮询结果。

现在看来，用消息队列实现也是很每秒，延时消息刚好可以满足这个业务需求，请求数据然后向消息队列中放入一个延时消息，时间到了，去请求结果，若是没好，就再往消息队列中放入一个延时消息。这样相对于定时任务的好处是，避免了CPU空转，提升了性能。

加载全部内容