Spring整合Quartz分布式调度的示例代码

2023-09-14 11:58:04 59

前言

为了保证应用的高可用和高并发性，一般都会部署多个节点；对于定时任务，如果每个节点都执行自己的定时任务，一方面耗费了系统资源，

另一方面有些任务多次执行，可能引发应用逻辑问题，所以需要一个分布式的调度系统，来协调每个节点执行定时任务。

Spring整合Quartz

Quartz是一个成熟的任务调度系统，Spring对Quartz做了兼容，方便开发，下面看看具体如何整合：

1.Maven依赖文件



org.springframework
spring-core
4.3.5.RELEASE


org.springframework
spring-context-support
4.3.5.RELEASE


org.springframework
spring-tx
4.3.5.RELEASE


org.springframework
spring-jdbc
4.3.5.RELEASE


org.quartz-scheduler
quartz
2.2.3


mysql
mysql-connector-java
5.1.29

主要就是Spring相关库、quartz库以及mysql驱动库，注：分布式调度需要用到数据库，这里选用mysql；

2.配置job

提供了两种方式来配置job，分别是：MethodInvokingJobDetailFactoryBean和JobDetailFactoryBean

2.1MethodInvokingJobDetailFactoryBean

要调用特定bean的一个方法的时候使用，具体配置如下：

2.2JobDetailFactoryBean

这种方式更加灵活，可以设置传递参数，具体如下：

jobClass定义的任务类，继承QuartzJobBean，实现executeInternal方法；jobDataMap用来给job传递数据

3.配置调度使用的触发器

同样提供了两种触发器类型：SimpleTriggerFactoryBean和CronTriggerFactoryBean

重点看CronTriggerFactoryBean，这种类型更加灵活，具体如下：

jobDetail指定的就是在步骤2中配置的job，cronExpression配置了每5秒执行一次job；

4.配置Quartz调度器的SchedulerFactoryBean

同样提供了两种方式：内存RAMJobStore和数据库方式

4.1内存RAMJobStore

job的相关信息存储在内存里，每个节点存储各自的，互相隔离，配置如下：

4.2数据库方式

job的相关信息存储在数据库中，所有节点共用数据库，每个节点通过数据库来通信，保证一个job同一时间只会在一个节点上执行，并且

如果某个节点挂掉，job会被分配到其他节点执行，具体配置如下：

dataSource用来配置数据源，数据表相关信息，可以到官网下载gz包，sql文件在路径：docs\dbTables下，里面提供了主流数据库的sql文件；

configLocation配置的quartz.properties文件在quartz.jar的org.quartz包下，里面提供了一些默认的数据，比如org.quartz.jobStore.class

org.quartz.jobStore.class:org.quartz.simpl.RAMJobStore

这里需要将quartz.properties拷贝出来做一些修改，具体修改如下：

org.quartz.scheduler.instanceId:AUTO
org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.isClustered:true
org.quartz.jobStore.clusterCheckinInterval:1000

5.相关类

publicclassFirstTaskextendsQuartzJobBean{

privateFirstServicefirstService;

@Override
protectedvoidexecuteInternal(JobExecutionContextcontext)throwsJobExecutionException{
firstService.service();
}

publicvoidsetFirstService(FirstServicefirstService){
this.firstService=firstService;
}
}

FirstTask继承QuartzJobBean，实现executeInternal方法，调用FirstService

publicclassFirstServiceimplementsSerializable{

privatestaticfinallongserialVersionUID=1L;

publicvoidservice(){
System.out.println(newSimpleDateFormat("YYYYMMddHH:mm:ss").format(newDate())+"---startFirstService");
try{
Thread.sleep(2000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println(newSimpleDateFormat("YYYYMMddHH:mm:ss").format(newDate())+"---endFirstService");
}
}

FirstService需要提供序列化接口，因为需要保存在数据库中；

publicclassApp{
publicstaticvoidmain(String[]args){
AbstractApplicationContextcontext=newClassPathXmlApplicationContext("quartz.xml");
}
}

主类用来加载quartz配置文件；

测试分布式调度

1.同时启动App两次，观察日志：

2018040514:48:10---startFirstService
2018040514:48:12---endFirstService
2018040514:48:15---startFirstService
2018040514:48:17---endFirstService

其中A1有日志输出，A2没有；当停掉A1以后，A2有日志输出；

2.添加新的job分别新建：SecondTask和SecondService，同时添加相关配置文件，启动App两次，观察日志：

A1日志如下：

2018040515:03:15---startFirstService
2018040515:03:15---startSecondService
2018040515:03:17---endFirstService
2018040515:03:17---endSecondService
2018040515:03:20---startFirstService
2018040515:03:22---endFirstService
2018040515:03:25---startFirstService
2018040515:03:27---endFirstService

A2日志如下：

2018040515:03:20---startSecondService
2018040515:03:22---endSecondService
2018040515:03:25---startSecondService
2018040515:03:27---endSecondService

可以发现A1和A2都有执行任务，但是同一任务同一时间只会在一个节点执行，并且只有在执行结束后才有可能分配到其他节点；

3.如果间隔时间小于任务执行时间，比如这里改成sleep(6000)

A1日志如下：

2018040515:14:40---startFirstService
2018040515:14:45---startFirstService
2018040515:14:46---endFirstService
2018040515:14:50---startFirstService
2018040515:14:50---startSecondService
2018040515:14:51---endFirstService

A2日志如下：

2018040515:14:40---startSecondService
2018040515:14:45---startSecondService
2018040515:14:46---endSecondService
2018040515:14:51---endSecondService

间隔时间是5秒，而任务执行需要6秒，观察日志可以发现，任务还没有结束，新的任务已经开始，这种情况可能引发应用的逻辑问题，其实就是任务能不能支持串行的问题；

4.@DisallowConcurrentExecution注解保证任务的串行

在FirstTask和SecondTask上分别添加@DisallowConcurrentExecution注解，日志结果如下：

A1日志如下：

2018040515:32:45---startFirstService
2018040515:32:51---endFirstService
2018040515:32:51---startFirstService
2018040515:32:51---startSecondService
2018040515:32:57---endFirstService
2018040515:32:57---endSecondService
2018040515:32:57---startFirstService
2018040515:32:57---startSecondService

A2日志如下：

2018040515:32:45---startSecondService
2018040515:32:51---endSecondService

观察日志可以发现，任务只有在end以后，才会开始新的任务，实现了任务的串行化；

总结

本文旨在对Spring+Quartz分布式调度有一个直观的了解，通过实际的使用来解决问题，当然可能还有很多疑问比如它是如何调度的，数据库如果挂了会怎么样等等，还需要做更加深入的了解。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

Spring整合Quartz分布式调度的示例代码

热门推荐

随机推荐