springboot+quartz定时任务，实现从页面传时间进行任务调度

小鱼儿 2023-06-28 08:37 13阅读 0赞

# 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>
    
    	<groupId>com.gqbj</groupId>
    	<artifactId>quartz-demo</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>jar</packaging>
    
    
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter</artifactId>
    		<version>2.0.4.RELEASE</version>
    	</parent>
    	<dependencies>
    
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-quartz</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    			<plugin>
    				<groupId>org.apache.maven.plugins</groupId>
    				<artifactId>maven-compiler-plugin</artifactId>
    				<configuration>
    					<source>6</source>
    					<target>6</target>
    				</configuration>
    			</plugin>
    		</plugins>
    	</build>
    </project>

# Application #

package com.gqbj.quartz_demo;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    /** * Hello world! * */
    @SpringBootApplication
    public class Application
    { 
        public static void main(String[] args) { 
            SpringApplication.run(Application.class, args);
        }
    }

# MyJob #

import org.quartz.Job;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    /** * @author 宫崎不骏 * @className MyJob * @Version 1.0 * @Description: TODO * @date 2020/1/720:50 */
    public class MyJob implements Job { 
    
        private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    
        @Override
        public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { 
            System.out.println(jobExecutionContext.getJobDetail());
            System.out.println("我是业务，调用时间：" + sdf.format(new Date()));
        }
    }

# QuartzSchedulerManager #

import com.gqbj.quartz_demo.task.MyJob;
    import org.quartz.*;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Configuration;
    
    import java.util.Date;
    
    /** * @author 宫崎不骏 * @className QuartzSchedulerManager * @Version 1.0 * @Description: TODO * @date 2020/1/720:52 */
    @Configuration
    public class QuartzSchedulerManager { 
    
        // 任务调度
        @Autowired
        private Scheduler scheduler;
        /** * 开始执行定时器 * * @throws SchedulerException */
        public void startJob(Date time) throws SchedulerException { 
            startJobTest(scheduler,time);
            scheduler.start();
        }
    
        /** * * @Title: startJobTest * @Description: 启动 定时器 test * @param scheduler * @throws SchedulerException 参数 * void 返回类型 */
        private void startJobTest(Scheduler scheduler , Date time) throws SchedulerException { 
            System.out.println(time + "TIME");
            // 通过JobBuilder构建JobDetail实例，JobDetail规定只能是实现Job接口的实例
            // JobDetail 是具体Job实例
            JobDetail jobDetail = JobBuilder.newJob(MyJob.class).withIdentity("job1", "group1").build();
            // 基于表达式构建触发器
            SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.simpleSchedule();
    
            // CronTrigger表达式触发器 继承于Trigger
            // TriggerBuilder 用于构建触发器实例
            SimpleTrigger simpleTrigger = TriggerBuilder.newTrigger().withIdentity("job1", "group1")
                    .withSchedule(simpleScheduleBuilder).startAt(time).build();
            scheduler.scheduleJob(jobDetail, simpleTrigger);
        }
    }

# testController #

import com.gqbj.quartz_demo.config.QuartzSchedulerManager;
    import org.quartz.SchedulerException;
    import org.springframework.format.annotation.DateTimeFormat;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import javax.annotation.Resource;
    import java.util.Date;
    
    /** * @author 宫崎不骏 * @className testController * @Version 1.0 * @Description: TODO * @date 2020/1/720:53 */
    @RestController
    public class testController { 
        @Resource
        private QuartzSchedulerManager quartzSchedulerManager;
    
        @RequestMapping("/startJob")
        public void start(@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") Date time) throws SchedulerException { 
            System.out.println("开启定时器");
            quartzSchedulerManager.startJob(time);
        }
    }

# postman调用 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0l0aXNzb2hhcmR0b2c_size_16_color_FFFFFF_t_70]

# 控制台 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0l0aXNzb2hhcmR0b2c_size_16_color_FFFFFF_t_70 1]

# 大功告成！！！ #

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0l0aXNzb2hhcmR0b2c_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200108095950799.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0l0aXNzb2hhcmR0b2c=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0l0aXNzb2hhcmR0b2c_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200108100037206.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0l0aXNzb2hhcmR0b2c=,size_16,color_FFFFFF,t_70