这期和小伙伴们一起来看看 IDEA
的 Endpoints
, 以 Quartz
初始化表结构的源码为例子,来感受下这样的 debug
思路 —— 只用配置文件时,这断点在哪里打 😝
前期准备
下面四大步骤,可以直接跳到第五步,进入正题!😝
一. pom 文件 引入 quartz jar 包
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
复制代码
二. 创建一个 job
并继承 QuartzJobBean
@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"));
}
}
复制代码
三. 创建 JobDetail
和 Trigger
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
复制代码
下面让我们走入正题 ~
探索 quartz
的初始化表结构 😝
五. debug 源码
1. 将项目跑起来
2. 步骤
按照图中四个步骤操作
点击 Endpoints
输入 quartz
搜索
点击 quartzScheduler
按住 ctrl 键 + 鼠标滚轮
放大图片 (按住 alt 键 有放大镜功能), 然后点击 quartzDataSourceInitializer
,双击或者按F4
可以跳转到源码处 (看这个名字应该是初始化的,先进来看看有没有找错)
没想到叭~ 😝
3. 打下断点: QuartzDataSourceInitializer ,并用 debug 方式启动
当当当当~ ,这样我们就完成了最重要的一步啦!打下了断点!!
如下图~ , 剩下的就是 一步步 debug
啦
按下 F7
进去, 再进去 super(dataSource, resourceLoader);
方法可以看到下图
注意这里有个 @PostConstruct
@PostConstruct 注解的方法将会在依赖注入完成后被自动调用。
Constructor >> @Autowired >> @PostConstruct
所以我们直接在这里打个断点
4. 打下断点如上图: @PostConstruct 并直接按 f9 就可以到该方法了
直接进入到 isEnabled
方法 , 可以看到下图 : 由于我们配置的是 Always
所以 在进行逻辑或运算时直接返回 true .不会执行后面的 EmbeddedDatabaseConnection.isEmbedded(this.dataSource);
代码
5. 执行 sql 语句代码 (重点)
从上图 debug
下来 可以看到 会去加载图中这个路径下的 sql
文件
我们来到 jar
包中可以看到还有很多其他的 sql
文件
6. 将 配置 修改为 Emembedded 默认的
代码会运行到 EmbeddedDatabaseConnection.isEmbedded(this.dataSource);
然后会来到这个 EmbeddedDatabaseConnection
类
其实这里就可以看到 它支持的内嵌数据库类型了~
当然有程序作证 哈哈
最后可以发现当你使用的 数据库类型是内存型的,如 H2
等时, 它会返回 true
。
即 isEnabled(
) 为 True
, 然后会去执行创建表格的 sql
语句,如步骤 5 图中的 sql 文件
结论
一. 当我们用 配置文件的方式(如 application.yml
.) 去配置程序的一些属性时,可以尝试从 IDEA
的 Endpoints
入手,找到目标类,打下断点
二. 断点时,留意下 初始化顺序,执行顺序 ,比如 @PostConstruct
,可以更快的找到我们想要的
三. 还可以故意配错属性,让程序抛出异常,然后进去打下断点,和我们平时遇到异常去打断点的思路差不多
四. quartz
初始化表结构时,使用默认值 embedded
(内嵌的) 时,会去看看 db 的类型是不是属于下面几个 h2
, derby
,hsql
,是的话会执行初始化的SQL
最后
欢迎小伙伴们来一起探讨问题~
如果你觉得本篇文章还不错的话,那拜托再点点赞支持一下呀😝
让我们开始这一场意外的相遇吧!~
欢迎留言!谢谢支持!ヾ(≧▽≦*)o 冲冲冲!!
我是 4ye 咱们下期应该……很快再见!! 😆
喜欢的话可以关注下公众号 Java4ye 支持下 4ye 呀😝
评论