SpringBoot整合Quartz定时框架

妖狐艹你老母 2021-09-29 12:10 373阅读 0赞

1.pom.xml

<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>  
    <parent>  
        <groupId>org.springframework.boot</groupId>  
        <artifactId>spring-boot-starter-parent</artifactId>  
        <version>1.5.10.RELEASE</version>  
    </parent>  
    <groupId>com.bjsxt</groupId>  
    <artifactId>spring-boot-quartz</artifactId>  
    <version>0.0.1-SNAPSHOT</version>

<properties>  
        <java.version>1.7</java.version>  
        <thymeleaf.version>3.0.2.RELEASE</thymeleaf.version>  
        <thymeleaf-layout-dialect.version>2.0.4</thymeleaf-layout-dialect.version>  
    </properties>

<dependencies>  
          
        <dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-starter-web</artifactId>  
        </dependency>  
          
        <dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-starter-thymeleaf</artifactId>  
        </dependency>

<dependency>  
            <groupId>org.quartz-scheduler</groupId>  
            <artifactId>quartz</artifactId>  
            <version>2.2.1</version>  
            <exclusions>  
                <exclusion>  
                    <artifactId>slf4j-api</artifactId>  
                    <groupId>org.slf4j</groupId>  
                </exclusion>  
            </exclusions>  
        </dependency>

<dependency>  
            <groupId>org.springframework</groupId>  
            <artifactId>spring-context-support</artifactId>  
        </dependency>

<dependency>  
            <groupId>org.springframework</groupId>  
            <artifactId>spring-tx</artifactId>  
        </dependency>  
    </dependencies>  
</project>

2.编写Quartz配置类

package com.bjsxt.config;

import org.quartz.SchedulerFactory;  
import org.springframework.context.annotation.Bean;  
import org.springframework.context.annotation.Configuration;  
import org.springframework.scheduling.quartz.CronTriggerFactoryBean;  
import org.springframework.scheduling.quartz.JobDetailFactoryBean;  
import org.springframework.scheduling.quartz.SchedulerFactoryBean;  
import org.springframework.scheduling.quartz.SimpleTriggerFactoryBean;

import com.bjsxt.quartz.QuartzDemo;

/\*\*  
 \* Quartz配置类  
 \*  
 \*  
 \*/  
@Configuration  
public class QuartzConfig \{

/\*\*  
     \* 1.创建Job对象  
     \*/  
    @Bean  
    public JobDetailFactoryBean jobDetailFactoryBean()\{  
        JobDetailFactoryBean factory = new JobDetailFactoryBean();  
        //关联我们自己的Job类  
        factory.setJobClass(QuartzDemo.class);  
        return factory;  
    \}  
      
    /\*\*  
     \* 2.创建Trigger对象  
     \* 简单的Trigger  
     \*/  
    /\*@Bean  
    public SimpleTriggerFactoryBean simpleTriggerFactoryBean(JobDetailFactoryBean jobDetailFactoryBean)\{  
        SimpleTriggerFactoryBean factory = new SimpleTriggerFactoryBean();  
        //关联JobDetail对象  
        factory.setJobDetail(jobDetailFactoryBean.getObject());  
        //该参数表示一个执行的毫秒数  
        factory.setRepeatInterval(2000);  
        //重复次数  
        factory.setRepeatCount(5);  
        return factory;  
    \}\*/  
      
    /\*\*  
     \* Cron Trigger  
     \*/  
    @Bean  
    public CronTriggerFactoryBean cronTriggerFactoryBean(JobDetailFactoryBean jobDetailFactoryBean)\{  
        CronTriggerFactoryBean factory = new CronTriggerFactoryBean();  
        factory.setJobDetail(jobDetailFactoryBean.getObject());  
        //设置触发时间  
        factory.setCronExpression("0/2 \* \* \* \* ?");  
        return factory;  
    \}  
      
    /\*\*  
     \* 3.创建Scheduler对象  
     \*/  
    @Bean  
    public SchedulerFactoryBean schedulerFactoryBean(CronTriggerFactoryBean cronTriggerFactoryBean,MyAdaptableJobFactory myAdaptableJobFactory)\{  
        SchedulerFactoryBean factory = new SchedulerFactoryBean();  
        //关联trigger  
        factory.setTriggers(cronTriggerFactoryBean.getObject());  
        factory.setJobFactory(myAdaptableJobFactory);  
        return factory;  
    \}  
\}

3.调用定时任务

package com.bjsxt.quartz;

import java.util.Date;  
import org.quartz.Job;  
import org.quartz.JobExecutionContext;  
import org.quartz.JobExecutionException;  
import org.springframework.beans.factory.annotation.Autowired;

import com.bjsxt.service.UsersService;

/\*\*  
 \* Job类  
 \*  
 \*  
 \*/  
public class QuartzDemo implements Job \{  
      
    @Autowired  
    private UsersService usersService;  
      
    @Override  
    public void execute(JobExecutionContext arg0) throws JobExecutionException \{  
        System.out.println("Execute...."+new Date());  
        this.usersService.addUsers();  
    \}  
\}

4.启动类

package com.bjsxt;

import org.springframework.boot.SpringApplication;  
import org.springframework.boot.autoconfigure.SpringBootApplication;  
import org.springframework.scheduling.annotation.EnableScheduling;

/\*\*  
 \*   
 \*spring Boot 整合Quartz案例  
 \*  
 \*/  
@SpringBootApplication  
@EnableScheduling  
public class App \{

public static void main(String\[\] args) \{  
        SpringApplication.run(App.class, args);  
    \}  
\}  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW8yOTczMjg_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW8yOTczMjg_size_16_color_FFFFFF_t_70]: /images/20210923/43fa1fc80db64cbf817c76a42c760094.png