Java怎么使用quartz实现定时任务

配置文件

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空转，提升了性能。

以上就是Java怎么使用quartz实现定时任务的详细内容，更多请关注Work网其它相关文章！