写点什么

Springboot+quartz 源码探索

用户头像
4ye
关注
发布于: 4 小时前

这期和小伙伴们一起来看看 IDEAEndpoints , 以 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"));
}}
复制代码

三. 创建 JobDetailTrigger

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. 步骤

按照图中四个步骤操作


  1. 点击 Endpoints

  2. 输入 quartz 搜索

  3. 点击 quartzScheduler

  4. 按住 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.) 去配置程序的一些属性时,可以尝试从 IDEAEndpoints 入手,找到目标类,打下断点


二. 断点时,留意下 初始化顺序,执行顺序 ,比如 @PostConstruct ,可以更快的找到我们想要的


三. 还可以故意配错属性,让程序抛出异常,然后进去打下断点,和我们平时遇到异常去打断点的思路差不多


四. quartz 初始化表结构时,使用默认值 embedded(内嵌的) 时,会去看看 db 的类型是不是属于下面几个 h2derby ,hsql ,是的话会执行初始化的SQL


最后

欢迎小伙伴们来一起探讨问题~


如果你觉得本篇文章还不错的话,那拜托再点点赞支持一下呀😝

让我们开始这一场意外的相遇吧!~

欢迎留言!谢谢支持!ヾ(≧▽≦*)o 冲冲冲!!

我是 4ye 咱们下期应该……很快再见!! 😆

喜欢的话可以关注下公众号 Java4ye 支持下 4ye 呀😝

发布于: 4 小时前阅读数: 5
用户头像

4ye

关注

公众号:J a v a 4 y e 2021.07.19 加入

还未添加个人简介

评论

发布
暂无评论
Springboot+quartz源码探索