简介
1、为什么我们并没有对数据库进行操作,数据库中就有了quartz的数据?
2、 我们配置了threadCount为5,那么如果有5个任务还在执行的时候触发了第六个任务会怎么样?
3、如果任务刚执行完,把系统时间修改为任务触发时间之前,那相同时间还会再触发一次吗?
4、job实现类中无法依赖注入问题。
github:https://github.com/mzd123/springboot_quartz
问题一:
问题:为什么我们并没有对数据库进行操作,数据库中就有了quartz的数据?
解决:
前言: 我的第一反应是配置druid去监控一下他,但是并不起作用。。。有点尴尬!
1、打开我们maven引入的jar包,位置:org.quartz.impl.jdbcjobstore,我们可以看到:StdJDBCConstants和Constants。
2、打开可以看到所有的sql语句、表名字、表字段名。
3、看到这里是不是疑惑减了一半,至少能确定quartz底层自己在对数据库进行操作。
4、具体怎么操作的呢?为什么每次项目启动的时候都能执行quartz呢?
5、说实话,到这里思路就断了,但是quartz的配置文件中的org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
我一直没搞清楚他是干嘛的,网上说他是用于数据库存储定时任务信息,于是我找到了这个类。
6、发现这个类是继承JobStoreSupport,然后我打开了JobStoreSupport这个类。
7、如果是新增任务的话,是不是应该少不了JobDetail,于是我全文搜索JobDetail发现有一个storeJobAndTrigger()方法,字面的意思就是储存job和trigger,于是我在这打了个断点,掉了一下新增任务的接口,果然进来了。。。
8、这时候显然我已经控制不住我自己激动的情绪了,那是不是能找到其他操作quartz的方法呢(removeJob、pauseJob、resumeJob、triggerJob)???
9、removeJob:在controller中我们使用的是deleteJob这个方法,不过这并不影响,一层一层点一下就是调用了JobStoreSupport的removeJob方法
10、pauseJob、resumeJob这里就不截图了,都是能找的。
11、triggerJob这个方法表示立刻执行,但是在JobStoreSupport中并没有找到,后来整理了一下发型发现确实不应该找到,JobStoreSupport中都是直接操作数据库的,triggerJob是立刻执行一个任务,和数据库没有直接关系,我们从controller层中一直点下去可以发现他在QuartzScheduler这个类中。
12、其实上面中的所有方法都会进入一个StdJDBCDelegate类中来进行对数据库的操作,这个时候我们应该清楚了为什么配置文件中需要配置org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
问题二:
问题:我们配置了threadCount为5,那么如果有5个任务还在执行的时候触发了第六个任务会怎么样?
解决:这个东西开始我是很疑惑的,但是可以做一个简单的实验,就是在任务中让线程睡眠一个长时间(大概3000秒吧),然后出发这个任务的时间设置为每隔20秒,这样就能看出到底会不会触发第六个任务了。
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println("任务执行成功");
try {
Thread.sleep(3000000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
结论: 是不会的,我们看 qrtz_fired_triggers (这张表表示正在执行的任务),一直都是5条记录。
问题三:
问题:如果任务刚执行完,把系统时间修改为任务触发时间之前,那相同时间还会再触发一次吗?
解决:这个是不会的,因为quartz每次执行之后会返回下次执行的时间,如果执行过的时间点是不会再执行了,他的唯一标准是从1970开始计算到下次执行时间点的毫秒数。我们可以打开 qrtz_triggers ,看到有一个 NEXT_FIRE_TIME 这个字段。http://tool.chinaz.com/Tools/unixtime.aspx 根据Unix时间转化工具转化之后,是北京时间2018/8/10 15:56:36
问题四:
问题: job实现类中无法依赖注入问题。
描述:在现实开发中显然不是只要输出aaa什么的就行了,肯定需要调用service层中的什么方法,这个时候我们就需要在job的具体实现类中注入一个service实例对象,但是我们惊奇的发现永远都注入不进来(其实也不能说是惊奇,spring理解不错的小伙伴应该早就知道,job的实现类都不受spring管理,那么在想注入spring容器中的对象是不可能的!)
解决:很明显就是让job的实现类受spring管理就行了!!!
1、增加一个配置类: SpringJobFactory继承AdaptableJobFactory,重写createJobInstance方法。
@Component
public class SpringJobFactory extends AdaptableJobFactory {
@Autowired
private AutowireCapableBeanFactory capableBeanFactory;
@Override
protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
// 调用父类的方法
Object jobInstance = super.createJobInstance(bundle);
// 进行注入
capableBeanFactory.autowireBean(jobInstance);
return jobInstance;
}
}
2、修改上篇文章中的SchedulerConfig配置类
@Autowired
private SpringJobFactory springJobFactory;
@Bean(name = "SchedulerFactory")
public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
SchedulerFactoryBean factory = new SchedulerFactoryBean();
factory.setAutoStartup(true);
factory.setStartupDelay(5);//延时5秒启动
factory.setQuartzProperties(quartzProperties());
factory.setJobFactory(springJobFactory);
return factory;
}
3、在job实现类中注入service,并调用方法
public class TestJob implements Job, Serializable {
private static final long serialVersionUID = 1L;
@Autowired
private JobService jobService;
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
jobService.doTest();
System.out.println("任务执行成功");
}
}
@Service
public class JobService {
@Autowired
private JobMapping testMapping;
public void doTest() {
System.out.println("aaaa");
}
public List<QuartzBean> listQuartzBean(String name) {
return testMapping.listQuartzBean(name);
}
}
4、实验结果: service注入成功了,并执行了方法。