SpringBoot整合Quartz--持久化任务

╰+攻爆jí腚メ 2021-08-28 20:39 415阅读 0赞

#### 持久化任务 ####

依赖：

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
            <version>2.0.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.3.0</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>com.mchange</groupId>
            <artifactId>c3p0</artifactId>
            <version>0.9.5.2</version>
        </dependency>
    </dependencies>

quartz.properties:

#=======================================================
    #调度器配置
    #=======================================================
    org.quartz.scheduler.instanceId=AUTO
    org.quartz.scheduler.instanceName=project1QuartzScheduler
    org.quartz.scheduler.rmi.export=false
    org.quartz.scheduler.rmi.proxy=false
    #=======================================================
    #线程池配置
    #=======================================================
    org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
    org.quartz.threadPool.threadCount=5
    org.quartz.threadPool.threadPriority=5
    org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread=true
    #=======================================================
    #JobStore配置
    #=======================================================
    org.quartz.jobStore.misfireThreshold=60000
    org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
    org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
    org.quartz.jobStore.isClustered=false
    org.quartz.jobStore.tablePrefix=QRTZ_
    org.quartz.jobStore.dataSource=myDS
    #=======================================================
    #数据库配置
    #=======================================================
    org.quartz.dataSource.myDS.driver= com.mysql.jdbc.Driver
    org.quartz.dataSource.myDS.URL= jdbc:mysql:///quartz?characterEncoding=utf8&serverTimezone=UTC
    org.quartz.dataSource.myDS.user= root
    org.quartz.dataSource.myDS.password=123456
    org.quartz.dataSource.myDS.maxConnections=5

配置：

package pers.zhang.sb_quartz.config;
    
    import org.quartz.JobDataMap;
    import org.quartz.Scheduler;
    import org.quartz.ee.servlet.QuartzInitializerListener;
    import org.quartz.spi.JobFactory;
    import org.quartz.spi.TriggerFiredBundle;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
    import org.springframework.beans.factory.config.PropertiesFactoryBean;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.ClassPathResource;
    import org.springframework.scheduling.quartz.*;
    import pers.zhang.sb_quartz.job.MySecondJob;
    
    import java.io.IOException;
    import java.util.Properties;
    
    /** * @Author: acton_zhang * @Date: 2020/4/11 2:28 下午 * @Version 1.0 */
    @Configuration
    public class QuartzConfig { 
    
    
        @Autowired
        private AutowireCapableBeanFactory capableBeanFactory;
    
        /** * 当触发器触发时，与之关联的任务被Scheduler中配置的JobFactory实例化，也就是每触发一次，就会创建一个任务的实例化对象 * (如果缺省)则调用Job类的newInstance方法生成一个实例 * (这里选择自定义)并将创建的Job实例化交给IoC管理 * @return */
        @Bean
        public JobFactory jobFactory() { 
            return new AdaptableJobFactory() { 
                @Override
                protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception { 
                    Object jobInstance = super.createJobInstance(bundle);
                    capableBeanFactory.autowireBean(jobInstance);
                    return jobInstance;
                }
            };
        }
    
    	//Job
        @Bean
        public JobDetailFactoryBean jobDetail2() { 
            JobDetailFactoryBean bean = new JobDetailFactoryBean();
            bean.setJobClass(MySecondJob.class);
            bean.setDurability(true);
            bean.setName("job2");
            bean.setGroup("group");
            return bean;
        }
    
    	//Trigger
        @Bean
        public CronTriggerFactoryBean cronTriggerFactoryBean() { 
            CronTriggerFactoryBean bean = new CronTriggerFactoryBean();
            bean.setJobDetail(jobDetail2().getObject());//关联job
            bean.setCronExpression("0/2 * * * * ?");
            bean.setName("trigger2");
            bean.setGroup("group");
            return bean;
        }
    
        @Bean
        public SchedulerFactoryBean schedulerFactoryBean() throws IOException { 
            SchedulerFactoryBean bean = new SchedulerFactoryBean();
            bean.setJobFactory(jobFactory());
            //延迟启动
            bean.setStartupDelay(1);
            bean.setConfigLocation(new ClassPathResource("/quartz.properties"));
            bean.setTriggers(cronTriggerFactoryBean().getObject());
            return bean;
        }
    
        /** * 获得Scheduler 对象 * @return * @throws IOException */
        @Bean
        public Scheduler scheduler() throws IOException { 
            return schedulerFactoryBean().getScheduler();
        }
    
    }

Job

public class MySecondJob extends QuartzJobBean { 
    
        private String name;
    
        public void setName(String name) { 
            this.name = name;
        }
    
        @Override
        protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException { 
            System.out.println("MySecondJob:hello " + name + ":" + new Date());
        }
    }

启动类：

@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class})
    public class SbQuartzApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(SbQuartzApplication.class, args);
        }
    
    }

运行：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][20200411162028425.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]: /images/20210813/b416774dbe31414a91b8ebfb7f7796b3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]: /images/20210813/432f9b7024d942c3b972dcfeeb895fac.png
[20200411162028425.png]: /images/20210813/4958b81376ff4f3da35b2ee7174b1acd.png