如果没有将任务进行持久化,当遇到程序版本更新、或机器宕机重启后,那些没有开始、或还没有执行完的任务就没了。所以我们需要把任务持久化到数据库中。
```xml
<!-- 我用的 maven 坐标 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<version>8.0.32</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.16</version>
</dependency>
<dependency>
<groupId>com.mchange</groupId>
<artifactId>c3p0</artifactId>
<version>0.9.5.5</version>
</dependency>
```
步骤如下:
**1. 确定自己使用的数据库并建表,我这里用 MySQL**
![](https://img.kancloud.cn/37/ad/37ade834ed6abcd5a753ae59388eab96_1996x432.png)
建表的脚本在`org/quartz/impl/jdbcjobstore/`目录下,我这里用`tables_mysql_innodb.sql`脚本。
```
# 这个是数据库平台,下面将会用到
# org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
```
![](https://img.kancloud.cn/e9/c9/e9c9a1ee8e13b8474edfc3bc10c098b8_1827x299.png)
<br/>
**2. quartz 相关配置`applicaton.yml`**
```yml
spring:
quartz:
properties:
org:
quartz:
scheduler:
#调度器名称,随便一个字符串就行
instanceName: quartz02Cluster
#调度器ID。AUTO就是quartz自动生成
instanceId: AUTO
threadPool:
#线程池类,使用quartz自带的SimpleThreadPool也几乎满足所有用户的需求了
class: org.quartz.simpl.SimpleThreadPool
threadCount: 10
threadPriority: 5
jobStore:
#将任务存储到数据库中,默认是org.quartz.simpl.RAMJobStore,存储在内存中
class: org.quartz.impl.jdbcjobstore.JobStoreTX
#数据库平台,MySQL对应的就是StdJDBCDelegate
driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
useProperties: false
#是否在集群环境下使用,true是、false不是
isClustered: true
#quartz相关表的表名前缀,方便quartz定位到相关的表。可自定义,我这里保持和官方一样的就好
tablePrefix: qrtz_
#数据源别名,可自定义
dataSource: mysql
dataSource:
#mysql,就是上面的jobStore.dataSource: mysql 设置的别名
mysql:
driver: com.mysql.cj.jdbc.Driver
URL: jdbc:mysql://127.0.0.1:3306/quartzdb?useUnicode=true&characterEncoding=utf-8&useSSL=false
user: root
password: uhg</flEt3dff
#持久化到数据库
job-store-type: jdbc
jdbc:
#在项目启动时是否自动建quartz相关表,建议用never,不自动建表。
initialize-schema: never
```
****
其它配置参考:https://www.w3cschool.cn/quartz_doc/quartz_doc-i7oc2d9l.html
<br/>
**3. 定时任务要执行的业务代码**
```java
@Slf4j
public class GoogsJob extends QuartzJobBean {
@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
JobDataMap dataMap = context.getJobDetail().getJobDataMap();
log.info("name:{}", dataMap.get("name"));
}
}
```
<br/>
**4. 创建定时任务**
```java
@RestController
public class GoogsJobController {
@Autowired
private Scheduler scheduler;
@GetMapping("/goodsJob1")
public void goodsJob1() throws SchedulerException {
JobDetail jobDetail = JobBuilder
.newJob(GoogsJob.class)
.usingJobData("name", "劳斯劳斯")
.withIdentity("goods-job1", "job-group1")
.build();
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("goods-trigger1", "trigger-group1")
.startNow()
.withSchedule(
SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(4)
.repeatForever()
)
.build();
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();
}
}
```
<br/>
**5. 测试:创建任务后,日志输出如下**
```
2023-04-06T22:17:45 ...job.GoogsJob : name:劳斯劳斯
2023-04-06T22:17:49 ...job.GoogsJob : name:劳斯劳斯
2023-04-06T22:17:53 ...job.GoogsJob : name:劳斯劳斯
```
<br/>
**6. 测试:先关掉 SpringBoot 项目,然后再重启,任务就会自动恢复执行了**
```
2023-04-06T22:21:17 ...job.GoogsJob : name:劳斯劳斯
2023-04-06T22:21:21 ...job.GoogsJob : name:劳斯劳斯
2023-04-06T22:21:25 ...job.GoogsJob : name:劳斯劳斯
```
- Mybatis
- mybatis是什么
- mybatis优缺点
- 环境搭建
- 使用步骤
- 传参方式
- 无需传参
- 一个参数
- 多个参数
- 增/删/改
- 查询
- 单表查询
- 一对一查询
- 一对多查询
- 动态SQL
- 注解操作
- Spring
- Spring什么
- Spring优点
- Spring组成
- 第一个Spring程序
- 两大核心技术
- IoC控制反转
- IoC思想
- IoC容器使用步骤
- 属性注入
- IoC注入方式
- 模拟IoC实现
- AOP
- AOP概念
- AOP原理
- AOP关键术语
- AOP编程过程
- 切入点规则
- 5种增强方式
- Spring注解开发
- 注解开发的优势
- Bean注解开发
- AOP注解开发
- 完全注解开发
- 模拟Spring注解开发
- 自动装配
- 配置文件拆分
- SpringBean
- Bean常用属性
- Bean的作用域
- Bean的生命周期
- Spring整合MyBatis
- 整合步骤
- SqlSessionTemplate
- 业务层添加事务
- 事务的作用
- 配置文件事务
- 注解事务
- 事务参数
- SpringMVC
- SpringMVC是什么
- 环境搭建
- 请求流程
- 核心组件
- 前后端交互
- 简单交互演示
- 常用注解
- 后端数据传递至前端
- ServletAPI
- 访问静态资源
- 异常处理
- HandlerExceptionResolver
- 局部异常
- 全局异常
- 转发与重定向
- 转发演示
- 重定向演示
- 转发与重定向的区别
- 获取表单数据
- 表单标签
- REST风格的URL
- 异步处理
- 异步请求
- JSON数据处理
- 中文乱码处理
- 日期处理
- 上传文件
- 拦截器
- 视图解析器
- 视图类型
- 多视图解析器
- 自定义pdf视图
- JSR303数据验证
- JSR303是什么
- 常用约束
- 使用步骤
- SpringMVC整合Mybatis
- 整合步骤
- Mybatis分页插件
- SpringBoot
- SpringBoot是什么
- 环境搭建
- SpringBoot启动分析
- SpringBoot启动类
- 启动过程
- SpringBoot配置文件
- 配置文件类型
- 更改配置文件
- 读取配置文件
- 占位符
- 配置优先级
- 自定义IoC容器
- 定义方式
- 引入Spring配置文件
- @Configuration
- SpringBoot自动配置
- 自动配置原理
- 条件注解
- 自动配置报告
- 自定义自动配置
- 关闭自动配置
- 接管自动配置
- 多环境配置
- CommandLineRunner
- SpringBoot与Web开发
- 引入模板引擎
- Thymeleaf模板
- Freemarker模板
- 静态资源访问
- webjars
- 静态资源位置
- ico图标
- 指定首页
- 更换Web服务器
- 国际化
- 拦截器
- 错误处理机制
- 错误处理机制原理
- 定制错误页面
- 定制错误数据
- 上传文件
- 注册servlet三大组件
- 注册Servlet
- 注册过滤器
- 注册监听器
- 外部Tomcat与jsp模板
- 前后端交互
- 传递json字符串
- 传递js对象
- 传递表单
- 下载功能
- Swagger2文档
- SpringBoot整合JDBC
- 整合步骤
- 核心API
- JdbcTemplate
- 增删改
- 查询
- NamedParameterJdbcTemplate
- 增删改
- 查询
- SpringBoot整合Mybatis
- 整合步骤
- 切换为Druid数据源
- 添加事务
- Mybatis分页插件
- 场景启动器
- 场景启动器是什么
- 自定义场景启动器
- SpringBoot与日志
- 日志框架
- slf4j日志
- slf4j日志实现
- 统一切换为slf4j
- 日志配置
- 日志文件
- 切换日志框架
- 切换日志场景启动器
- SpringBoot与缓存
- JSR107缓存技术
- Spring缓存抽象
- 缓存注解
- SpEL表达式
- 使用缓存
- 自定义key生成器
- 缓存工作原理与流程
- SpringBoot整合Redis
- 整合步骤
- 初步使用
- 序列化机制
- 缓存管理器
- SpringBoot与任务
- 异步任务
- 实现异步任务
- 注意事项与原理
- 自定义线程池
- 定时任务
- cron表达式
- 创建定时任务
- @Scheduled参数
- 动态时间
- 邮件任务
- Quartz定时任务
- Quartz是什么
- 创建定时任务
- 触发器与任务
- 任务的CURD
- 两种触发器
- 并发问题
- 持久化
- 任务持久化
- Quartz集群
- misfire策略
- 打包插件
- appassembler-maven-plugin
- appassembler与assembly配合