? ? 在開(kāi)發(fā)中有很多定時(shí)任務(wù)都不是寫(xiě)死的而是可以人為配置并且寫(xiě)到數(shù)據(jù)庫(kù)中的，下面簡(jiǎn)單的分享一個(gè)SpringBoot整合QUARTZ并嵌入可視化界面的demo。

Step1. 在數(shù)據(jù)庫(kù)中建立有關(guān)quartz的表，我用的是 mySql 數(shù)據(jù)庫(kù)，建表語(yǔ)句如下，如果是其他的數(shù)據(jù)庫(kù)可以自己去網(wǎng)上下載：

# # Quartz seems to work best with the driver mm.mysql-2.0.7-bin.jar # # PLEASE consider using mysql with innodb tables to avoid locking issues # # In your Quartz properties file, you'll need to set # org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate #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) );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) );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) );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(200) 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) );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) );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),FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) );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) );CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS(SCHED_NAME VARCHAR(120) NOT NULL,TRIGGER_GROUP VARCHAR(200) NOT NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_GROUP) );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) );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) );CREATE TABLE QRTZ_LOCKS(SCHED_NAME VARCHAR(120) NOT NULL,LOCK_NAME VARCHAR(40) NOT NULL, PRIMARY KEY (SCHED_NAME,LOCK_NAME) );commit;

Step2.新建一個(gè)springBoot項(xiàng)目并導(dǎo)入依賴(lài)

? ? ? ? ? ?pom.xml 文件的內(nèi)容如下：

<?xml version="1.0" encoding="UTF-8"?> <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.example.demo</groupId><artifactId>QuartzDemo</artifactId><version>0.0.1-SNAPSHOT</version><packaging>war</packaging><name>demo-quartz</name><description>Demo project for quartz</description><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.3.RELEASE</version> <!-- lookup parent from repository --></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId><exclusions><exclusion><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-logging</artifactId></exclusion></exclusions></dependency> <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>1.3.2</version></dependency> <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-log4j2</artifactId></dependency><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-core</artifactId></dependency> <dependency><groupId>com.lmax</groupId><artifactId>disruptor</artifactId><version>3.3.4</version></dependency> <dependency><groupId>javax.mail</groupId><artifactId>mail</artifactId><version>1.4.7</version></dependency> <dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.9</version></dependency> <dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.1.9</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>com.ds.tech</groupId><artifactId>dstech3-utility</artifactId><version>3.1.7</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-thymeleaf</artifactId></dependency><dependency><groupId>com.aliyun</groupId><artifactId>aliyun-java-sdk-dysmsapi</artifactId><version>1.1.0</version></dependency><dependency><groupId>com.aliyun</groupId><artifactId>aliyun-java-sdk-core</artifactId><version>3.2.8</version></dependency><dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId><version>2.2.1</version></dependency> <dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper</artifactId><version>5.0.0</version></dependency></dependencies><build><resources><resource><directory>src/main/java</directory><includes><include>**/*.*</include></includes><excludes><exclude>**/*.java</exclude></excludes></resource><resource><directory>src/main/resources</directory><includes><include>**/*.*</include></includes></resource></resources> <plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

其中下面的這個(gè)依賴(lài)是Quartz 所必須的

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId></dependency>

Step3. 在配置文件中進(jìn)行配置，application.properties 的內(nèi)容如下：

#服務(wù)端口號(hào) server.port=8082 #以Tomcat為web容器時(shí)的字符編碼 server.tomcat.uri-encoding=UTF-8 spring.http.encoding.force=true spring.http.encoding.enabled=true# 數(shù)據(jù)源配置 spring.datasource.url=jdbc:mysql://localhost:3306/AthenaDB?useUnicode=true&characterEncoding=utf-8 spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.username=root spring.datasource.password=123456#連接池配置 #spring.datasource.type=org.apache.commons.dbcp2.BasicDataSource spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spring.datasource.initialSize=5 spring.datasource.minIdle=5 spring.datasource.maxActive=20 spring.datasource.maxWait=60000 spring.datasource.timeBetweenEvictionRunsMillis=60000 spring.datasource.minEvictableIdleTimeMillis=300000 spring.datasource.validationQuery=SELECT 1 FROM DUAL spring.datasource.testWhileIdle=true spring.datasource.testOnBorrow=false spring.datasource.testOnReturn=false spring.datasource.poolPreparedStatements=true spring.datasource.maxPoolPreparedStatementPerConnectionSize=20 spring.datasource.connectionProperties=characterEncoding=utf8;druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000 # 合并多個(gè)DruidDataSource的監(jiān)控?cái)?shù)據(jù) #spring.datasource.useGlobalDataSourceStat=true #spring.datasource.filters=stat,wall,log4j #mybaits mapper位置設(shè)置 mybatis.mapper-locations=classpath*:com/example/demo/mapper/rmdb/*.xml #mybatis mybatis.type-aliases-package=com.example.demo.entity#訪(fǎng)問(wèn)日志路徑 #server.tomcat.accesslog.directory= #出現(xiàn)錯(cuò)誤時(shí), 直接拋出異常,自定義異常頁(yè)面使用 spring.mvc.throw-exception-if-no-handler-found=true #不要為我們工程中的資源文件建立映射,自定義異常頁(yè)面使用 spring.resources.add-mappings=false #應(yīng)用名稱(chēng)，一般就是項(xiàng)目名稱(chēng)，這個(gè)名稱(chēng)在SpringCloud中比較關(guān)鍵 spring.application.name=dscms #http請(qǐng)求的字符編碼 spring.http.encoding.charset=UTF-8 #配置在使用Thymeleaf做頁(yè)面模板時(shí)的前綴，即頁(yè)面所在路徑 spring.thymeleaf.prefix=classpath:/templates #設(shè)置在使用Thymeleaf做頁(yè)面模板時(shí)的后綴，其實(shí)默認(rèn)就是html spring.thymeleaf.suffix=.html #spring.thymeleaf.mode=LEGACYHTML5 spring.thymeleaf.mode=HTML #設(shè)置在使用Thymeleaf做頁(yè)面模板時(shí)是否啟用緩存 spring.thymeleaf.cache=false #設(shè)置編碼格式 spring.thymeleaf.encoding=UTF-8 #設(shè)置靜態(tài)資源的請(qǐng)求路徑 #spring.mvc.static-path-pattern=/** #指定靜態(tài)資源的路徑 #spring.resources.static-locations=classpath:/static/,classpath:/public/ #禁止對(duì)外提供Spring MBeans spring.jmx.enabled=false

Step4. 在resources文件夾下新建一個(gè)?quartz.properties 的配置文件，這樣就不會(huì)走它自帶的quartz.properties的配置文件，配置文件的內(nèi)容如下：

#作業(yè)實(shí)例名稱(chēng) org.quartz.scheduler.instanceName: DefaultQuartzScheduler #如果使用集群，instanceId必須唯一，設(shè)置成AUTO org.quartz.scheduler.instanceId = AUTO org.quartz.scheduler.rmi.export: false org.quartz.scheduler.rmi.proxy: false org.quartz.scheduler.wrapJobExecutionInUserTransaction: false org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool org.quartz.threadPool.threadCount: 10 org.quartz.threadPool.threadPriority: 5 org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true org.quartz.jobStore.misfireThreshold: 60000 #============================================================================ # Configure JobStore #============================================================================ #計(jì)劃任務(wù)存儲(chǔ)在內(nèi)存中 #org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore #存儲(chǔ)方式使用JobStoreTX(持久化到數(shù)據(jù)庫(kù)中) org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate #使用自己的配置文件 org.quartz.jobStore.useProperties:true #數(shù)據(jù)庫(kù)中quartz表的表名前綴 org.quartz.jobStore.tablePrefix:QRTZ_ org.quartz.jobStore.dataSource:qzDS #是否使用集群（如果項(xiàng)目只部署到 一臺(tái)服務(wù)器，就不用了） org.quartz.jobStore.isClustered = false #============================================================================ # Configure Datasources #============================================================================ #配置數(shù)據(jù)源 org.quartz.dataSource.qzDS.connectionProvider.class:com.example.demo.common.duird.DruidConnectionProvider org.quartz.dataSource.qzDS.driver = com.mysql.jdbc.Driver org.quartz.dataSource.qzDS.URL = jdbc:mysql://localhost:3306/AthenaDB?characterEncoding=utf-8 org.quartz.dataSource.qzDS.user:root org.quartz.dataSource.qzDS.password:123456 org.quartz.dataSource.qzDS.maxConnection:10

Step5. 自定義數(shù)據(jù)源，因?yàn)橐志没綌?shù)據(jù)庫(kù)，所以要用ConnectionProvider自定以數(shù)據(jù)源，代碼如下

package com.example.demo.common.duird;import java.sql.Connection; import java.sql.SQLException; import org.quartz.SchedulerException; import org.quartz.utils.ConnectionProvider;import com.alibaba.druid.pool.DruidDataSource;public class DruidConnectionProvider implements ConnectionProvider {//JDBC驅(qū)動(dòng)public String driver;//JDBC連接串public String URL;//數(shù)據(jù)庫(kù)用戶(hù)名public String user;//數(shù)據(jù)庫(kù)用戶(hù)密碼public String password;//數(shù)據(jù)庫(kù)最大連接數(shù)public int maxConnection;//數(shù)據(jù)庫(kù)SQL查詢(xún)每次連接返回執(zhí)行到連接池，以確保它仍然是有效的。public String validationQuery;private boolean validateOnCheckout;private int idleConnectionValidationSeconds;public String maxCachedStatementsPerConnection;private String discardIdleConnectionsSeconds;public static final int DEFAULT_DB_MAX_CONNECTIONS = 10;public static final int DEFAULT_DB_MAX_CACHED_STATEMENTS_PER_CONNECTION = 120;//Druid連接池private DruidDataSource datasource;/** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~** 接口實(shí)現(xiàn)** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~*/public Connection getConnection() throws SQLException {return datasource.getConnection();}public void shutdown() throws SQLException {datasource.close();}public void initialize() throws SQLException{if (this.URL == null) {throw new SQLException("DBPool could not be created: DB URL cannot be null");}if (this.driver == null) {throw new SQLException("DBPool driver could not be created: DB driver class name cannot be null!");}if (this.maxConnection < 0) {throw new SQLException("DBPool maxConnectins could not be created: Max connections must be greater than zero!");}datasource = new DruidDataSource();try{datasource.setDriverClassName(this.driver);} catch (Exception e) {try {throw new SchedulerException("Problem setting driver class name on datasource: " + e.getMessage(), e);} catch (SchedulerException e1) {}}datasource.setUrl(this.URL);datasource.setUsername(this.user);datasource.setPassword(this.password);datasource.setMaxActive(this.maxConnection);datasource.setMinIdle(1);datasource.setMaxWait(0);datasource.setMaxPoolPreparedStatementPerConnectionSize(DEFAULT_DB_MAX_CONNECTIONS);if (this.validationQuery != null) {datasource.setValidationQuery(this.validationQuery);if(!this.validateOnCheckout)datasource.setTestOnReturn(true);elsedatasource.setTestOnBorrow(true);datasource.setValidationQueryTimeout(this.idleConnectionValidationSeconds);}}/** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~** 提供get set方法** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~*/public String getDriver() {return driver;}public void setDriver(String driver) {this.driver = driver;}public String getURL() {return URL;}public void setURL(String URL) {this.URL = URL;}public String getUser() {return user;}public void setUser(String user) {this.user = user;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}public int getMaxConnection() {return maxConnection;}public void setMaxConnection(int maxConnection) {this.maxConnection = maxConnection;}public String getValidationQuery() {return validationQuery;}public void setValidationQuery(String validationQuery) {this.validationQuery = validationQuery;}public boolean isValidateOnCheckout() {return validateOnCheckout;}public void setValidateOnCheckout(boolean validateOnCheckout) {this.validateOnCheckout = validateOnCheckout;}public int getIdleConnectionValidationSeconds() {return idleConnectionValidationSeconds;}public void setIdleConnectionValidationSeconds(int idleConnectionValidationSeconds) {this.idleConnectionValidationSeconds = idleConnectionValidationSeconds;}public DruidDataSource getDatasource() {return datasource;}public void setDatasource(DruidDataSource datasource) {this.datasource = datasource;}public String getDiscardIdleConnectionsSeconds() {return discardIdleConnectionsSeconds;}public void setDiscardIdleConnectionsSeconds(String discardIdleConnectionsSeconds) {this.discardIdleConnectionsSeconds = discardIdleConnectionsSeconds;}}

注意：上邊的這個(gè)數(shù)據(jù)源的內(nèi)容是和quartz.properties中的數(shù)據(jù)源的配置互相配合的

Step6. 自定義一個(gè)jobfactory ，其目的是在具體的作業(yè)中 需要Spring 注入一些Service，所以要自定義一個(gè)jobfactory， 讓其在具體job 類(lèi)實(shí)例化時(shí) 使用Spring 的API 來(lái)進(jìn)行依賴(lài)注入

@Component public class JobFactory extends AdaptableJobFactory {/*** 讓不受spring管理的類(lèi)具有spring自動(dòng)注入*/@Autowiredprivate AutowireCapableBeanFactory capableBeanFactory;@Overrideprotected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {// 調(diào)用父類(lèi)的方法Object jobInstance = super.createJobInstance(bundle);// 進(jìn)行注入capableBeanFactory.autowireBean(jobInstance);return jobInstance;} }

Step7.創(chuàng)建調(diào)度器

package com.example.demo.common.config;import java.io.IOException; import java.util.Properties;import org.quartz.Scheduler; 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.annotation.EnableScheduling; import org.springframework.scheduling.quartz.SchedulerFactoryBean;import com.example.demo.common.factory.JobFactory;@Configuration @EnableScheduling public class SchedulerConfig {@AutowiredJobFactory jobFactory;@Bean(name="SchedulerFactory")public SchedulerFactoryBean schedulerFactoryBean() throws IOException {SchedulerFactoryBean factory = new SchedulerFactoryBean();//用于quartz集群,QuartzScheduler 啟動(dòng)時(shí)更新己存在的Job，這樣就不用每次修改targetObject后刪除qrtz_job_details表對(duì)應(yīng)記錄了 //factory.setOverwriteExistingJobs(true);//QuartzScheduler 延時(shí)啟動(dòng)，應(yīng)用啟動(dòng)完10秒后 QuartzScheduler 再啟動(dòng) //factory.setStartupDelay(10);factory.setQuartzProperties(quartzProperties()); //作業(yè)及數(shù)據(jù)源配置信息// 自定義Job Factory，用于Spring注入 service,bin等f(wàn)actory.setJobFactory(jobFactory);return factory;}@Beanpublic Properties quartzProperties() throws IOException {PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));//在quartz.properties中的屬性被讀取并注入后再初始化對(duì)象propertiesFactoryBean.afterPropertiesSet();return propertiesFactoryBean.getObject();}/** quartz初始化監(jiān)聽(tīng)器*/ /* @Beanpublic QuartzInitializerListener executorListener() {return new QuartzInitializerListener();}*//** 通過(guò)SchedulerFactoryBean獲取Scheduler的實(shí)例*/@Bean(name="Scheduler")public Scheduler scheduler() throws IOException {return schedulerFactoryBean().getScheduler();}}

Step8. 創(chuàng)建一個(gè)job_info_config.properties的配置文件，寫(xiě)關(guān)于作業(yè)的信息

#作業(yè)信息配置 demoquartz1_limit=2 demoquartz1_id=1000001 demoquartz1_name="樣例作業(yè)1";

Step9. 新建一個(gè)類(lèi)讀取上面的配置文件中的信息

public class JobInfoConfig {/*** 樣例作業(yè)1的隊(duì)列查詢(xún)上限* @return*/public static Integer getDemoQuartz1Limit() {return ConvertUtil.toInteger(ConfigUtil.getSettings("demoquartz1_limit"));}/*** 樣例作業(yè)1的id* @return*/public static String getDemoQuartz1Id() {return ConvertUtil.toString(ConfigUtil.getSettings("demoquartz1_id"));}/*** 樣例作業(yè)1的名稱(chēng)* @return*/public static String getDemoQuartz1Name() {return ConvertUtil.toString(ConfigUtil.getSettings("demoquartz1_name"));}}

Step10, 新建一個(gè)job類(lèi)

package com.example.demo.job;import org.quartz.DisallowConcurrentExecution; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired;import com.example.demo.service.DemoService;@DisallowConcurrentExecution public class DemoJob implements IBaseJob {private final Logger logger = LoggerFactory.getLogger(DemoJob.class);@Autowiredprivate DemoService demoService;@Overridepublic void execute(JobExecutionContext context)throws JobExecutionException {// TODO Auto-generated method stubtry{demoService.run();}catch(Exception e){logger.error(e.toString());}}} package com.example.demo.job;import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException;public interface IBaseJob extends Job {public void execute(JobExecutionContext context) throws JobExecutionException;}

Step11.在service 中寫(xiě)要執(zhí)行的作業(yè)

/*** 讀取作業(yè)信息* @author Administrator**/ public class BaseService {/*** 作業(yè)編號(hào)*/protected String jobId;/*** 作業(yè)名稱(chēng)*/protected String jobName;/*** 執(zhí)行成功數(shù)量*/protected int success=0;/*** 執(zhí)行失敗數(shù)量*/protected int fail = 0;/*** 待處理記錄總數(shù)*/protected int total = 0;/*** 設(shè)置job編號(hào)* @param jid*/protected void setJobId(String jId) {jobId = jId;}/*** 設(shè)置job名稱(chēng)* @param jName*/protected void setJobName(String jName) {jobName = jName;}/*** 開(kāi)始作業(yè)方法*/protected void startJob() {success = 0;fail=0;total = 0;LogWriter.writeJobStartLog(jobId, jobName);}/*** 設(shè)置作業(yè)待處理總數(shù)* @param tl*/protected void setJobTotal(int tl) {total = tl;LogWriter.writeJobStartLog(jobId, jobName,total);}/*** 當(dāng)前項(xiàng)處理狀態(tài)* @param currentKey*/protected void setSuccessJob(String currentKey) {success++;String msg = String.format("jobsrun - jobid：%s jobname:%s key:%s status:success", jobId,jobName,currentKey);LogWriter.writeWorkLog(msg);}/*** 失敗處理* @param currentKey*/protected void setFailJob(String currentKey) {fail++;String msg = String.format("jobsrun - jobid：%s jobname:%s key:%s status:fail", jobId,jobName,currentKey);LogWriter.writeWorkLog(msg);}/*** 結(jié)束作業(yè)*/protected void endJob() {LogWriter.writeJobEndLog(jobId, jobName, total, success, fail);} } package com.example.demo.service;import java.math.BigDecimal; import java.util.ArrayList; import java.util.List;import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service;import com.example.demo.common.config.JobInfoConfig; import com.example.demo.dao.UserDao; import com.example.demo.entity.User; import com.example.demo.entity.UserExample;@Service public class DemoService extends BaseService{private final Logger logger = LoggerFactory.getLogger(DemoService.class);@Autowiredprivate UserDao userDao;public void run(){//設(shè)置作業(yè)編號(hào)setJobId(JobInfoConfig.getDemoQuartz1Id());System.out.println("作業(yè)編號(hào):"+JobInfoConfig.getDemoQuartz1Name());//設(shè)置作業(yè)名稱(chēng)setJobName(JobInfoConfig.getDemoQuartz1Name());System.out.println("作業(yè)名稱(chēng)為:"+JobInfoConfig.getDemoQuartz1Name());//開(kāi)始作業(yè)startJob();//獲取待處理隊(duì)列List<User> list = getQueueList();if(list.size() == 0){endJob();return;}//設(shè)置待處理的總數(shù)setJobTotal(list.size());//循環(huán)處理內(nèi)容for (User user : list) {queueToDeal(user);}//結(jié)束作業(yè)endJob();}public List<User> getQueueList(){List<User> list = new ArrayList<User>();try{UserExample userExample = new UserExample();userExample.createCriteria().andBalanceEqualTo(new BigDecimal(0));userExample.setStart(0);userExample.setLength(Integer.valueOf(JobInfoConfig.getDemoQuartz1Limit()));System.out.println("作業(yè)上限:"+JobInfoConfig.getDemoQuartz1Limit());list = userDao.selectByExample(userExample);}catch(Exception e){logger.error(jobName,e);}return list;}public void queueToDeal(User user){User users = userDao.selectByPrimaryKey(user.getUserId());try{if(users != null){users.setBalance(new BigDecimal(1));UserExample userExample = new UserExample();userExample.createCriteria().andUserIdEqualTo(user.getUserId());if(userDao.updateByExample(users, userExample)<=0){setFailJob(users.getUserId().toString());return;}setSuccessJob(users.getUserId().toString());}else{setFailJob(user.getUserId().toString());return;}}catch(Exception e){setFailJob(users.getUserId().toString());logger.error(e.toString());}}} package com.example.demo.service;import java.util.List;import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service;import com.example.demo.dao.JobAndTriggerDao; import com.example.demo.entity.JobAndTrigger; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo;/*** 作業(yè)配置服務(wù)* 查詢(xún)所有的作業(yè)*/ @Service public class JobAndTriggerSevice {@Autowiredprivate JobAndTriggerDao jobAndTriggerDao;/*** 分頁(yè)查詢(xún)* @param pageNum* @param pageSize* @return*/public PageInfo<JobAndTrigger> getJobAndTriggerDetails(int pageNum, int pageSize) {PageHelper.startPage(pageNum, pageSize);List<JobAndTrigger> list = jobAndTriggerDao.getJobAndTriggerDetails();PageInfo<JobAndTrigger> page = new PageInfo<JobAndTrigger>(list);return page;}}

?

?Step12. controller 中的代碼如下：

package com.example.demo.controller;import java.util.HashMap; import java.util.Map;import org.quartz.CronScheduleBuilder; import org.quartz.CronTrigger; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.JobKey; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.TriggerBuilder; import org.quartz.TriggerKey; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController;import com.ds.tech.utility.log4j2.LogWriter; import com.example.demo.entity.JobAndTrigger; import com.example.demo.job.IBaseJob; import com.example.demo.service.JobAndTriggerSevice; import com.github.pagehelper.PageInfo;@RestController @RequestMapping(value="/job") public class JobController {@Autowiredprivate JobAndTriggerSevice jobAndTriggerSevice;//加入Qulifier注解，通過(guò)名稱(chēng)注入bean@Autowired @Qualifier("Scheduler")Scheduler scheduler;public static IBaseJob getClass(String classname) throws Exception {Class<?> class1 = Class.forName(classname);return (IBaseJob)class1.newInstance();}@PostMapping(value="/addjob")public void addJob(@RequestParam(value="jobClassName")String jobClassName, @RequestParam(value="jobGroupName")String jobGroupName, @RequestParam(value="cronExpression")String cronExpression,@RequestParam(value="description")String description) throws Exception {// 啟動(dòng)調(diào)度器 scheduler.start();//構(gòu)建job信息JobDetail jobDetail = JobBuilder.newJob(getClass(jobClassName).getClass()).withIdentity(jobClassName, jobGroupName).withDescription(description).build();//表達(dá)式調(diào)度構(gòu)建器(即任務(wù)執(zhí)行的時(shí)間)CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);//按新的cronExpression表達(dá)式構(gòu)建一個(gè)新的triggerCronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobClassName, jobGroupName).withSchedule(scheduleBuilder).build();try {scheduler.scheduleJob(jobDetail, trigger);} catch (SchedulerException e) {System.out.println("創(chuàng)建定時(shí)任務(wù)失敗"+e);//throw new Exception("創(chuàng)建定時(shí)任務(wù)失敗");}}@PostMapping(value="/pausejob")public void pauseJob(@RequestParam(value="jobClassName")String jobClassName, @RequestParam(value="jobGroupName")String jobGroupName) throws Exception {try {scheduler.pauseJob(JobKey.jobKey(jobClassName, jobGroupName));} catch (SchedulerException e) {System.out.println("停止定時(shí)任務(wù)失敗"+e);//throw new Exception("創(chuàng)建定時(shí)任務(wù)失敗");}}@PostMapping(value="/resumejob")public void resumeJob(@RequestParam(value="jobClassName")String jobClassName, @RequestParam(value="jobGroupName")String jobGroupName) throws Exception {try {scheduler.resumeJob(JobKey.jobKey(jobClassName, jobGroupName));} catch (SchedulerException e) {System.out.println("繼續(xù)定時(shí)任務(wù)失敗"+e);//throw new Exception("創(chuàng)建定時(shí)任務(wù)失敗");}}@PostMapping(value="/deletejob")public void deleteJob(@RequestParam(value="jobClassName")String jobClassName, @RequestParam(value="jobGroupName")String jobGroupName) throws Exception {try {scheduler.pauseTrigger(TriggerKey.triggerKey(jobClassName, jobGroupName));scheduler.unscheduleJob(TriggerKey.triggerKey(jobClassName, jobGroupName));scheduler.deleteJob(JobKey.jobKey(jobClassName, jobGroupName));} catch (SchedulerException e) {System.out.println("刪除定時(shí)任務(wù)失敗"+e);//throw new Exception("創(chuàng)建定時(shí)任務(wù)失敗");}}/*** 查詢(xún)?nèi)蝿?wù)列表* @param pageNum* @param pageSize* @return*/@GetMapping(value="/queryjob")public Map<String, Object> queryjob(@RequestParam(value="pageNum")Integer pageNum, @RequestParam(value="pageSize")Integer pageSize) { Map<String, Object> map = new HashMap<String, Object>();try {PageInfo<JobAndTrigger> jobAndTrigger = jobAndTriggerSevice.getJobAndTriggerDetails(pageNum, pageSize);map.put("JobAndTrigger", jobAndTrigger);map.put("number", jobAndTrigger.getTotal());} catch (Exception e) {LogWriter.writeErrorLog("查詢(xún)定時(shí)任務(wù)列表失敗", e);}return map;}/*** 修改定時(shí)任務(wù)* @param jobClassName* @param jobGroupName* @param cronExpression* @param description* @throws Exception*/@PostMapping(value="/reschedulejob")public void rescheduleJob(@RequestParam(value="jobClassName")String jobClassName, @RequestParam(value="jobGroupName")String jobGroupName,@RequestParam(value="cronExpression")String cronExpression,@RequestParam(value="description")String description) throws Exception{ try {TriggerKey triggerKey = TriggerKey.triggerKey(jobClassName, jobGroupName);// 表達(dá)式調(diào)度構(gòu)建器CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);// 按新的cronExpression表達(dá)式重新構(gòu)建triggertrigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).withDescription(description).build();// 按新的trigger重新設(shè)置job執(zhí)行scheduler.rescheduleJob(triggerKey, trigger);} catch (SchedulerException e) {LogWriter.writeErrorLog("更新定時(shí)任務(wù)失敗", e);}}}

Step13. 放開(kāi)頁(yè)面所在的靜態(tài)資源，讓他可以訪(fǎng)問(wèn)到

package com.example.demo.common.config;import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.web.servlet.config.annotation.EnableWebMvc; import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry; import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;/*** Spring mvc 配置**/ @Configuration @EnableWebMvc @ComponentScan public class WebMvcConfig implements WebMvcConfigurer {/*** 設(shè)置資源*/@Overridepublic void addResourceHandlers(ResourceHandlerRegistry registry) {//全部靜態(tài)資源,如果指定全部資源則全局異常捕獲無(wú)法傳遞到自定義的error.html頁(yè)面//registry.addResourceHandler("/webapp/**").addResourceLocations("classpath:/webapp/"); registry.addResourceHandler("/**").addResourceLocations("classpath:/static/");WebMvcConfigurer.super.addResourceHandlers(registry);}}

Step14. 在static 文件夾下建立一個(gè)html，代碼如下：

<!DOCTYPE html> <html> <head> <meta charset="UTF-8"><title>Quartz任務(wù)管理</title><link rel="stylesheet" href="https://unpkg.com/element-ui@2.0.5/lib/theme-chalk/index.css"><script src="https://unpkg.com/vue/dist/vue.js"></script><script src="https://cdn.bootcss.com/vue-validator/2.1.5/vue-validator.js"></script><script src="http://cdn.bootcss.com/vue-resource/1.3.4/vue-resource.js"></script><script src="https://unpkg.com/element-ui@2.0.5/lib/index.js"></script><style> #top {background:#20A0FF;padding:5px;overflow:hidden}</style></head> <body><div id="test"> <div id="top"> <el-button type="text" @click="search" style="color:white">查詢(xún)</el-button> <el-button type="text" @click="handleadd" style="color:white">添加</el-button> </span> </div> <br/><div style="margin-top:15px"> <el-tableref="testTable" :data="tableData"style="width:100%"border><el-table-columnprop="job_NAME"label="任務(wù)名稱(chēng)"sortableshow-overflow-tooltip></el-table-column><el-table-columnprop="job_GROUP"label="任務(wù)所在組"width="120"sortable></el-table-column><el-table-columnprop="job_CLASS_NAME"label="任務(wù)類(lèi)名"sortable></el-table-column><el-table-columnprop="trigger_NAME"label="觸發(fā)器名稱(chēng)"sortable></el-table-column><el-table-columnprop="trigger_GROUP"label="觸發(fā)器所在組"width="120"sortable></el-table-column><el-table-columnprop="cron_EXPRESSION"label="表達(dá)式"sortable></el-table-column><el-table-columnprop="time_ZONE_ID"label="時(shí)區(qū)"sortable></el-table-column><el-table-column label="操作" width="300"><template scope="scope"><el-buttonsize="small"type="warning"@click="handlePause(scope.$index, scope.row)">暫停</el-button><el-buttonsize="small"type="info"@click="handleResume(scope.$index, scope.row)">恢復(fù)</el-button><el-buttonsize="small"type="danger"@click="handleDelete(scope.$index, scope.row)">刪除</el-button><el-buttonsize="small"type="success"@click="handleUpdate(scope.$index, scope.row)">修改</el-button></template></el-table-column></el-table><div align="center"><el-pagination@size-change="handleSizeChange"@current-change="handleCurrentChange":current-page="currentPage":page-sizes="[10, 20, 30, 40]":page-size="pagesize"layout="total, sizes, prev, pager, next, jumper":total="totalCount"></el-pagination></div></div> <el-dialog title="添加任務(wù)" :visible.sync="dialogFormVisible" width="500px"><el-form :model="form"><el-form-item label="任務(wù)名稱(chēng)" label-width="120px" style="width:400px"><el-input v-model="form.jobName" auto-complete="off"></el-input></el-form-item><el-form-item label="任務(wù)分組" label-width="120px" style="width:400px"><el-input v-model="form.jobGroup" auto-complete="off"></el-input></el-form-item><el-form-item label="表達(dá)式" label-width="120px" style="width:400px"><el-input v-model="form.cronExpression" auto-complete="off"></el-input></el-form-item><el-form-item label="備注信息" label-width="120px" style="width:400px"><el-input type="textarea" v-model="form.description" auto-complete="off"></el-input></el-form-item></el-form><div slot="footer" class="dialog-footer"><el-button @click="dialogFormVisible = false">取 消</el-button><el-button type="primary" @click="add">確 定</el-button></div></el-dialog><el-dialog title="修改任務(wù)" :visible.sync="updateFormVisible" width="500px"><el-form :model="updateform"><el-form-item label="表達(dá)式" label-width="120px" style="width:400px"><el-input v-model="updateform.cronExpression" auto-complete="off"></el-input></el-form-item><el-form-item label="備注信息" label-width="120px" style="width:400px"><el-input type="textarea" v-model="form.description" auto-complete="off"></el-input></el-form-item></el-form><div slot="footer" class="dialog-footer"><el-button @click="updateFormVisible = false">取 消</el-button><el-button type="primary" @click="update">確 定</el-button></div></el-dialog></div><footer align="center"><p>&copy; Quartz 任務(wù)管理</p></footer><script>var vue = new Vue({ el:"#test",data: { //表格當(dāng)前頁(yè)數(shù)據(jù)tableData: [],//請(qǐng)求的URLurl:'job/queryjob',//默認(rèn)每頁(yè)數(shù)據(jù)量pagesize: 10, //當(dāng)前頁(yè)碼currentPage: 1,//查詢(xún)的頁(yè)碼start: 1,//默認(rèn)數(shù)據(jù)總數(shù)totalCount: 1000,//添加對(duì)話(huà)框默認(rèn)可見(jiàn)性dialogFormVisible: false,//修改對(duì)話(huà)框默認(rèn)可見(jiàn)性u(píng)pdateFormVisible: false,//提交的表單form: {jobName: '',jobGroup: '',cronExpression: '',description:'',},updateform: {jobName: '',jobGroup: '',cronExpression: '',description:'',},},methods: {//從服務(wù)器讀取數(shù)據(jù)loadData: function(pageNum, pageSize){ this.$http.get('job/queryjob?' + 'pageNum=' + pageNum + '&pageSize=' + pageSize).then(function(res){console.log(res)this.tableData = res.body.JobAndTrigger.list;this.totalCount = res.body.number;},function(){console.log('failed');}); }, //單行刪除handleDelete: function(index, row) {this.$http.post('job/deletejob',{"jobClassName":row.job_NAME,"jobGroupName":row.job_GROUP},{emulateJSON: true}).then(function(res){this.loadData( this.currentPage, this.pagesize);},function(){console.log('failed');});},//暫停任務(wù)handlePause: function(index, row){this.$http.post('job/pausejob',{"jobClassName":row.job_NAME,"jobGroupName":row.job_GROUP},{emulateJSON: true}).then(function(res){this.loadData( this.currentPage, this.pagesize);},function(){console.log('failed');});},//恢復(fù)任務(wù)handleResume: function(index, row){this.$http.post('job/resumejob',{"jobClassName":row.job_NAME,"jobGroupName":row.job_GROUP},{emulateJSON: true}).then(function(res){this.loadData( this.currentPage, this.pagesize);},function(){console.log('failed');});},//搜索search: function(){this.loadData(this.currentPage, this.pagesize);},//彈出對(duì)話(huà)框handleadd: function(){ this.dialogFormVisible = true; },//添加add: function(){this.$http.post('job/addjob',{"jobClassName":this.form.jobName,"jobGroupName":this.form.jobGroup,"cronExpression":this.form.cronExpression,"description":this.form.description},{emulateJSON: true}).then(function(res){this.loadData(this.currentPage, this.pagesize);this.dialogFormVisible = false;},function(){console.log('failed');});this.form.jobName="";},//更新handleUpdate: function(index, row){console.log(row)this.updateFormVisible = true;this.updateform.jobName = row.job_CLASS_NAME;this.updateform.jobGroup = row.job_GROUP;},//更新任務(wù)update: function(){this.$http.post('job/reschedulejob',{"jobClassName":this.updateform.jobName,"jobGroupName":this.updateform.jobGroup,"cronExpression":this.updateform.cronExpression,"description":this.form.description},{emulateJSON: true}).then(function(res){this.loadData(this.currentPage, this.pagesize);this.updateFormVisible = false;},function(){console.log('failed');});},//每頁(yè)顯示數(shù)據(jù)量變更handleSizeChange: function(val) {this.pagesize = val;this.loadData(this.currentPage, this.pagesize);},//頁(yè)碼變更handleCurrentChange: function(val) {this.currentPage = val;this.loadData(this.currentPage, this.pagesize);}, }, });//載入數(shù)據(jù)vue.loadData(vue.currentPage, vue.pagesize);</script> </body> </html>

這樣所有的東西都完成啦，運(yùn)行一下就好啦，運(yùn)行效果如下：

?

總結(jié)

以上是生活随笔為你收集整理的SpringBoot 整合QUARTZ 并嵌入可视化界面的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。