您的位置:首页 > 编程语言 > Java开发

springboot实现任务调度的第三种方式------使用第三方quartz插件调度(springBoot+quartz+cronTrigger进行任务调度)

2019-10-11 20:27 435 查看
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。 本文链接:https://blog.csdn.net/m0_45294725/article/details/102509613

本案例使用IDEA创建的maven的web项目。
任务调度三要素:任务类、触发器、调度器

步骤一:在pom.xml文件中导入依赖

<!--声明springboot版本-->
<parent><!--注意该标签不在<dependencies>中-->
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.4.5.RELEASE</version>
<relativePath/>
</parent>

<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>

</dependency>
<!-- mvc,aop的依赖包 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<!-- 由于我们在上面指定了parent,这里就不需要指定版本号 -->
</dependency>

<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jstl</artifactId>
</dependency>
<!--tomcat-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-tomcat</artifactId>
</dependency>

<dependency>
<groupId>org.apache.tomcat.embed</groupId>
<artifactId>tomcat-embed-jasper</artifactId>
</dependency>
<!--mybatis-->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.41</version>
</dependency>
<!-- 阿里巴巴的Druid数据库连接池 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.9</version>
</dependency>
<!--pageHelper分页插件-->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>4.0.0</version>
</dependency>
<!--quartz依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.3</version>
</dependency>

</dependencies>

步骤二:在resources下创建application.yml配置数据库信息

#application.yml文件对格式要求很严,下面每一个空格都要对齐。application.yml用于读取定义sql语句的文件和配置数据库信息
spring:
datasource:
name: dataSource
type: com.alibaba.druid.pool.DruidDataSource
#druid相关配置,数据库配置
druid:
#监控统计拦截的filters
filters: stat
driver-class-name: com.mysql.jdbc.Driver
#基本属性
url: jdbc:mysql://localhost:3306/day06
username: root
password: root
#配置初始化大小/最小/最大
initial-size: 1
min-idle: 1
max-active: 20
#获取连接等待超时时间
max-wait: 60000
#间隔多久进行一次检测,检测需要关闭的空闲连接
time-between-eviction-runs-millis: 60000
#一个连接在池中最小生存的时间
min-evictable-idle-time-millis: 300000

#配置mabatis文件,扫描定义sql语句的文件,即扫描mapper下的所有xml文件
mybatis:
mapper-locations: classpath:mapper/*.xml

#这是给包起别名的
#type-aliases-package: com.qf.bean

步骤三:创建任务类

将该类命名为:QuartzJob

package com.qf.util;

import org.springframework.stereotype.Component;

import java.util.Date;

@Component//Component给当前类创建对象,为了让它们自动调用,自动执行(这就叫自动装配?)。
// 这就是为什么之用运行执行类,关联类就能自动执行的原因。我们写完对象创建的注解,底层自动执行
public class QuartzJob {
public void  abc(){
System.out.println("任务aa:"+new Date());
}
}

步骤四:创建配置工具类,用于创建任务类、触发器、调度器

该案例将该类命名为:QuartzConfig
注意:mijd、triggerFactoryBean这两个参数爆红不影响运行

package com.qf.util;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.CronTriggerFactoryBean;
import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;

//配置quartz的工具类
@Configuration
public class QuartzConfig {
//1、创建任务类。固定用法。告诉quartz框架去执行哪个任务
@Bean//Bean将component创建的类对象进行注入。就如同@Resources给属性注入一样
public MethodInvokingJobDetailFactoryBean  a1(QuartzJob job){
MethodInvokingJobDetailFactoryBean factoryBean=new MethodInvokingJobDetailFactoryBean();
factoryBean.setTargetObject(job);//QuartzJob是包含要执行任务的类
factoryBean.setTargetMethod("abc");//abc代表包含要执行任务的方法名。//此处调成了setStaticMethod()方法花了一小时找错。
return factoryBean;
}
//2、创建触发器。告诉quartz框架多久执行一次任务
@Bean
public CronTriggerFactoryBean b1(MethodInvokingJobDetailFactoryBean mijd){//返回一个CronTriggerFactoryBean对象
CronTriggerFactoryBean factoryBean = new CronTriggerFactoryBean();
factoryBean.setJobDetail(mijd.getObject());
factoryBean.setCronExpression("0/5 * * * * ?");
return factoryBean;
}

//3、创建调度器。告诉quartz框架返回什么对象
@Bean//
public SchedulerFactoryBean c1(CronTriggerFactoryBean triggerFactoryBean){
SchedulerFactoryBean factoryBean=new SchedulerFactoryBean();
factoryBean.setTriggers(triggerFactoryBean.getObject());
return factoryBean;
}
}

本案例框架结构图:

本案例运行结果:

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: