IT评测·应用市场-qidao123.com

标题: Quartz---Springboot项目整合Quartz---实现内存、数据库持久化 [打印本页]

---

作者: 铁佛    时间: 2024-8-6 23:36
标题: Quartz---Springboot项目整合Quartz---实现内存、数据库持久化
1.SpringBoot整合Quartz使用内存持久化

1.1.什么是内存持久化

   Quartz的内存持久化是指Quartz框架在默认环境下将任务调理的运行信息保存在内存中。这种方式的优点是可以提供最佳的性能，因为内存中数据访问最快。然而，内存持久化的缺点是缺乏数据的持久性。当程序制止或系统崩溃时，所有运行的信息都会丢失。
  1.2.步调如下

1.2.1. 添加依靠


起首，在pom.xml文件中添加Quartz的依靠项。

2. <dependency>  
3.     <groupId>org.springframework.boot</groupId>  
4.     <artifactId>spring-boot-starter-quartz</artifactId>  
5. </dependency>

复制代码

 
1.2.2. 创建Job类


实现org.quartz.Job接口或org.quartz.StatefulJob接口，并覆盖execute方法。

2. import org.quartz.Job;  
3. import org.quartz.JobExecutionContext;  
4. import org.quartz.JobExecutionException;  
5.   
6. public class MyJob implements Job {  
7.     @Override  
8.     public void execute(JobExecutionContext context) throws JobExecutionException {  
9.         // 执行作业逻辑  
10.     }  
11. }

复制代码

1.2.3. 创建JobDetail和Trigger


使用JobBuilder和TriggerBuilder来创建JobDetail和Trigger实例，并通过调理器将它们关联起来。

2. import org.quartz.*;  
3. import org.springframework.context.annotation.Bean;  
4. import org.springframework.context.annotation.Configuration;  
5.   
6. @Configuration  
7. public class QuartzConfig {  
8.     //创建JobDetailr实例
9.     @Bean  
10.     public JobDetail myJobDetail() {  
11.         return JobBuilder.newJob(MyJob.class)  
12.                 .withIdentity("myJob", "group1")  
13.                 .storeDurably()  
14.                 .build();  
15.     }  
16.     //创建调度器和Trigge并管理jobDetail
17.     @Bean  
18.     public Trigger myTrigger() {  
19.         SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()  
20.                 .withIntervalInSeconds(5)  //每5秒执行一次任务
21.                 .repeatForever();  
22.   
23.         return TriggerBuilder.newTrigger()  
24.                 .forJob(myJobDetail())  
25.                 .withIdentity("myTrigger", "group1")  
26.                 .withSchedule(scheduleBuilder)  
27.                 .build();  
28.     }  
29. }

复制代码

1.2.4. 启动应用


运行你的Spring Boot应用，Quartz将会根据配置主动启动，并按照你定义的Trigger来触发并执行作业。
1.2.实例

   定时执行任务，查找数据库中预约时间过期的数据并将车位状态实时更新。
  1.2.1数据库数据说明

预约记录表单

车位表单中的id作为预约表单的外键

1.2.2.关键代码

对job类进行修改

1. package com.duhong.quartz;
3. import com.duhong.entity.OrderParking;
4. import com.duhong.service.OrderService;
5. import org.quartz.*;
6. import org.springframework.beans.factory.annotation.Autowired;
7. import org.springframework.boot.autoconfigure.batch.BatchProperties;
8. import org.springframework.boot.autoconfigure.quartz.QuartzDataSource;
9. import org.springframework.context.annotation.Configuration;
10. import org.springframework.stereotype.Component;
12. import java.time.LocalDateTime;
13. import java.util.List;
14. @PersistJobDataAfterExecution
15. @DisallowConcurrentExecution
16. public class UpdateJob implements Job {
17.     @Autowired
18.     OrderService orderService;
20.     @Override
21.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
22.          //查询所有预约记录
23.         List<OrderParking> orderParkings = orderService.selectRecord();
24.         for (OrderParking orderParking : orderParkings) {
25.             System.out.println("作业执行");
26.             System.out.println("到期时间"+orderParking.getDeadtime());
27.             System.out.println("当前时间"+LocalDateTime.now());
28.             //未到预约时间
29.             if(orderParking.getDeadtime().isBefore( LocalDateTime.now())){
30.                 //更新车位状态
31.                 orderService.updateInitStatus(orderParking.getId());
32.                 System.out.println("更新成功");
33.             }else{
34.                 System.out.println("未到预约时间");
35.             }
36.         }
37.     }
38. }

复制代码

1.2.3.执行结果

2.SpringBoot整合Quartz使用mysql持久化

2.1.为啥要使用数据库持久化

   Quartz 是一个开源的任务调理框架，用于在 Java 应用中执行定时任务。Quartz 自己不直接提供任务持久化的功能，但它支持将任务、触发器和其他相关信息存储到数据库中，以便在应用程序重启或服务器崩溃后恢复。
  选择 MySQL 作为 Quartz 的持久化存储有以下几个缘故原由：
  

• 通用性和普及性：MySQL 是一个广泛使用的开源关系型数据库管理系统，具有很高的通用性和普及性。许多开发者和团队都认识 MySQL，因此选择 MySQL 作为 Quartz 的持久化存储可以简化开发和维护过程。
  
• 稳定性和可靠性：MySQL 是一个成熟、稳定且经过广泛验证的数据库系统。它提供了良好的数据完整性和可靠性保证，可以确保 Quartz 任务调理的准确性和一致性。
  
• 性能优化：MySQL 在处理大量数据和复杂查询方面体现精彩。通过合理的索引和查询优化，可以确保 Quartz 在持久化任务时具有良好的性能体现。
  
• 社区支持和资源：由于 MySQL 的广泛使用和开源性子，它拥有庞大的用户社区和丰富的资源。这意味着在碰到题目时，可以更容易地找到解决方案或获得帮助。
  
• 扩展性和灵活性：MySQL 支持多种存储引擎和配置选项，可以根据实际需求进行灵活的配置和扩展。这使得它成为一个得当各种规模应用程序的持久化存储选择。
  

  2.2.持久化步调

基于对quartz使用内存持久化，我们只需添加数据库表及修改properities文件即可
2.2.1.添加数据库表

1. create table if not exists parking_place
2. (
3.    id int auto_increment
4.       primary key,
5.    location varchar(255) null,
6.    status int default 0 null,
7.    price double null,
8.    type varchar(255) null
9. );
11. create table if not exists qrtz_calendars
12. (
13.    SCHED_NAME varchar(120) not null,
14.    CALENDAR_NAME varchar(190) not null,
15.    CALENDAR blob not null,
16.    primary key (SCHED_NAME, CALENDAR_NAME)
17. );
19. create table if not exists qrtz_fired_triggers
20. (
21.    SCHED_NAME varchar(120) not null,
22.    ENTRY_ID varchar(95) not null,
23.    TRIGGER_NAME varchar(190) not null,
24.    TRIGGER_GROUP varchar(190) not null,
25.    INSTANCE_NAME varchar(190) not null,
26.    FIRED_TIME bigint(13) not null,
27.    SCHED_TIME bigint(13) not null,
28.    PRIORITY int not null,
29.    STATE varchar(16) not null,
30.    JOB_NAME varchar(190) null,
31.    JOB_GROUP varchar(190) null,
32.    IS_NONCONCURRENT varchar(1) null,
33.    REQUESTS_RECOVERY varchar(1) null,
34.    primary key (SCHED_NAME, ENTRY_ID)
35. );
37. create index IDX_QRTZ_FT_INST_JOB_REQ_RCVRY
38.    on qrtz_fired_triggers (SCHED_NAME, INSTANCE_NAME, REQUESTS_RECOVERY);
40. create index IDX_QRTZ_FT_JG
41.    on qrtz_fired_triggers (SCHED_NAME, JOB_GROUP);
43. create index IDX_QRTZ_FT_J_G
44.    on qrtz_fired_triggers (SCHED_NAME, JOB_NAME, JOB_GROUP);
46. create index IDX_QRTZ_FT_TG
47.    on qrtz_fired_triggers (SCHED_NAME, TRIGGER_GROUP);
49. create index IDX_QRTZ_FT_TRIG_INST_NAME
50.    on qrtz_fired_triggers (SCHED_NAME, INSTANCE_NAME);
52. create index IDX_QRTZ_FT_T_G
53.    on qrtz_fired_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP);
55. create table if not exists qrtz_job_details
56. (
57.    SCHED_NAME varchar(120) not null,
58.    JOB_NAME varchar(190) not null,
59.    JOB_GROUP varchar(190) not null,
60.    DESCRIPTION varchar(250) null,
61.    JOB_CLASS_NAME varchar(250) not null,
62.    IS_DURABLE varchar(1) not null,
63.    IS_NONCONCURRENT varchar(1) not null,
64.    IS_UPDATE_DATA varchar(1) not null,
65.    REQUESTS_RECOVERY varchar(1) not null,
66.    JOB_DATA blob null,
67.    primary key (SCHED_NAME, JOB_NAME, JOB_GROUP)
68. );
70. create index IDX_QRTZ_J_GRP
71.    on qrtz_job_details (SCHED_NAME, JOB_GROUP);
73. create index IDX_QRTZ_J_REQ_RECOVERY
74.    on qrtz_job_details (SCHED_NAME, REQUESTS_RECOVERY);
76. create table if not exists qrtz_locks
77. (
78.    SCHED_NAME varchar(120) not null,
79.    LOCK_NAME varchar(40) not null,
80.    primary key (SCHED_NAME, LOCK_NAME)
81. );
83. create table if not exists qrtz_paused_trigger_grps
84. (
85.    SCHED_NAME varchar(120) not null,
86.    TRIGGER_GROUP varchar(190) not null,
87.    primary key (SCHED_NAME, TRIGGER_GROUP)
88. );
90. create table if not exists qrtz_scheduler_state
91. (
92.    SCHED_NAME varchar(120) not null,
93.    INSTANCE_NAME varchar(190) not null,
94.    LAST_CHECKIN_TIME bigint(13) not null,
95.    CHECKIN_INTERVAL bigint(13) not null,
96.    primary key (SCHED_NAME, INSTANCE_NAME)
97. );
99. create table if not exists qrtz_triggers
100. (
101.    SCHED_NAME varchar(120) not null,
102.    TRIGGER_NAME varchar(190) not null,
103.    TRIGGER_GROUP varchar(190) not null,
104.    JOB_NAME varchar(190) not null,
105.    JOB_GROUP varchar(190) not null,
106.    DESCRIPTION varchar(250) null,
107.    NEXT_FIRE_TIME bigint(13) null,
108.    PREV_FIRE_TIME bigint(13) null,
109.    PRIORITY int null,
110.    TRIGGER_STATE varchar(16) not null,
111.    TRIGGER_TYPE varchar(8) not null,
112.    START_TIME bigint(13) not null,
113.    END_TIME bigint(13) null,
114.    CALENDAR_NAME varchar(190) null,
115.    MISFIRE_INSTR smallint(2) null,
116.    JOB_DATA blob null,
117.    primary key (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
118.    constraint qrtz_triggers_ibfk_1
119.       foreign key (SCHED_NAME, JOB_NAME, JOB_GROUP) references qrtz_job_details (SCHED_NAME, JOB_NAME, JOB_GROUP)
120. );
122. create table if not exists qrtz_blob_triggers
123. (
124.    SCHED_NAME varchar(120) not null,
125.    TRIGGER_NAME varchar(190) not null,
126.    TRIGGER_GROUP varchar(190) not null,
127.    BLOB_DATA blob null,
128.    primary key (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
129.    constraint qrtz_blob_triggers_ibfk_1
130.       foreign key (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) references qrtz_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP)
131. );
133. create index SCHED_NAME
134.    on qrtz_blob_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP);
136. create table if not exists qrtz_cron_triggers
137. (
138.    SCHED_NAME varchar(120) not null,
139.    TRIGGER_NAME varchar(190) not null,
140.    TRIGGER_GROUP varchar(190) not null,
141.    CRON_EXPRESSION varchar(120) not null,
142.    TIME_ZONE_ID varchar(80) null,
143.    primary key (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
144.    constraint qrtz_cron_triggers_ibfk_1
145.       foreign key (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) references qrtz_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP)
146. );
148. create table if not exists qrtz_simple_triggers
149. (
150.    SCHED_NAME varchar(120) not null,
151.    TRIGGER_NAME varchar(190) not null,
152.    TRIGGER_GROUP varchar(190) not null,
153.    REPEAT_COUNT bigint(7) not null,
154.    REPEAT_INTERVAL bigint(12) not null,
155.    TIMES_TRIGGERED bigint(10) not null,
156.    primary key (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
157.    constraint qrtz_simple_triggers_ibfk_1
158.       foreign key (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) references qrtz_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP)
159. );
161. create table if not exists qrtz_simprop_triggers
162. (
163.    SCHED_NAME varchar(120) not null,
164.    TRIGGER_NAME varchar(190) not null,
165.    TRIGGER_GROUP varchar(190) not null,
166.    STR_PROP_1 varchar(512) null,
167.    STR_PROP_2 varchar(512) null,
168.    STR_PROP_3 varchar(512) null,
169.    INT_PROP_1 int null,
170.    INT_PROP_2 int null,
171.    LONG_PROP_1 bigint null,
172.    LONG_PROP_2 bigint null,
173.    DEC_PROP_1 decimal(13,4) null,
174.    DEC_PROP_2 decimal(13,4) null,
175.    BOOL_PROP_1 varchar(1) null,
176.    BOOL_PROP_2 varchar(1) null,
177.    primary key (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
178.    constraint qrtz_simprop_triggers_ibfk_1
179.       foreign key (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) references qrtz_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP)
180. );
182. create index IDX_QRTZ_T_C
183.    on qrtz_triggers (SCHED_NAME, CALENDAR_NAME);
185. create index IDX_QRTZ_T_G
186.    on qrtz_triggers (SCHED_NAME, TRIGGER_GROUP);
188. create index IDX_QRTZ_T_J
189.    on qrtz_triggers (SCHED_NAME, JOB_NAME, JOB_GROUP);
191. create index IDX_QRTZ_T_JG
192.    on qrtz_triggers (SCHED_NAME, JOB_GROUP);
194. create index IDX_QRTZ_T_NEXT_FIRE_TIME
195.    on qrtz_triggers (SCHED_NAME, NEXT_FIRE_TIME);
197. create index IDX_QRTZ_T_NFT_MISFIRE
198.    on qrtz_triggers (SCHED_NAME, MISFIRE_INSTR, NEXT_FIRE_TIME);
200. create index IDX_QRTZ_T_NFT_ST
201.    on qrtz_triggers (SCHED_NAME, TRIGGER_STATE, NEXT_FIRE_TIME);
203. create index IDX_QRTZ_T_NFT_ST_MISFIRE
204.    on qrtz_triggers (SCHED_NAME, MISFIRE_INSTR, NEXT_FIRE_TIME, TRIGGER_STATE);
206. create index IDX_QRTZ_T_NFT_ST_MISFIRE_GRP
207.    on qrtz_triggers (SCHED_NAME, MISFIRE_INSTR, NEXT_FIRE_TIME, TRIGGER_GROUP, TRIGGER_STATE);
209. create index IDX_QRTZ_T_N_G_STATE
210.    on qrtz_triggers (SCHED_NAME, TRIGGER_GROUP, TRIGGER_STATE);
212. create index IDX_QRTZ_T_N_STATE
213.    on qrtz_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP, TRIGGER_STATE);
215. create index IDX_QRTZ_T_STATE
216.    on qrtz_triggers (SCHED_NAME, TRIGGER_STATE);

复制代码

2.2.2.持久化配置

1. quartz:
2.   # 将任务等保存化到数据库
3.   job-store-type: jdbc
4.   # 程序结束时会等待quartz相关的内容结束
5.   wait-for-jobs-to-complete-on-shutdown: true
6.   overwrite-existing-jobs: true
7.   properties:
8.     org:
9.       quartz:
10.         scheduler:
11.           # scheduler的实例名
12.           instanceName: scheduler
13.           #auto：自动生成唯一值
14.           instanceId: AUTO
15.         # 持久化相关
16.         jobStore:
17.           # 升级 springboot 版本，注释 class 属性
18.           # class: org.quartz.impl.jdbcjobstore.JobStoreTX
19.           # 数据库类型
20.           driverDelegateClass: org.quartz.impl.jdbcjobstore.PostgreSQLDelegate
21.           # 表示数据库表名前缀
22.           tablePrefix: QRTZ_
23.           useProperties: false
24.         # 线程池相关
25.         threadPool:
26.           class: org.quartz.simpl.SimpleThreadPool
27.           # 线程数
28.           threadCount: 10
29.           # 线程优先级
30.           threadPriority: 5
31.           threadsInheritContextClassLoaderOfInitializingThread: true

复制代码

2.2.3.重启实例，持久化成功

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

---

欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/)

Powered by Discuz! X3.4