如果沒有將任務進行持久化,當遇到程序版本更新、或機器宕機重啟后,那些沒有開始、或還沒有執行完的任務就沒了。所以我們需要把任務持久化到數據庫中。
```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**

建表的腳本在`org/quartz/impl/jdbcjobstore/`目錄下,我這里用`tables_mysql_innodb.sql`腳本。
```
# 這個是數據庫平臺,下面將會用到
# org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
```

<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配合