Quartz 定时任务 (crud,暂停,恢复)

悠悠 2021-12-03 13:43 331阅读 0赞

**目录**

1.版本

2.创建数据库表 (下面是建表语句)

3. quartz.properties 配置文件

4.application.yml 配置 (数据库配置修改成自己项目配置):

5. springBoot 启动类(省略....)

6. 实体类

7. 返回相应结果类

8. quartz配置类

9. 解决spring bean注入Job的问题

10.定时任务类

11. controller

12.包结构.

--------------------

### 1.版本 ###

springBoot 1.5.12

Quartz 2.3

### 2.创建数据库表 (下面是建表语句) ###

#
    # In your Quartz properties file, you'll need to set 
    # org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
    #
    #
    # By: Ron Cordell - roncordell
    #  I didn't see this anywhere, so I thought I'd post it here. This is the script from Quartz to create the tables in a MySQL database, modified to use INNODB instead of MYISAM.
    
    DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS;
    DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS;
    DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE;
    DROP TABLE IF EXISTS QRTZ_LOCKS;
    DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS;
    DROP TABLE IF EXISTS QRTZ_SIMPROP_TRIGGERS;
    DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS;
    DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS;
    DROP TABLE IF EXISTS QRTZ_TRIGGERS;
    DROP TABLE IF EXISTS QRTZ_JOB_DETAILS;
    DROP TABLE IF EXISTS QRTZ_CALENDARS;
    
    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) 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 NULL,
    PRIMARY KEY (SCHED_NAME,JOB_NAME,JOB_GROUP))
    ENGINE=InnoDB;
    
    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) NULL,
    NEXT_FIRE_TIME BIGINT(13) NULL,
    PREV_FIRE_TIME BIGINT(13) NULL,
    PRIORITY INTEGER NULL,
    TRIGGER_STATE VARCHAR(16) NOT NULL,
    TRIGGER_TYPE VARCHAR(8) NOT NULL,
    START_TIME BIGINT(13) NOT NULL,
    END_TIME BIGINT(13) NULL,
    CALENDAR_NAME VARCHAR(200) NULL,
    MISFIRE_INSTR SMALLINT(2) NULL,
    JOB_DATA BLOB NULL,
    PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    FOREIGN KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)
    REFERENCES QRTZ_JOB_DETAILS(SCHED_NAME,JOB_NAME,JOB_GROUP))
    ENGINE=InnoDB;
    
    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),
    FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))
    ENGINE=InnoDB;
    
    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),
    PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))
    ENGINE=InnoDB;
    
    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) NULL,
        STR_PROP_2 VARCHAR(512) NULL,
        STR_PROP_3 VARCHAR(512) NULL,
        INT_PROP_1 INT NULL,
        INT_PROP_2 INT NULL,
        LONG_PROP_1 BIGINT NULL,
        LONG_PROP_2 BIGINT NULL,
        DEC_PROP_1 NUMERIC(13,4) NULL,
        DEC_PROP_2 NUMERIC(13,4) NULL,
        BOOL_PROP_1 VARCHAR(1) NULL,
        BOOL_PROP_2 VARCHAR(1) NULL,
        PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
        FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) 
        REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))
    ENGINE=InnoDB;
    
    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 NULL,
    PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    INDEX (SCHED_NAME,TRIGGER_NAME, TRIGGER_GROUP),
    FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
    REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))
    ENGINE=InnoDB;
    
    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;
    
    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;
    
    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 INTEGER NOT NULL,
    STATE VARCHAR(16) NOT NULL,
    JOB_NAME VARCHAR(200) NULL,
    JOB_GROUP VARCHAR(200) NULL,
    IS_NONCONCURRENT VARCHAR(1) NULL,
    REQUESTS_RECOVERY VARCHAR(1) NULL,
    PRIMARY KEY (SCHED_NAME,ENTRY_ID))
    ENGINE=InnoDB;
    
    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;
    
    CREATE TABLE QRTZ_LOCKS (
    SCHED_NAME VARCHAR(120) NOT NULL,
    LOCK_NAME VARCHAR(40) NOT NULL,
    PRIMARY KEY (SCHED_NAME,LOCK_NAME))
    ENGINE=InnoDB;
    
    CREATE INDEX IDX_QRTZ_J_REQ_RECOVERY ON QRTZ_JOB_DETAILS(SCHED_NAME,REQUESTS_RECOVERY);
    CREATE INDEX IDX_QRTZ_J_GRP ON QRTZ_JOB_DETAILS(SCHED_NAME,JOB_GROUP);
    
    CREATE INDEX IDX_QRTZ_T_J ON QRTZ_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP);
    CREATE INDEX IDX_QRTZ_T_JG ON QRTZ_TRIGGERS(SCHED_NAME,JOB_GROUP);
    CREATE INDEX IDX_QRTZ_T_C ON QRTZ_TRIGGERS(SCHED_NAME,CALENDAR_NAME);
    CREATE INDEX IDX_QRTZ_T_G ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP);
    CREATE INDEX IDX_QRTZ_T_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE);
    CREATE INDEX IDX_QRTZ_T_N_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP,TRIGGER_STATE);
    CREATE INDEX IDX_QRTZ_T_N_G_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP,TRIGGER_STATE);
    CREATE INDEX IDX_QRTZ_T_NEXT_FIRE_TIME ON QRTZ_TRIGGERS(SCHED_NAME,NEXT_FIRE_TIME);
    CREATE INDEX IDX_QRTZ_T_NFT_ST ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE,NEXT_FIRE_TIME);
    CREATE INDEX IDX_QRTZ_T_NFT_MISFIRE ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME);
    CREATE INDEX IDX_QRTZ_T_NFT_ST_MISFIRE ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_STATE);
    CREATE INDEX IDX_QRTZ_T_NFT_ST_MISFIRE_GRP ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_GROUP,TRIGGER_STATE);
    
    CREATE INDEX IDX_QRTZ_FT_TRIG_INST_NAME ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME);
    CREATE INDEX IDX_QRTZ_FT_INST_JOB_REQ_RCVRY ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME,REQUESTS_RECOVERY);
    CREATE INDEX IDX_QRTZ_FT_J_G ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP);
    CREATE INDEX IDX_QRTZ_FT_JG ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_GROUP);
    CREATE INDEX IDX_QRTZ_FT_T_G ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP);
    CREATE INDEX IDX_QRTZ_FT_TG ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_GROUP);
    
    commit;

### 3. quartz.properties 配置文件 ###

org.quartz.scheduler.instanceName = MyScheduler
    
    org.quartz.threadPool.threadCount = 5
    org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
    org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
    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://localhost:3306/test?characterEncoding=utf-8&useSSL=false
    org.quartz.dataSource.myDS.user = root
    org.quartz.dataSource.myDS.password = root
    org.quartz.dataSource.myDS.maxConnections = 5

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc2NzA4Nw_size_16_color_FFFFFF_t_70][]

### 4.application.yml 配置 (数据库配置修改成自己项目配置): ###

# 项目contextPath 科帮网https://blog.52itstyle.vip
    server.context-path=/quartz
    # 服务端口
    server.port=8080
    # session最大超时时间(分钟)，默认为30
    server.session-timeout=60
    # 该服务绑定IP地址，启动服务器时如本机不是该IP地址则抛出异常启动失败，只有特殊需求的情况下才配置
    #server.address=192.168.1.66
    
    # tomcat最大线程数，默认为200
    server.tomcat.max-threads=100
    # tomcat的URI编码
    server.tomcat.uri-encoding=UTF-8
    
    spring.thymeleaf.mode=LEGACYHTML5
    
    #dev tools
    spring.devtools.livereload.enabled=true
    spring.thymeleaf.cache=false
    spring.thymeleaf.cache-period=0
    spring.thymeleaf.template.cache=false
    # 静态文件请求匹配方式
    spring.mvc.static-path-pattern=/**
    
    #注意中文乱码
    spring.datasource.url=jdbc:mysql://localhost:3306/test?characterEncoding=utf-8&useSSL=false
    spring.datasource.username=root
    spring.datasource.password=root
    spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    # Specify the DBMS
    spring.jpa.database = MYSQL
    # Show or not log for each sql query
    spring.jpa.show-sql = true
    # DDL mode. This is actually a shortcut for the "hibernate.hbm2ddl.auto" property. Default to "create-drop" when using an embedded database, "none" otherwise.
    spring.jpa.hibernate.ddl-auto = update
    # Hibernate 4 naming strategy fully qualified name. Not supported with Hibernate 5.
    spring.jpa.hibernate.naming.strategy = org.hibernate.cfg.ImprovedNamingStrategy
    # stripped before adding them to the entity manager)
    spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.MySQL5Dialect

### 5. springBoot 启动类(省略....) ###

### 6. 实体类 ###

package com.itstyle.quartz.entity;
    
    import java.io.Serializable;
    import io.swagger.annotations.ApiModelProperty;
    import com.baomidou.mybatisplus.activerecord.Model;
    import com.baomidou.mybatisplus.annotations.TableField;
    import com.baomidou.mybatisplus.annotations.TableId;
    import com.baomidou.mybatisplus.annotations.TableName;
    import com.baomidou.mybatisplus.enums.IdType;
    
    /**
     * (QuartzEntity)实体类
     *
     * @author LauKitFai
     * @since 2019-07-17 10:45:33
     */
    @TableName("quartz_entity")
    public class QuartzEntity extends Model<QuartzEntity>{
    
        private static final long serialVersionUID = 1L;
        
        /**
         * 主键id
         */
        @TableId(value = "id", type = IdType.AUTO)
        @ApiModelProperty(value="主键id")    
        private Long id;
        
        /**
         * 任务名称
         */
         @TableField("job_name")
        @ApiModelProperty(value="任务名称")    
        private String jobName;
        
        /**
         * 任务分组
         */
         @TableField("job_group")
        @ApiModelProperty(value="任务分组")    
        private String jobGroup;
        
        /**
         * 任务描述
         */
         @TableField("description")
        @ApiModelProperty(value="任务描述")    
        private String description;
        
        /**
         * 执行类
         */
         @TableField("job_class_name")
        @ApiModelProperty(value="执行类")    
        private String jobClassName;
        
        /**
         * 执行时间
         */
         @TableField("cron_expression")
        @ApiModelProperty(value="执行时间")    
        private String cronExpression;
        
        /**
         * 触发器名称
         */
         @TableField("trigger_name")
        @ApiModelProperty(value="触发器名称")    
        private String triggerName;
        
        /**
         * 任务状态
         */
         @TableField("trigger_state")
        @ApiModelProperty(value="任务状态")    
        private String triggerState;
        
        /**
         * 任务名称 用于修改
         */
         @TableField("old_job_name")
        @ApiModelProperty(value="任务名称 用于修改")    
        private String oldJobName;
        
        /**
         * 任务分组 用于修改
         */
         @TableField("old_job_group")
        @ApiModelProperty(value="任务分组 用于修改")    
        private String oldJobGroup;
    
    
        public QuartzEntity() {
        }
    
        public QuartzEntity(Long id, String jobName, String jobGroup, String description, String jobClassName, String cronExpression, String triggerName, String triggerState, String oldJobName, String oldJobGroup) {
            this.id = id;
            this.jobName = jobName;
            this.jobGroup = jobGroup;
            this.description = description;
            this.jobClassName = jobClassName;
            this.cronExpression = cronExpression;
            this.triggerName = triggerName;
            this.triggerState = triggerState;
            this.oldJobName = oldJobName;
            this.oldJobGroup = oldJobGroup;
        }
    
        public Long getId() {
            return id;
        }
    
        public void setId(Long id) {
            this.id = id;
        }
        
        public String getJobName() {
            return jobName;
        }
    
        public void setJobName(String jobName) {
            this.jobName = jobName;
        }
        
        public String getJobGroup() {
            return jobGroup;
        }
    
        public void setJobGroup(String jobGroup) {
            this.jobGroup = jobGroup;
        }
        
        public String getDescription() {
            return description;
        }
    
        public void setDescription(String description) {
            this.description = description;
        }
        
        public String getJobClassName() {
            return jobClassName;
        }
    
        public void setJobClassName(String jobClassName) {
            this.jobClassName = jobClassName;
        }
        
        public String getCronExpression() {
            return cronExpression;
        }
    
        public void setCronExpression(String cronExpression) {
            this.cronExpression = cronExpression;
        }
        
        public String getTriggerName() {
            return triggerName;
        }
    
        public void setTriggerName(String triggerName) {
            this.triggerName = triggerName;
        }
        
        public String getTriggerState() {
            return triggerState;
        }
    
        public void setTriggerState(String triggerState) {
            this.triggerState = triggerState;
        }
        
        public String getOldJobName() {
            return oldJobName;
        }
    
        public void setOldJobName(String oldJobName) {
            this.oldJobName = oldJobName;
        }
        
        public String getOldJobGroup() {
            return oldJobGroup;
        }
    
        public void setOldJobGroup(String oldJobGroup) {
            this.oldJobGroup = oldJobGroup;
        }
    
        @Override
        protected Serializable pkVal() {
            return this.id;
        }
    
        @Override
        public String toString() {
            return "QuartzEntity{" +
                    "id=" + id +
                    ", jobName=" + jobName +
                    ", jobGroup=" + jobGroup +
                    ", description=" + description +
                    ", jobClassName=" + jobClassName +
                    ", cronExpression=" + cronExpression +
                    ", triggerName=" + triggerName +
                    ", triggerState=" + triggerState +
                    ", oldJobName=" + oldJobName +
                    ", oldJobGroup=" + oldJobGroup +
                                    '}';
        }
    }

### 7. 返回相应结果类 ###

package com.itstyle.quartz.entity;
    
    import java.util.HashMap;
    import java.util.Map;
    /**
     * 页面响应entity
     */
    public class Result extends HashMap<String, Object> {
    
    	private static final long serialVersionUID = 1L;
    
    	public Result() {
    		put("code", 0);
    	}
    
    	public static Result error() {
    		return error(500, "未知异常，请联系管理员");
    	}
    
    	public static Result error(String msg) {
    		return error(500, msg);
    	}
    
    	public static Result error(int code, String msg) {
    		Result r = new Result();
    		r.put("code", code);
    		r.put("msg", msg);
    		return r;
    	}
    
    	public static Result ok(Object msg) {
    		Result r = new Result();
    		r.put("msg", msg);
    		return r;
    	}
    
    
    	public static Result ok(Map<String, Object> map) {
    		Result r = new Result();
    		r.putAll(map);
    		return r;
    	}
    
    	public static Result ok() {
    		return new Result();
    	}
    
    	@Override
    	public Result put(String key, Object value) {
    		super.put(key, value);
    		return this;
    	}
    }

### 8. quartz配置类 ###

package com.itstyle.quartz.config;
    import java.io.IOException;
    import java.util.Properties;
    
    import org.quartz.Scheduler;
    import org.quartz.ee.servlet.QuartzInitializerListener;
    import org.springframework.beans.factory.annotation.Autowired;
    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.SchedulerFactoryBean;
    /**
     * quartz配置
     */
    @Configuration
    public class SchedulerConfig {
    	
    	@Autowired
    	private SpringJobFactory springJobFactory;
    	
        @Bean(name="SchedulerFactory")
        public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
            SchedulerFactoryBean factory = new SchedulerFactoryBean();
            factory.setAutoStartup(true);
            factory.setStartupDelay(5);//延时5秒启动
            factory.setQuartzProperties(quartzProperties());
            factory.setJobFactory(springJobFactory);  
            return factory;
        }
    
        @Bean
        public Properties quartzProperties() throws IOException {
            PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
            propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
            propertiesFactoryBean.afterPropertiesSet();
            return propertiesFactoryBean.getObject();
        }
    
        /*
         * quartz初始化监听器
         */
        @Bean
        public QuartzInitializerListener executorListener() {
           return new QuartzInitializerListener();
        }
    
        /*
         * 通过SchedulerFactoryBean获取Scheduler的实例
         */
        @Bean(name="Scheduler")
        public Scheduler scheduler() throws IOException {
            return schedulerFactoryBean().getScheduler();
        }
    
    }

### 9. 解决spring bean注入Job的问题 ###

package com.itstyle.quartz.config;
    
    import org.quartz.spi.TriggerFiredBundle;  
    import org.springframework.beans.factory.annotation.Autowired;  
    import org.springframework.beans.factory.config.AutowireCapableBeanFactory;  
    import org.springframework.scheduling.quartz.AdaptableJobFactory;  
    import org.springframework.stereotype.Component;
    /**
     * 解决spring bean注入Job的问题
     */
    @Component  
    public class SpringJobFactory extends AdaptableJobFactory  {       
        @Autowired    
        private AutowireCapableBeanFactory capableBeanFactory;    
        
        @Override    
        protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {    
            // 调用父类的方法    
            Object jobInstance = super.createJobInstance(bundle);    
            // 进行注入    
            capableBeanFactory.autowireBean(jobInstance);    
            return jobInstance;    
        }    
    }

### 10.定时任务类 ###

package com.itstyle.quartz.job;
    
    import com.itstyle.quartz.service.IJobService;
    import org.quartz.Job;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    import org.springframework.beans.factory.annotation.Autowired;
    
    import java.io.Serializable;
    
    /**
     * 定时任务
     */
    public class TestTwo implements  Job,Serializable {
    
    	private static final long serialVersionUID = 1L;
    	   
        @Autowired  
        private IJobService jobService; 
        
    	@Override
    	public void execute(JobExecutionContext context) throws JobExecutionException {
    		//注入jobService 执行相关业务操作
    		//System.out.println(jobService);
    		System.out.println("测试任务3");
    	}
    }

### 11. controller ###

package com.itstyle.quartz.web;
    
    import com.itstyle.quartz.entity.QuartzEntity;
    import com.itstyle.quartz.entity.QuartzEntity_two;
    import io.swagger.annotations.Api;
    import io.swagger.annotations.ApiOperation;
    
    import java.util.List;
    
    import javax.servlet.http.HttpServletResponse;
    
    import org.quartz.CronScheduleBuilder;
    import org.quartz.JobBuilder;
    import org.quartz.JobDetail;
    import org.quartz.JobKey;
    import org.quartz.Scheduler;
    import org.quartz.SchedulerException;
    import org.quartz.Trigger;
    import org.quartz.TriggerBuilder;
    import org.quartz.TriggerKey;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.itstyle.quartz.entity.Result;
    import com.itstyle.quartz.service.IJobService;
    
    @Api(tags = "Quartz任务")
    @RestController
    @RequestMapping("/job")
    public class JobController {
        private final static Logger LOGGER = LoggerFactory.getLogger(JobController.class);
    
    
        @Autowired
        @Qualifier("Scheduler")
        private Scheduler scheduler;
        @Autowired
        private IJobService jobService;
    
        @SuppressWarnings({"unchecked", "rawtypes"})
        @ApiOperation(value = "新建任务")
        @PostMapping("/add")
        public Result save(QuartzEntity quartz) {
            LOGGER.info("新增任务");
            try {
                //获取Scheduler实例、废弃、使用自动注入的scheduler、否则spring的service将无法注入
                //Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
                //如果是修改  展示旧的 任务
                if (quartz.getOldJobGroup() != null) {
                    JobKey key = new JobKey(quartz.getOldJobName(), quartz.getOldJobGroup());
                    scheduler.deleteJob(key);
                }
                Class cls = Class.forName(quartz.getJobClassName());
                cls.newInstance();
    
                //构建job信息
                JobDetail job = JobBuilder.newJob(cls)
                        .withIdentity(quartz.getJobName(),quartz.getJobGroup())
                        .withDescription(quartz.getDescription())
                        .build();
                // 触发时间点
                CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(quartz.getCronExpression());
                Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger" + quartz.getJobName(), quartz.getJobGroup())
                        .startNow().withSchedule(cronScheduleBuilder).build();
                //交由Scheduler安排触发
                scheduler.scheduleJob(job, trigger);
            } catch (Exception e) {
                e.printStackTrace();
                return Result.error();
            }
            return Result.ok();
        }
    
        @ApiOperation(value = "任务列表")
        @PostMapping("/list")
        public Result list(QuartzEntity quartz, Integer pageNo, Integer pageSize) {
            LOGGER.info("任务列表");
            List<QuartzEntity> list = jobService.listQuartzEntity(quartz, pageNo, pageSize);
            return Result.ok(list);
        }
    
        @ApiOperation(value = "触发任务")
        @PostMapping("/trigger")
        public Result trigger(QuartzEntity quartz, HttpServletResponse response) {
            try {
                JobKey key = new JobKey(quartz.getJobName(), quartz.getJobGroup());
                scheduler.triggerJob(key);
            } catch (SchedulerException e) {
                e.printStackTrace();
                return Result.error();
            }
            return Result.ok();
        }
    
        @ApiOperation("停止任务")
        @PostMapping("/pause")
        public Result pause(QuartzEntity_two quartz) {
            LOGGER.info("停止任务");
            try {
                JobKey key = new JobKey(quartz.getJobName(), quartz.getJobGroup());
                scheduler.pauseJob(key);
            } catch (SchedulerException e) {
                e.printStackTrace();
                return Result.error();
            }
            return Result.ok();
        }
    
        @ApiOperation("恢复任务")
        @PostMapping("/resume")
        public Result resume(QuartzEntity_two quartz) {
            LOGGER.info("恢复任务");
            try {
                JobKey key = new JobKey(quartz.getJobName(), quartz.getJobGroup());
                scheduler.resumeJob(key);
            } catch (SchedulerException e) {
                e.printStackTrace();
                return Result.error();
            }
            return Result.ok();
        }
    
        @ApiOperation(value = "移除任务")
        @PostMapping("/remove")
        public Result remove(QuartzEntity_two quartz) {
            try {
    
                TriggerKey triggerKey = TriggerKey.triggerKey(quartz.getJobName(), quartz.getJobGroup());
                // 停止触发器  
                scheduler.pauseTrigger(triggerKey);
                // 移除触发器  
                scheduler.unscheduleJob(triggerKey);
                // 删除任务  
                scheduler.deleteJob(JobKey.jobKey(quartz.getJobName(), quartz.getJobGroup()));
                System.out.println("removeJob:" + JobKey.jobKey(quartz.getJobName()));
            } catch (Exception e) {
                e.printStackTrace();
                return Result.error();
            }
            return Result.ok();
        }
    }

### 12.包结构. ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc2NzA4Nw_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc2NzA4Nw_size_16_color_FFFFFF_t_70]: /images/20211203/108b39a2b44e45aeb49084ea18e30a56.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc2NzA4Nw_size_16_color_FFFFFF_t_70 1]: /images/20211203/a1f1ee8fbc324dc4b02b324cebd469aa.png