这期和小伙伴们一起来看看 IDEA 的 Endpoints , 以 Quartz 初始化表结构的源码为例子,来感受下这样的 debug 思路 —— 只用配置文件时,这断点在哪里打 😝
前期准备
下面四大步骤,可以直接跳到第五步,进入正题!😝
一. pom 文件 引入 quartz jar 包
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-quartz</artifactId></dependency>
复制代码
二. 创建一个 job 并继承 QuartzJobBean
@Slf4jpublic 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;
@Configurationpublic 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 呀😝
评论