Springboot+quartz源码探索
这期和小伙伴们一起来看看 的 , 以 初始化表结构的源码为例子，来感受下这样的 思路 —— 只用配置文件时，这断点在哪里打 😝
前期准备
下面四大步骤，可以直接跳到第五步，进入正题！😝
一. pom 文件 引入 quartz jar包
org.springframework.boot
spring-boot-starter-quartz
二. 创建一个 并继承
@Slf4j
public class HelloWorldJob extends QuartzJobBean {
@Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
JobKey key = jobExecutionContext.getJobDetail().getKey();
log.info("[JobKey] name:{},group:{}",key.getName(),key.getGroup());
JobDataMap jobDataMap = jobExecutionContext.getJobDetail().getJobDataMap();
log.info("[jobDataMap] arg1:{},arg2:{}",jobDataMap.get("arg1"),jobDataMap.get("arg2"));
}
}
三. 创建 和
package com.java4ye.demo.config;
import com.java4ye.demo.job.HelloWorldJob;
import org.quartz.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class QuartzConfig {
@Bean
public JobDetail myJobDetail() {
return JobBuilder.newJob(HelloWorldJob.class)
.withIdentity("HelloWorldJob", "HelloWorldJob")
//JobDataMap可以给任务execute传递参数
.usingJobData("arg1", "Hello")
.usingJobData("arg2", "World")
.storeDurably()
.build();
}
@Bean
public Trigger myTrigger() {
return TriggerBuilder.newTrigger()
.forJob(myJobDetail())
.withIdentity("Hello World Job TRIGGER", "TRIGGER GROUP1")
.usingJobData("arg11","TRIGGER-arg11")
.usingJobData("arg1","TRIGGER-arg1")
.startNow()
//.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever())
.withSchedule(CronScheduleBuilder.cronSchedule("0/10 * * * * ?"))
.build();
}
}
四. 配置 application.yml
spring:
datasource:
url: jdbc:mysql://192.168.80.128:3306/4ye?useSSL=false&useUnicode=true&characterEncoding=utf-8
username: java4ye
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
quartz:
jdbc:
# 这里有 三个选项 always（每次都帮你创建表） never(自己手动建表) embedded 默认的
initialize-schema: always
#持久化到数据库方式
job-store-type: jdbc
properties:
org:
quartz:
scheduler:
instanceName: MysqlScheduler
instanceId: AUTO
startupDelay: 10
jobStore:
class: org.quartz.impl.jdbcjobstore.JobStoreTX
driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
tablePrefix: QRTZ_
isClustered: true
clusterCheckinInterval: 10000
useProperties: false
threadPool:
class: org.quartz.simpl.SimpleThreadPool
#线程数 一个任务使用一个线程
threadCount: 10
threadPriority: 5
threadsInheritContextClassLoaderOfInitializingThread: true
下面让我们走入正题 ~
探索 的初始化表结构 😝
五. debug 源码
1. 将项目跑起来
2. 步骤
按照图中四个步骤操作
没想到叭~ 😝
3. 打下断点: QuartzDataSourceInitializer ,并用debug方式启动
当当当当~ ，这样我们就完成了最重要的一步啦！打下了断点！！
如下图~ ， 剩下的就是 一步步 啦
按下 进去, 再进去 方法可以看到下图
注意这里有个
@PostConstruct注解的方法将会在依赖注入完成后被自动调用。
Constructor >> @Autowired >> @PostConstruct
所以我们直接在这里打个断点
4. 打下断点如上图: @PostConstruct 并直接按f9 就可以到该方法了
直接进入到 方法 , 可以看到下图 : 由于我们配置的是
所以 在进行逻辑或运算时直接返回 true .不会执行后面的 代码
5. 执行 sql 语句代码 (重点)
从上图 下来 可以看到 会去加载图中这个路径下的 文件
我们来到 包中可以看到还有很多其他的 文件
6. 将 配置 修改为 Emembedded 默认的
代码会运行到
然后会来到这个 类
其实这里就可以看到 它支持的内嵌数据库类型了~
当然有程序作证 哈哈
最后可以发现当你使用的 数据库类型是内存型的，如 等时, 它会返回 。
即 ) 为 , 然后会去执行创建表格的 语句,如步骤5图中的sql文件
结论
一. 当我们用 配置文件的方式（如 .) 去配置程序的一些属性时，可以尝试从 的 入手，找到目标类，打下断点
二. 断点时，留意下 初始化顺序，执行顺序 ，比如 ，可以更快的找到我们想要的
三. 还可以故意配错属性，让程序抛出异常，然后进去打下断点，和我们平时遇到异常去打断点的思路差不多
四. 初始化表结构时,使用默认值 (内嵌的) 时，会去看看db的类型是不是属于下面几个 ， , ，是的话会执行初始化的
最后
欢迎小伙伴们来一起探讨问题~
如果你觉得本篇文章还不错的话，那拜托再点点赞支持一下呀😝
让我们开始这一场意外的相遇吧！~
欢迎留言！谢谢支持！ヾ(≧▽≦*)o 冲冲冲！！
我是 4ye 咱们下期应该……很快再见！！ 😆
喜欢的话可以关注下公众号 Java4ye 支持下 4ye 呀😝