SpringBoot结合Quartz实现数据库存储-FinClip官网

SpringBoot结合Quartz实现数据库存储

网友投稿 1029 2022-11-07

SpringBoot结合Quartz实现数据库存储

目录一、先创建一个SpringBoot项目二、导入依赖三、导入DruidConnectionProvider.java(Druid连接池的Quartz扩展类)四、修改自定义quartz.properties配置(在项目中添加quartz.properties文件(这样就不会加载自带的properties文件) )五、自定义MyJobFactory，解决spring不能在quartz中注入bean的问题六、创建调度器schedule七、创建自定义任务八、更新quartz中的任务小结：

一、先创建一个SpringBoot项目

还有一个截屏忘了截屏，就是选择保存路径选择一下就点Finish就可以了。

更改application.properties为application.yml

application.yml文件如下

server:

port: 8080

#数据库连接池druid配置

spring:

datasource:

#1.JDBC

type: com.alibaba.druid.pool.DruidDataSource

driver-class-name: com.mysql.cj.jdbc.Driver

url: jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false

username: root

password: 123

druid:

#2.连接池配置

#初始化连接池的连接数量大小，最小，最大

initial-size: 5

min-idle: 5

max-active: 20

#配置获取连接等待超时的时间

max-wait: 60000

#配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒

time-between-eviction-runs-millis: 60000

# 配置一个连接在池中最小生存的时间，单位是毫秒

min-evictable-idle-time-millis: 30000

validation-query: SELECT 1 FROM DUAL

test-while-idle: true

test-on-borrow: true

test-on-return: false

# 是否缓存preparedStatement，也就是PSCache 官方建议MySQL下建议关闭个人建议如果想用SQL防火墙建议打开

pool-prepared-statements: true

max-pool-prepared-statement-per-connection-size: 20

# 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙

filter:

stat:

merge-sql: true

slow-sql-millis: 5000

#3.基础监控配置

web-stat-filter:

enabled: true

url-pattern: /*

#设置不统计哪些URL

exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"

session-stat-enable: true

session-stat-max-count: 100

stat-view-servlet:

enabled: true

url-pattern: /druid/*

reset-enable: true

#设置监控页面的登录名和密码

allow: 127.0.0.1

mybatis:

mapper-locations: classpath*:mapper/*.xml

type-aliases-package: com.zking.quartz02.model

二、导入依赖

1.导入Quartz依赖

org.quartz-scheduler

quartz-jobs

2.2.1

org.springframework.boot

spring-boot-starter-quartz

2.用于我用的是Druid数据库连接池，所以我需要更换成Druid连接池，先引入Druid依赖。

com.alibaba

druid-spring-boot-starter

1.1.10

三、导入DruidConnectionProvider.java(Druid连接池的Quartz扩展类)

package com.zking.quartz02.utils;

import com.alibaba.druid.pool.DruidDataSource;

import org.quartz.SchedulerException;

import org.quartz.utils.ConnectionProvider;

import java.sql.Connection;

import java.sql.SQLException;

#============================================================================

# JDBC

#============================================================================

org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate

org.quartz.jobStore.useProperties:false

org.quartz.jobStore.dataSource:qzDS

#org.quartz.dataSource.qzDS.connectionProvider.class:org.quartz.utils.PoolingConnectionProvider

org.quartz.dataSource.qzDS.connectionProvider.class:com.zking.q03.quartz.DruidConnectionProvider

org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver

org.quartz.dataSource.qzDS.URL:jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8

org.quartz.dataSource.qzDS.user:root

org.quartz.dataSource.qzDS.password:root

org.quartz.dataSource.qzDS.maxConnections:30

org.quartz.dataSource.qzDS.validationQuery: select 0

/**

* [Druid连接池的Quartz扩展类]

public class DruidConnectionProvider implements ConnectionProvider {

* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

* 常量配置，与quartz.properties文件的key保持一致(去掉前缀)，同时提供set方法，Quartz框架自动注入值。

* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

//JDBC驱动

public String driver;

//JDBC连接串

public String URL;

//数据库用户名

public String user;

//数据库用户密码

public String password;

//数据库最大连接数

public int maxConnection;

//数据库SQL查询每次连接返回执行到连接池，以确保它仍然是有效的。

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;

* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

* 接口实现

* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

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(this.DEFAULT_DB_MAX_CACHED_STATEMENTS_PER_CONNECTION);

if (this.validationQuery != null) {

datasource.setValidationQuery(this.validationQuery);

if(!this.validateOnCheckout)

datasource.setTestOnReturn(true);

else

datasource.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 idleConnectionValYpfXXidationSeconds;

}

public void setIdleConnectionValidationSeconds(int idleConnectionValidationSeconds) {

this.idleConnectionValidationSeconds = idleConnectionValidationSeconds;

}

public DruidDataSource getDatasource() {

return datasource;

}

public void setDatasource(DruidDataSource datasource) {

this.datasource = datasource;

}

四、修改自定义quartz.properties配置(在项目中添加quartz.properties文件(这样就不会加载自带的properties文件) )

#============================================================================

# Configure Main Scheduler Properties \u8C03\u5EA6\u5668\u5C5E\u6027

#============================================================================

org.quartz.scheduler.instanceName: DefaultQuartzScheduler

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

#============================================================================

#\u5B58\u50A8\u65B9\u5F0F\u4F7F\u7528JobStoreTX\uFF0C\u4E5F\u5C31\u662F\u6570\u636E\u5E93

org.quartz.jobStore.class: org.quartz.impl.jdbcjobstore.JobStoreTX

org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate

#\u4F7F\u7528\u81EA\u5DF1\u7684\u914D\u7F6E\u6587\u4EF6

org.quartz.jobStore.useProperties:true

#\u6570\u636E\u5E93\u4E2Dquartz\u8868\u7684\u8868\u540D\u524D\u7F00

org.quartz.jobStore.tablePrefix:qrtz_

org.quartz.jobStore.dataSource:qzDS

#\u662F\u5426\u4F7F\u7528\u96C6\u7FA4\uFF08\u5982\u679C\u9879\u76EE\u53EA\u90E8\u7F72\u5230 \u4E00\u53F0\u670D\u52A1\u5668\uFF0C\u5C31\u4E0D\u7528\u4E86\uFF09

org.quartz.jobStore.isClustered = true

#============================================================================

# Configure Datasources

#============================================================================

#\u914D\u7F6E\u6570\u636E\u5E93\u6E90

org.quartz.dataSource.qzDS.connectionProvider.class: com.zking.quartz02.utils.DruidConnectionProvider

org.quartz.dataSource.qzDS.driver: com.mysql.cj.jdbc.Driver

#修改为自己的数据库名称、用户名和密码

org.quartz.dataSource.qzDS.URL: jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false

org.quartz.dataSource.qzDS.user: root

org.quartz.dataSource.qzDS.password: 123

org.quartz.dataSource.qzDS.maxConnection: 10

在数据库中创建quartz相关的表进入quartz的官网http://quartz-scheduler.org/，点击Downloads， -后在目录\docs\dbTables下有常用数据库创建quartz表的脚本，例如：“tables_mysql.sql”

五、自定义MyJobFactory，解决spring不能在quartz中注入bean的问题

package com.zking.quartz02.quartz;

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不能在quartz中注入bean的问题

@Component

public class MyJobFactory extends AdaptableJobFactory {

@Autowired

private AutowireCapableBeanFactory autowireCapableBeanFactory;

@Override

protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {

Object jobInstance = super.createJobInstance(bundle);

autowireCapableBeanFactory.autowireBean(jobInstance);

return jobInstance;

}

六、创建调度器schedule

package com.zking.quartz02.quartz;

//quartz配置类将调度器交给spring管理

import org.quartz.Scheduler;

import org.quartz.SchedulerFactory;

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.Scheduled;

import org.springframework.scheduling.quartz.SchedulerFactoryBean;

import java.io.IOException;

import java.util.Properties;

@Configuration

public class QuartzConfiguration {

@Autowired

private MyJobFactory myJobFactory;

@Bean

public Scheduler scheduler(){

return this.getSchedulerFactoryBean().getScheduler();

}

//读取自定义配置文件，获取调度器工厂

@Bean

public SchedulerFactoryBean getSchedulerFactoryBean(){

//1.创建SchedulerFactoryBean sc=new SchedulerFactoryBean

SchedulerFactoryBean sc=new SchedulerFactoryBean();

//2.加载自定义的quartz.properties

sc.setQuartzProperties(this.getProperties());

//3.设置自定义的MyJobFactory

sc.setJobFactory(myJobFactory);

return sc;

}

//读取配置文件

@Bean

public Properties getProperties(){

try {

PropertiesFactoryBean propertiesFactoryBean =

new PropertiesFactoryBean();

//设置自定义配置文件位置

propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));

//读取配置文件

propertiesFactoryBean.afterPropertiesSet();

return propertiesFactoryBean.getObject();

} catch (IOException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

七、创建自定义任务

首先我们需要自己创建一张表t_schedule_trigger，用来存放trigger的信息，然后从数据库读取这些信息来随时更新定时任务注意：job_name存放的任务类的全路径，在quartz中通过jobName和jobGroup来确定trigger的唯一性，所以这两列为联合唯一索引

t_schedule_trigger和t_schedule_trigger_param表生成的sql代码如下(去执行一下sql语句即可)

-- 注意：job_name存放的任务类的全路径，在quartz中通过jobName和jobGroup来确定trigger的唯一性，所以这两列为联合唯一索引

create table t_schedule_trigger

(

id int primary key auto_increment, -- ID

cron varchar(200) not null, -- 时间表达式

status char(1) not null, -- 使用状态 0：禁用 1：启用

job_name varchar(200) not null, -- 任务名称

job_group varchar(200) not null, -- 任务分组

unique index(job_name,job_group)

);

-- 额外添加到任务中的参数

create table t_schedule_trigger_param

(

param_id int primary key auto_increment, -- ID

name varchar(200) not null, -- 参数名

value varchar(512), -- 参数值

schedule_trigger_id int not null, -- 外键：引用t_schedule_trigger(id)

foreign key(schedule_trigger_id) references t_schedule_trigger(id)

);

注1：t_schedule_trigger的子表t_schedule_trigger_param还可以用来传递额外添加到任务中的参数

注2：实现org.quartz.Job或org.springframework.scheduling.quartz.QuartzJobBean创建任务，可通过JobExecutionContext传参

八、更新quartz中的任务

首先我们将t_schedule_trigger和t_schedule_trigger_param通过generatorConfig.xml自动生成实体类，XXmapper.java，XXmapper.xml.

"http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd" >

connectionURL="jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=UTF-8" userId="root" password="123"/>

targetProject="src/main/java">

targetProject="src/main/resources">

targetProject="src/main/java" type="XMLMAPPER">

enableCountByExample="false" enableDeleteByExample="false"

enableSelectByExample="false" enableUpdateByExample="false">

connectionURL="jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=UTF-8" userId="root" password="123"/>

targetProject="src/main/java">

targetProject="src/main/resources">

targetProject="src/main/java" type="XMLMAPPER">

enableCountByExample="false" enableDeleteByExample="false"

enableSelectByExample="false" enableUpdateByExample="false">

enableCountByExample="false" enableDeleteByExample="false"

enableSelectByExample="false" enableUpdateByExample="false">

记得修改数据库jdbc驱动jar包的位置为自己数据库jdbc驱动jar包的位置，jdbc连接数据库名、用户名和密码改为自己的。

注意：targetPackage改成自己的包名。

自动生成操作

命令：mybatis-generator:generate -e

注意：实体类上加一个@Data,XXmapper.java上加一个@Repository自己需要写一个查询全部的方法。

写一个IScheduleService接口，用来定时刷新任务，更新调度器中的任务

package com.zking.quartz02.service;

public interface IScheduleService {

//定时刷新任务，更新调度器中的任务

public void refresh();

}

实现IScheduleService接口

package com.zking.quartz02.service.impl;

import com.zking.quartz02.mapper.ScheduleTriggerMapper;

import com.zking.quartz02.mapper.ScheduleTriggerParamMapper;

import com.zking.quartz02.model.ScheduleTrigger;

import com.zking.quartz02.model.ScheduleTriggerParam;

import com.zking.quartz02.service.IScheduleService;

import org.quartz.*;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Service;

import javax.annotation.Resource;

import java.util.List;

@Service

public class ScheduleServiceImpl implements IScheduleService {

@Resource

private ScheduleTriggerMapper scheduleTriggerMapper;

@Resource

private ScheduleTriggerParamMapper scheduleTriggerParamMapper;

@Resource

private Scheduler scheduler;

@Scheduled(cron = "*/10 * * * * ?")

@Override

public void refresh() {

try {

//1.查询数据库中所有的任务

List

scheduleTriggerMapper.listScheduleTrigger();

//2.遍历所有任务

for (ScheduleTrigger scheduleTrigger : scheduleTriggers) {

Integer id = scheduleTrigger.getId();

String cron = scheduleTrigger.getCron();

String status = scheduleTrigger.getStatus();

String jobName = scheduleTrigger.getJobName();

String jobGroup = scheduleTrigger.getJobGroup();

//设置triggerKey

TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);

//通过triggerKey获取调度器中的触发器

CronTrigger cronTrigger = (CronTrigger)scheduler.getTrigger(triggerKey);

if(null==cronTrigger){//如果为空,表示调度器中没有该任务，不存在就添加任务

if("0".equals(status)){//如果该任务状态为0,表示该任务不用添加，此次循环结束

continue;

}

//创建触发器

CronTrigger cronTrigger1 = TriggerBuilder.newTrigger()

.withIdentity(jobName, jobGroup)

.withSchedule(CronScheduleBuilder.cronSchedule(cron))

.build();

//创建工作详情实例

JobDetail jobDetail = JobBuilder.newJob((Class extends Job>) Class.forName(jobName))

.withIdentity(jobName, jobGroup)

.build();

JobDataMap jobDataMap = jobDetail.getJobDataMap();

//查询该任务中所有的参数

List scheduleTriggerParams = scheduleTriggerParamMapper.listScheduleTriggerParamById(id);

//遍历所有参数，将参数设置到jobDataMap中

for (ScheduleTriggerParam scheduleTriggerParam : scheduleTriggerParams) {

jobDataMap.put(scheduleTriggerParam.getName(),scheduleTriggerParam.getValue());

}

//添加任务，将触发器和工作详情实例添加到调度器中

scheduler.scheduleJob(jobDetail,cronTrigger1);

}else{//如果不为空，表示调度器中存在该任务

if("0".equals(status)){//如果任务状态改为禁用，移除该任务

JobKey jobKey = JobKey.jobKey(jobName, jobGroup);

scheduler.deleteJob(jobKey);//移除任务

}

//如果调度器中的触发器的表达式和数据库中的表达式不一致

//获取调度器中触发器的表达式

String cronExpression = cronTrigger.getCronExpression();

if(!cronExpression.equals(cron)){//不一致

//重新创建新的触发器

CronTrigger cronTrigger2 = TriggerBuilder.newTrigger()

.withIdentity(jobName, jobGroup)

.withSchedule(CronScheduleBuilder.cronSchedule(cron))

.build();

//更新调度器中的触发器

scheduler.rescheduleJob(triggerKey,cronTrigger2);

}

} catch (Exception e) {

e.printStackTrace();

throw new RuntimeException(e);

}

1) service层实现类使用@Scheduled注解声明一个方法用于定时刷新数据库中的调度任务； 2) 使用@Resource注解注入Scheduler，在第5点中已装配到Spring上下文；

3) 在启动类上加入@MapperScan(指定要变成实现类的接口所在的包路径，比如我的就是com.zking.quartz02.mapper)，然后包下面的所有接口在编译之后都会生成相应的实现类； 4) 在启动类上加入@EnableScheduling启动Spring自带定时器任务；

小结：

要搞清楚一个问题：从数据库读取任务信息动态生成定时任务，和把quartz持久化到数据库是没有关系的。前者是我们自己定义的业务表，而后者是quartz使用自己的表来存储信息。持久化到数据库后，就算服务器重启或是多个quartz节点也没关系，因为他们共享数据库中的任务信息。

scheduleTriggerMapper.listScheduleTrigger();

//2.遍历所有任务

for (ScheduleTrigger scheduleTrigger : scheduleTriggers) {

Integer id = scheduleTrigger.getId();

String cron = scheduleTrigger.getCron();

String status = scheduleTrigger.getStatus();

String jobName = scheduleTrigger.getJobName();

String jobGroup = scheduleTrigger.getJobGroup();

//设置triggerKey

TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);

//通过triggerKey获取调度器中的触发器

CronTrigger cronTrigger = (CronTrigger)scheduler.getTrigger(triggerKey);

if(null==cronTrigger){//如果为空,表示调度器中没有该任务，不存在就添加任务

if("0".equals(status)){//如果该任务状态为0,表示该任务不用添加，此次循环结束

continue;

}

//创建触发器

CronTrigger cronTrigger1 = TriggerBuilder.newTrigger()

.withIdentity(jobName, jobGroup)

.withSchedule(CronScheduleBuilder.cronSchedule(cron))

.build();

//创建工作详情实例

JobDetail jobDetail = JobBuilder.newJob((Class extends Job>) Class.forName(jobName))

.withIdentity(jobName, jobGroup)

.build();

JobDataMap jobDataMap = jobDetail.getJobDataMap();

//查询该任务中所有的参数

List scheduleTriggerParams = scheduleTriggerParamMapper.listScheduleTriggerParamById(id);

//遍历所有参数，将参数设置到jobDataMap中

for (ScheduleTriggerParam scheduleTriggerParam : scheduleTriggerParams) {

jobDataMap.put(scheduleTriggerParam.getName(),scheduleTriggerParam.getValue());

}

//添加任务，将触发器和工作详情实例添加到调度器中

scheduler.scheduleJob(jobDetail,cronTrigger1);

}else{//如果不为空，表示调度器中存在该任务

if("0".equals(status)){//如果任务状态改为禁用，移除该任务

JobKey jobKey = JobKey.jobKey(jobName, jobGroup);

scheduler.deleteJob(jobKey);//移除任务

}

//如果调度器中的触发器的表达式和数据库中的表达式不一致

//获取调度器中触发器的表达式

String cronExpression = cronTrigger.getCronExpression();

if(!cronExpression.equals(cron)){//不一致

//重新创建新的触发器

CronTrigger cronTrigger2 = TriggerBuilder.newTrigger()

.withIdentity(jobName, jobGroup)

.withSchedule(CronScheduleBuilder.cronSchedule(cron))

.build();

//更新调度器中的触发器

scheduler.rescheduleJob(triggerKey,cronTrigger2);

}

} catch (Exception e) {

e.printStackTrace();

throw new RuntimeException(e);

}

1) service层实现类使用@Scheduled注解声明一个方法用于定时刷新数据库中的调度任务； 2) 使用@Resource注解注入Scheduler，在第5点中已装配到Spring上下文；

小结：

小程序开发制作公司：打造独特的移动应用体验

1029 2022-11-07

SpringBoot结合Quartz实现数据库存储

小程序三方平台开发: 解析小程序开发的未来趋势和机遇

小程序开发制作公司：打造独特的移动应用体验

小程序开发基础: 从零开始打造自己的小程序

最近发表

更多内容

小程序SDK

Finclip技术文档

小程序开发

小程序容器

小程序框架

Finclip小程序平台

Finclip用户投稿

车联网

推荐文章

小程序SDK是什么意思？小程序sdk和插件有什么区别？

小程序支付功能怎么实现？

企业app开发流程是什么？

app运营模式有哪些？

小程序多端引流怎么做？

小程序生态分析的机会和威胁

Flutter入门这一篇效率文章就够了

原生与跨平台解决方案分析,跨平台软件开发技术方案

热更新技术：让软件更新变得更加轻松快速

解决方案

银行解决方案

证券解决方案

互联网解决方案

政企OA解决方案

科技解决方案

loT解决方案

信任解决方案

热评文章

AppCan:基于混合模式的移动应用开发,移动混合模

Hybrid App混合模式开发的了解

小程序容器技术助力券商数字营销突围，小程序容器化的意

用mpvue开发微信小程序基础知识（vue.js开发

小程序多端框架全面测评对比，强烈推荐！

券商app架构 - 解析券商应用程序的构建与设计