一. 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