springboot+quartz集群搭建的完整步骤_quartz集群搭建资源-CSDN下载

188 浏览量 2020-08-27 14:01:01 上传评论收藏 81KB PDF 举报

Spring Boot + Quartz 集群搭建的完整步骤 Spring Boot 是一个流行的 Java 框架，用于快速构建基于 Spring 的应用程序。Quartz 是一个流行的开源作业调度框架，可以用于实现定时任务的调度。 Spring Boot + Quartz 集群搭建是指将 Spring Boot 与 Quartz 集成，以实现高可用性和可靠性的定时任务调度。知识点一：Quartz 集群的概念 Quartz 集群是指将多个 Quartz 节点组合在一起，以实现高可用性和可靠性的定时任务调度。Quartz 集群可以分为水平集群和垂直集群两种。水平集群是指将定时任务节点部署在不同的服务器上，这样可以提高服务的可靠性，但需要解决时钟同步问题。垂直集群是指将集群节点部署在同一台服务器上，可以解决时钟同步问题，但存在单点故障问题。知识点二：Quartz 集群的实现方式 Quartz 集群的实现方式不同于 Redis 集群，Redis 集群需要节点之间通信，各节点需要知道其他节点的状况。Quartz 集群的实现方式是通过 11 张表，集群节点相互之间不通信，而是通过定时任务持久化加锁的方式来实现集群。知识点三：Spring Boot + Quartz 集群搭建的步骤 Spring Boot + Quartz 集群搭建的步骤包括： 1. 配置 Quartz 的数据库连接信息 2. 创建 Quartz 的配置 bean 3. 配置 Quartz 的 JobStore 4. 配置 Quartz 的 Trigger 5. 配置 Quartz 的 Scheduler 知识点四：Quartz 集群的优点和缺陷 Quartz 集群的优点包括： * 高可用性：Quartz 集群可以提高服务的可靠性，避免单点故障。 * 可靠性：Quartz 集群可以确保定时任务的可靠执行。 Quartz 集群的缺陷包括： * 时钟同步问题：水平集群需要解决时钟同步问题，否则可能导致集群中的节点状态紊乱。 * 单点故障问题：垂直集群存在单点故障问题，服务器宕机可能影响服务的可用性。知识点五：Spring Boot + Quartz 集群搭建的注意事项在 Spring Boot + Quartz 集群搭建中，需要注意以下几点： * 时钟同步：需要解决时钟同步问题，避免集群中的节点状态紊乱。 * 集群模式：需要在本地开发环境中使用集群模式，避免破坏集群。 * 线上环境：需要在线上环境中使用集群模式，避免单点故障。 Spring Boot + Quartz 集群搭建可以实现高可用性和可靠性的定时任务调度，但需要注意时钟同步问题和单点故障问题。

资源推荐

资源详情

资源评论

spring boot + quartz集群搭建的完整步骤集群搭建的完整步骤

主要给大家介绍了关于spring boot + quartz集群搭建的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋

友们下面随着小编来一起学习学习吧

quartz集群能力：集群能力：

quartz集群分为水平集群和垂直集群，水平集群即将定时任务节点部署在不同的服务器，水平集群最大的问题就是时钟同步问题，

quartz集群强烈要求时钟同步，若时钟不能同步，则会导致集群中各个节点状态紊乱，造成不可预知的后果，请自行搜索服务器时钟同步,

若能保证时钟同步，水平集群能保证服务的可靠性，其中一个节点挂掉或其中一个服务器宕机，其他节点依然正常服务；垂直集群则是集群各节点部署在同一台服务器，

时钟同步自然不是问题，但存在单点故障问题，服务器宕机会严重影响服务的可用性。因此，要结合实际情况来考虑集群方案

由于集群中强烈要求时钟同步，因此不管是垂直集群还是水平集群，本地开发决不能连接线上环境（本地也是集群模式），这样的话势必会破坏集群，但本地若是非集群模式，

则可以依情况来连接线上环境。

quartz集群和redis这样的集群实现方式不一样，redis集群需要节点之间通信，各节点需要知道其他节点的状况，而quartz集群的实现

方式在于11张表，集群节点相互之间不通信，而是通过定时任务持久化加锁的方式来实现集群。

破坏集群后果一般是死锁或者状态紊乱每个节点都不可用或其中某些节点能用部分或全部的定时任务

以上是个人的一些见解，下面开始本文的正文，本文主要介绍了关于spring boot + quartz集群搭建的相关内容，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍

吧。

步骤如下：步骤如下：

spring boot bean配置：

@Configuration

public class QuartzConfig {

@Value("${quartz.scheduler.instanceName}")

private String quartzInstanceName;

@Value("${org.quartz.dataSource.myDS.driver}")

private String myDSDriver;

@Value("${org.quartz.dataSource.myDS.URL}")

private String myDSURL;

@Value("${org.quartz.dataSource.myDS.user}")

private String myDSUser;

@Value("${org.quartz.dataSource.myDS.password}")

private String myDSPassword;

@Value("${org.quartz.dataSource.myDS.maxConnections}")

private String myDSMaxConnections;

/**

* 设置属性

* @return

* @throws IOException

private Properties quartzProperties() throws IOException {

Properties prop = new Properties();

prop.put("quartz.scheduler.instanceName", quartzInstanceName);

prop.put("org.quartz.scheduler.instanceId", "AUTO");

prop.put("org.quartz.scheduler.skipUpdateCheck", "true");

prop.put("org.quartz.scheduler.jmx.export", "true");

prop.put("org.quartz.jobStore.class", "org.quartz.impl.jdbcjobstore.JobStoreTX");

prop.put("org.quartz.jobStore.driverDelegateClass", "org.quartz.impl.jdbcjobstore.StdJDBCDelegate");

prop.put("org.quartz.jobStore.dataSource", "quartzDataSource");

prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");

prop.put("org.quartz.jobStore.isClustered", "true");

prop.put("org.quartz.jobStore.clusterCheckinInterval", "20000");

prop.put("org.quartz.jobStore.dataSource", "myDS");

prop.put("org.quartz.jobStore.maxMisfiresToHandleAtATime", "1");

prop.put("org.quartz.jobStore.misfireThreshold", "120000");

prop.put("org.quartz.jobStore.txIsolationLevelSerializable", "true");

prop.put("org.quartz.jobStore.selectWithLockSQL", "SELECT * FROM {0}LOCKS WHERE LOCK_NAME = ? FOR UPDATE");

prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");

prop.put("org.quartz.threadPool.threadCount", "10");

prop.put("org.quartz.threadPool.threadPriority", "5");

prop.put("org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread", "true");

prop.put("org.quartz.dataSource.myDS.driver", myDSDriver);

prop.put("org.quartz.dataSource.myDS.URL", myDSURL);

prop.put("org.quartz.dataSource.myDS.user", myDSUser);

prop.put("org.quartz.dataSource.myDS.password", myDSPassword);

System.out.println("myDSMaxConnections:" + myDSMaxConnections);

prop.put("org.quartz.dataSource.myDS.maxConnections", myDSMaxConnections);

prop.put("org.quartz.plugin.triggHistory.class", "org.quartz.plugins.history.LoggingJobHistoryPlugin");

prop.put("org.quartz.plugin.shutdownhook.class", "org.quartz.plugins.management.ShutdownHookPlugin");

prop.put("org.quartz.plugin.shutdownhook.cleanShutdown", "true");

return prop;

}

@Bean

public SchedulerFactoryBean schedulerFactoryBean(@Qualifier("dialogJobTrigger") Trigger cronJobTrigger) throws IOException {

SchedulerFactoryBean factory = new SchedulerFactoryBean();

// this allows to update triggers in DB when updating settings in config file:

//用于quartz集群,QuartzScheduler 启动时更新己存在的Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了

factory.setOverwriteExistingJobs(true);

//用于quartz集群,加载quartz数据源

//factory.setDataSource(dataSource);

//QuartzScheduler 延时启动，应用启动完10秒后 QuartzScheduler 再启动

factory.setStartupDelay(10);

//用于quartz集群,加载quartz数据源配置

factory.setQuartzProperties(quartzProperties());

factory.setAutoStartup(true);

factory.setApplicationContextSchedulerContextKey("applicationContext");

//注册触发器

factory.setTriggers(cronJobTrigger);<br data-filtered="filtered">　　　　　//直接使用配置文件

// factory.setConfigLocation(new FileSystemResource(this.getClass().getResource("/quartz.properties").getPath()));

return factory;

}

/**

* 加载job

* @return

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余4页未读，立即下载

评论收藏

内容反馈

weixin_38735570

粉丝: 5

spring boot + quartz集群搭建的完整步骤

springboot整合quartz完整项目

spring boot quartz集群实现

springboot+quartz集群：通过动态配置调度dubbo接口/http接口代码实现

Springboot集成quartz集群

spring + quartz 集群配置

spring-boot集成quartz实现动态任务管理，支持集群

SpringBoot 整合Quartz（集群）实现定时任务调度

springboot2.0整合quartz

springboot整合quartz的demo

springboot 集成 quartz 集群 加 sql 等

spring boot新搭建完整项目

5分钟快速创建spring boot项目的完整步骤

spring boot配置多个请求服务代理的完整步骤

spring boot配置读写分离的完整实现步骤

quartz在集群环境下的最终解决方案

Spring整合quartz2.2.3总结，quartz动态定时任务，Quartz定时任务集群配置

springboot2.3集成quartz定时任务持久化数据库,支持集群

Springboot 整合Quartz

spring和quartz整合示例

springboot 集成quartz

quartz与spring集成

springMVC+Mybatis+quartz+log4j+maven项目

Quartz + SpringBoot 实现分布式定时任务demo

crystal-demo：用于Spring Boot 2和Quartz Scheduler集成的演示项目

springboot与quartz集成的最简单实例

SpringBoot项目构建定时任务

quartz+spring分布式集群调度

springboot整合quartz定时任务yml文件配置方式

基于遗传模拟退火算法的模糊C-均值聚类算法(SAGAFCM)—MATLAB实现

Android去掉滑动锁屏后SIM PIN界面会出现两次

最新资源

springboot 集成 quartz 集群加 sql 等