springboot动态配置定时任务2种方式

Dear 丶 2022-04-17 03:25 438阅读 0赞

//定时任务使用  
compile group: 'org.quartz-scheduler', name: 'quartz', version: '2.3.0'  
compile group: 'org.springframework', name: 'spring-context-support', version: '4.3.11.RELEASE'  
方式一在项目启动类上添加启动schedule注解，采用的是串行的方式执行定时任务

@Controller  
@EnableScheduling  
@SpringBootApplication  
public class LxybootApplication extends SpringBootServletInitializer \{  
采用是cron的配置方式  秒/分/时/日/月周的配置顺序，下面定时任务的意思是说1分钟执行一次  
@Component  
public class ScheduleJobs \{  
    public final static long SECOND = 1 \* 1000;  
    private UserService userService = SpringContextHelper.getBean("userService");

@Scheduled(cron = "0 0/1 \* \* \* ?")  
    public void cronJob() \{  
        User user = new User();  
        user.setName("lisi");  
        System.out.println("执行爬取任务查询会员lisi："+userService.getUser(user));  
        HttpExecute.sendGet("http://www.chinawutong.com");  
    \}

\}  
方式二采用线程池可直接修改数据库完成动态更改定时任务的执行间隔  
package com.lxy;  
import com.lxy.config.springs.AutowiringSpringBeanJobFactory;  
import com.lxy.tasks.CronJob;  
import com.lxy.utils.PropertiesHander;  
import org.apache.commons.dbcp.BasicDataSource;  
import org.quartz.JobDetail;  
import org.quartz.Trigger;  
import org.quartz.spi.JobFactory;  
import org.springframework.beans.factory.annotation.Qualifier;  
import org.springframework.beans.factory.config.PropertiesFactoryBean;  
import org.springframework.context.ApplicationContext;  
import org.springframework.context.annotation.Bean;  
import org.springframework.context.annotation.Configuration;  
import org.springframework.core.io.ClassPathResource;  
import org.springframework.scheduling.quartz.CronTriggerFactoryBean;  
import org.springframework.scheduling.quartz.JobDetailFactoryBean;  
import org.springframework.scheduling.quartz.SchedulerFactoryBean;  
import javax.sql.DataSource;  
import java.io.IOException;  
import java.util.Properties;

@Configuration  
public class QuartzConfiguration \{

@Bean(destroyMethod = "close")  
    public DataSource dataSource() \{  
        BasicDataSource dataSource = new BasicDataSource();  
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");  
        String url = PropertiesHander.getPropertiesValue("quartzdata.url");  
        String username = PropertiesHander.getPropertiesValue("quartzdata.username");  
        String password = PropertiesHander.getPropertiesValue("quartzdata.password");  
        dataSource.setUrl(url);  
        dataSource.setUsername(username);  
        dataSource.setPassword(password);  
        dataSource.setMaxActive(100);  
        dataSource.setInitialSize(1);  
        dataSource.setMaxWait(60000);  
        dataSource.setMaxIdle(15);  
        dataSource.setMinIdle(5);  
        dataSource.setTestOnBorrow(true);//解决link faile  
        dataSource.setValidationQuery("SELECT 1");  
        dataSource.setRemoveAbandoned(true);  
        dataSource.setRemoveAbandonedTimeout(180);  
        return dataSource;  
    \}

@Bean  
    public JobFactory jobFactory(ApplicationContext applicationContext) \{  
        AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory();  
        jobFactory.setApplicationContext(applicationContext);  
        return jobFactory;  
    \}

@Bean  
    public Properties quartzProperties() throws IOException \{  
        PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();  
        propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));  
        propertiesFactoryBean.afterPropertiesSet();  
        return propertiesFactoryBean.getObject();  
    \}  
    /\*\*这是一组定时任务A   开始\*/  
    @Bean(name = "cronJob")  
    public JobDetailFactoryBean creatptdataBetDayJob() \{  
        JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();  
        factoryBean.setJobClass(CronJob.class);  
        factoryBean.setName(CronJob.class.getName());  
        factoryBean.setGroup("cronmygroup");  
        factoryBean.setDurability(true);  
        return factoryBean;  
    \}

@Bean(name = "cronJobTrigger")  
    public CronTriggerFactoryBean cronptdatajobTriggerFactoryBean(@Qualifier("cronJob") JobDetail jobDetail)\{  
        CronTriggerFactoryBean stFactory = new CronTriggerFactoryBean();  
        stFactory.setJobDetail(jobDetail);  
        stFactory.setStartDelay(3000);  
        stFactory.setName("crontrigger");  
        stFactory.setGroup("cronmygroup");  
        String express = PropertiesHander.getPropertiesValue("cron.job.cron.express");  
        stFactory.setCronExpression(express);  
        return stFactory;  
    \}

@Bean  
    public SchedulerFactoryBean ptdatajobSchedulerFactoryBean(DataSource dataSource, JobFactory jobFactory, @Qualifier("cronJobTrigger") Trigger sampleJobTrigger) throws IOException \{  
        SchedulerFactoryBean factory = new SchedulerFactoryBean();  
        factory.setOverwriteExistingJobs(true);  
        factory.setJobFactory(jobFactory);  
        factory.setDataSource(dataSource);  
        factory.setQuartzProperties(quartzProperties());  
        factory.setTriggers(sampleJobTrigger);  
        return factory;  
    \}  
    /\*\*这是一组定时任务A   结束\*/  
\}下面是配置quartz.properties的内容  
org.quartz.scheduler.instanceName=DefaultQuartzScheduler  
org.quartz.scheduler.instanceId=AUTO  
org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool  
org.quartz.threadPool.threadCount: 10  
org.quartz.threadPool.threadPriority: 5  
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: false  
org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX  
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate  
org.quartz.jobStore.useProperties=true  
org.quartz.jobStore.misfireThreshold=60000  
org.quartz.jobStore.tablePrefix=QRTZ\_  
org.quartz.scheduler.rmi.export: false  
org.quartz.scheduler.rmi.proxy: false  
org.quartz.jobStore.isClustered=true  
org.quartz.jobStore.clusterCheckinInterval=20000  
具体的定时任务业务执行 类CronJob  
public class CronJob  extends QuartzJobBean \{  
    private UserService userService = SpringContextHelper.getBean("userService");  
    public static  final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

@Override  
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException \{  
        User selectObj =new User();  
        selectObj.setName("lisi");  
        User user = userService.getUser(selectObj);  
        System.out.println("执行定时任务开始----"+sdf.format(new Date())+user.getId()+"\*----\*"+user.getName());  
    \}  
\}  
下面是定时任务线程池自动插入数据所需要的数据库表结构qrtz\_blob\_triggers.sql  
/\*  
Navicat MySQL Data Transfer

Source Server         : 127.0.0.1  
Source Server Version : 50546  
Source Host           : 127.0.0.1:3306  
Source Database       : hs\_job

Target Server Type    : MYSQL  
Target Server Version : 50546  
File Encoding         : 65001

Date: 2017-10-04 09:51:25  
\*/

SET FOREIGN\_KEY\_CHECKS=0;

\-- ----------------------------  
\-- Table structure for qrtz\_blob\_triggers  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_blob\_triggers\`;  
CREATE TABLE \`qrtz\_blob\_triggers\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`TRIGGER\_NAME\` varchar(200) NOT NULL,  
  \`TRIGGER\_GROUP\` varchar(200) NOT NULL,  
  \`BLOB\_DATA\` blob,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`TRIGGER\_NAME\`,\`TRIGGER\_GROUP\`),  
  KEY \`SCHED\_NAME\` (\`SCHED\_NAME\`,\`TRIGGER\_NAME\`,\`TRIGGER\_GROUP\`),  
  CONSTRAINT \`QRTZ\_BLOB\_TRIGGERS\_ibfk\_1\` FOREIGN KEY (\`SCHED\_NAME\`, \`TRIGGER\_NAME\`, \`TRIGGER\_GROUP\`) REFERENCES \`qrtz\_triggers\` (\`SCHED\_NAME\`, \`TRIGGER\_NAME\`, \`TRIGGER\_GROUP\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_calendars  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_calendars\`;  
CREATE TABLE \`qrtz\_calendars\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`CALENDAR\_NAME\` varchar(200) NOT NULL,  
  \`CALENDAR\` blob NOT NULL,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`CALENDAR\_NAME\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_cron\_triggers  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_cron\_triggers\`;  
CREATE TABLE \`qrtz\_cron\_triggers\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`TRIGGER\_NAME\` varchar(200) NOT NULL,  
  \`TRIGGER\_GROUP\` varchar(200) NOT NULL,  
  \`CRON\_EXPRESSION\` varchar(120) NOT NULL,  
  \`TIME\_ZONE\_ID\` varchar(80) DEFAULT NULL,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`TRIGGER\_NAME\`,\`TRIGGER\_GROUP\`),  
  CONSTRAINT \`QRTZ\_CRON\_TRIGGERS\_ibfk\_1\` FOREIGN KEY (\`SCHED\_NAME\`, \`TRIGGER\_NAME\`, \`TRIGGER\_GROUP\`) REFERENCES \`qrtz\_triggers\` (\`SCHED\_NAME\`, \`TRIGGER\_NAME\`, \`TRIGGER\_GROUP\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_fired\_triggers  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_fired\_triggers\`;  
CREATE TABLE \`qrtz\_fired\_triggers\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`ENTRY\_ID\` varchar(95) NOT NULL,  
  \`TRIGGER\_NAME\` varchar(200) NOT NULL,  
  \`TRIGGER\_GROUP\` varchar(200) NOT NULL,  
  \`INSTANCE\_NAME\` varchar(200) NOT NULL,  
  \`FIRED\_TIME\` bigint(13) NOT NULL,  
  \`SCHED\_TIME\` bigint(13) NOT NULL,  
  \`PRIORITY\` int(11) NOT NULL,  
  \`STATE\` varchar(16) NOT NULL,  
  \`JOB\_NAME\` varchar(200) DEFAULT NULL,  
  \`JOB\_GROUP\` varchar(200) DEFAULT NULL,  
  \`IS\_NONCONCURRENT\` varchar(1) DEFAULT NULL,  
  \`REQUESTS\_RECOVERY\` varchar(1) DEFAULT NULL,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`ENTRY\_ID\`),  
  KEY \`IDX\_QRTZ\_FT\_TRIG\_INST\_NAME\` (\`SCHED\_NAME\`,\`INSTANCE\_NAME\`),  
  KEY \`IDX\_QRTZ\_FT\_INST\_JOB\_REQ\_RCVRY\` (\`SCHED\_NAME\`,\`INSTANCE\_NAME\`,\`REQUESTS\_RECOVERY\`),  
  KEY \`IDX\_QRTZ\_FT\_J\_G\` (\`SCHED\_NAME\`,\`JOB\_NAME\`,\`JOB\_GROUP\`),  
  KEY \`IDX\_QRTZ\_FT\_JG\` (\`SCHED\_NAME\`,\`JOB\_GROUP\`),  
  KEY \`IDX\_QRTZ\_FT\_T\_G\` (\`SCHED\_NAME\`,\`TRIGGER\_NAME\`,\`TRIGGER\_GROUP\`),  
  KEY \`IDX\_QRTZ\_FT\_TG\` (\`SCHED\_NAME\`,\`TRIGGER\_GROUP\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_job\_details  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_job\_details\`;  
CREATE TABLE \`qrtz\_job\_details\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`JOB\_NAME\` varchar(200) NOT NULL,  
  \`JOB\_GROUP\` varchar(200) NOT NULL,  
  \`DESCRIPTION\` varchar(250) DEFAULT NULL,  
  \`JOB\_CLASS\_NAME\` varchar(250) NOT NULL,  
  \`IS\_DURABLE\` varchar(1) NOT NULL,  
  \`IS\_NONCONCURRENT\` varchar(1) NOT NULL,  
  \`IS\_UPDATE\_DATA\` varchar(1) NOT NULL,  
  \`REQUESTS\_RECOVERY\` varchar(1) NOT NULL,  
  \`JOB\_DATA\` blob,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`JOB\_NAME\`,\`JOB\_GROUP\`),  
  KEY \`IDX\_QRTZ\_J\_REQ\_RECOVERY\` (\`SCHED\_NAME\`,\`REQUESTS\_RECOVERY\`),  
  KEY \`IDX\_QRTZ\_J\_GRP\` (\`SCHED\_NAME\`,\`JOB\_GROUP\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_locks  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_locks\`;  
CREATE TABLE \`qrtz\_locks\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`LOCK\_NAME\` varchar(40) NOT NULL,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`LOCK\_NAME\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_paused\_trigger\_grps  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_paused\_trigger\_grps\`;  
CREATE TABLE \`qrtz\_paused\_trigger\_grps\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`TRIGGER\_GROUP\` varchar(200) NOT NULL,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`TRIGGER\_GROUP\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_scheduler\_state  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_scheduler\_state\`;  
CREATE TABLE \`qrtz\_scheduler\_state\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`INSTANCE\_NAME\` varchar(200) NOT NULL,  
  \`LAST\_CHECKIN\_TIME\` bigint(13) NOT NULL,  
  \`CHECKIN\_INTERVAL\` bigint(13) NOT NULL,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`INSTANCE\_NAME\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_simple\_triggers  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_simple\_triggers\`;  
CREATE TABLE \`qrtz\_simple\_triggers\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`TRIGGER\_NAME\` varchar(200) NOT NULL,  
  \`TRIGGER\_GROUP\` varchar(200) NOT NULL,  
  \`REPEAT\_COUNT\` bigint(7) NOT NULL,  
  \`REPEAT\_INTERVAL\` bigint(12) NOT NULL,  
  \`TIMES\_TRIGGERED\` bigint(10) NOT NULL,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`TRIGGER\_NAME\`,\`TRIGGER\_GROUP\`),  
  CONSTRAINT \`QRTZ\_SIMPLE\_TRIGGERS\_ibfk\_1\` FOREIGN KEY (\`SCHED\_NAME\`, \`TRIGGER\_NAME\`, \`TRIGGER\_GROUP\`) REFERENCES \`qrtz\_triggers\` (\`SCHED\_NAME\`, \`TRIGGER\_NAME\`, \`TRIGGER\_GROUP\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_simprop\_triggers  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_simprop\_triggers\`;  
CREATE TABLE \`qrtz\_simprop\_triggers\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`TRIGGER\_NAME\` varchar(200) NOT NULL,  
  \`TRIGGER\_GROUP\` varchar(200) NOT NULL,  
  \`STR\_PROP\_1\` varchar(512) DEFAULT NULL,  
  \`STR\_PROP\_2\` varchar(512) DEFAULT NULL,  
  \`STR\_PROP\_3\` varchar(512) DEFAULT NULL,  
  \`INT\_PROP\_1\` int(11) DEFAULT NULL,  
  \`INT\_PROP\_2\` int(11) DEFAULT NULL,  
  \`LONG\_PROP\_1\` bigint(20) DEFAULT NULL,  
  \`LONG\_PROP\_2\` bigint(20) DEFAULT NULL,  
  \`DEC\_PROP\_1\` decimal(13,4) DEFAULT NULL,  
  \`DEC\_PROP\_2\` decimal(13,4) DEFAULT NULL,  
  \`BOOL\_PROP\_1\` varchar(1) DEFAULT NULL,  
  \`BOOL\_PROP\_2\` varchar(1) DEFAULT NULL,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`TRIGGER\_NAME\`,\`TRIGGER\_GROUP\`),  
  CONSTRAINT \`QRTZ\_SIMPROP\_TRIGGERS\_ibfk\_1\` FOREIGN KEY (\`SCHED\_NAME\`, \`TRIGGER\_NAME\`, \`TRIGGER\_GROUP\`) REFERENCES \`qrtz\_triggers\` (\`SCHED\_NAME\`, \`TRIGGER\_NAME\`, \`TRIGGER\_GROUP\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

\-- ----------------------------  
\-- Table structure for qrtz\_triggers  
\-- ----------------------------  
DROP TABLE IF EXISTS \`qrtz\_triggers\`;  
CREATE TABLE \`qrtz\_triggers\` (  
  \`SCHED\_NAME\` varchar(120) NOT NULL,  
  \`TRIGGER\_NAME\` varchar(200) NOT NULL,  
  \`TRIGGER\_GROUP\` varchar(200) NOT NULL,  
  \`JOB\_NAME\` varchar(200) NOT NULL,  
  \`JOB\_GROUP\` varchar(200) NOT NULL,  
  \`DESCRIPTION\` varchar(250) DEFAULT NULL,  
  \`NEXT\_FIRE\_TIME\` bigint(13) DEFAULT NULL,  
  \`PREV\_FIRE\_TIME\` bigint(13) DEFAULT NULL,  
  \`PRIORITY\` int(11) DEFAULT NULL,  
  \`TRIGGER\_STATE\` varchar(16) NOT NULL,  
  \`TRIGGER\_TYPE\` varchar(8) NOT NULL,  
  \`START\_TIME\` bigint(13) NOT NULL,  
  \`END\_TIME\` bigint(13) DEFAULT NULL,  
  \`CALENDAR\_NAME\` varchar(200) DEFAULT NULL,  
  \`MISFIRE\_INSTR\` smallint(2) DEFAULT NULL,  
  \`JOB\_DATA\` blob,  
  PRIMARY KEY (\`SCHED\_NAME\`,\`TRIGGER\_NAME\`,\`TRIGGER\_GROUP\`),  
  KEY \`IDX\_QRTZ\_T\_J\` (\`SCHED\_NAME\`,\`JOB\_NAME\`,\`JOB\_GROUP\`),  
  KEY \`IDX\_QRTZ\_T\_JG\` (\`SCHED\_NAME\`,\`JOB\_GROUP\`),  
  KEY \`IDX\_QRTZ\_T\_C\` (\`SCHED\_NAME\`,\`CALENDAR\_NAME\`),  
  KEY \`IDX\_QRTZ\_T\_G\` (\`SCHED\_NAME\`,\`TRIGGER\_GROUP\`),  
  KEY \`IDX\_QRTZ\_T\_STATE\` (\`SCHED\_NAME\`,\`TRIGGER\_STATE\`),  
  KEY \`IDX\_QRTZ\_T\_N\_STATE\` (\`SCHED\_NAME\`,\`TRIGGER\_NAME\`,\`TRIGGER\_GROUP\`,\`TRIGGER\_STATE\`),  
  KEY \`IDX\_QRTZ\_T\_N\_G\_STATE\` (\`SCHED\_NAME\`,\`TRIGGER\_GROUP\`,\`TRIGGER\_STATE\`),  
  KEY \`IDX\_QRTZ\_T\_NEXT\_FIRE\_TIME\` (\`SCHED\_NAME\`,\`NEXT\_FIRE\_TIME\`),  
  KEY \`IDX\_QRTZ\_T\_NFT\_ST\` (\`SCHED\_NAME\`,\`TRIGGER\_STATE\`,\`NEXT\_FIRE\_TIME\`),  
  KEY \`IDX\_QRTZ\_T\_NFT\_MISFIRE\` (\`SCHED\_NAME\`,\`MISFIRE\_INSTR\`,\`NEXT\_FIRE\_TIME\`),  
  KEY \`IDX\_QRTZ\_T\_NFT\_ST\_MISFIRE\` (\`SCHED\_NAME\`,\`MISFIRE\_INSTR\`,\`NEXT\_FIRE\_TIME\`,\`TRIGGER\_STATE\`),  
  KEY \`IDX\_QRTZ\_T\_NFT\_ST\_MISFIRE\_GRP\` (\`SCHED\_NAME\`,\`MISFIRE\_INSTR\`,\`NEXT\_FIRE\_TIME\`,\`TRIGGER\_GROUP\`,\`TRIGGER\_STATE\`),  
  CONSTRAINT \`QRTZ\_TRIGGERS\_ibfk\_1\` FOREIGN KEY (\`SCHED\_NAME\`, \`JOB\_NAME\`, \`JOB\_GROUP\`) REFERENCES \`qrtz\_job\_details\` (\`SCHED\_NAME\`, \`JOB\_NAME\`, \`JOB\_GROUP\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;