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

2024-07-14 08:40:39

字體：大中小

來源：轉載

供稿：網友

quartz集群能力：

quartz集群分為水平集群和垂直集群，水平集群即將定時任務節點部署在不同的服務器，水平集群最大的問題就是時鐘同步問題，
quartz集群強烈要求時鐘同步，若時鐘不能同步，則會導致集群中各個節點狀態紊亂，造成不可預知的后果，請自行搜索服務器時鐘同步,
若能保證時鐘同步，水平集群能保證服務的可靠性，其中一個節點掛掉或其中一個服務器宕機，其他節點依然正常服務；垂直集群則是集群各節點部署在同一臺服務器，
時鐘同步自然不是問題，但存在單點故障問題，服務器宕機會嚴重影響服務的可用性。因此，要結合實際情況來考慮集群方案
由于集群中強烈要求時鐘同步，因此不管是垂直集群還是水平集群，本地開發決不能連接線上環境（本地也是集群模式），這樣的話勢必會破壞集群，但本地若是非集群模式，
則可以依情況來連接線上環境。
quartz集群和redis這樣的集群實現方式不一樣，redis集群需要節點之間通信，各節點需要知道其他節點的狀況，而quartz集群的實現
方式在于11張表，集群節點相互之間不通信，而是通過定時任務持久化加鎖的方式來實現集群。
破壞集群后果一般是死鎖或者狀態紊亂每個節點都不可用或其中某些節點能用部分或全部的定時任務

以上是個人的一些見解，下面開始本文的正文，本文主要介紹了關于spring boot + quartz集群搭建的相關內容，分享出來供大家參考學習，下面話不多說了，來一起看看詳細的介紹吧。

步驟如下：

spring boot bean配置：

@Configurationpublic 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  */ @Bean  public JobDetailFactoryBean updateDialogStatusJobDetail() {   return createJobDetail(InvokingJobDetailDetailFactory.class, "updateDialogStatusGroup", "dialogJob");  }   /**  * 加載觸發器  * @param jobDetail  * @return  */ @Bean(name = "dialogJobTrigger")  public CronTriggerFactoryBean dialogStatusJobTrigger(@Qualifier("updateDialogStatusJobDetail") JobDetail jobDetail) {   return dialogStatusTrigger(jobDetail, "0 0 0/1 * * ?");  }   /**  * 創建job工廠  * @param jobClass  * @param groupName  * @param targetObject  * @return  */ private static JobDetailFactoryBean createJobDetail(Class<?> jobClass, String groupName, String targetObject) {   JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();   factoryBean.setJobClass(jobClass);   factoryBean.setDurability(true);   factoryBean.setRequestsRecovery(true);  factoryBean.setGroup(groupName);  Map<String, String> map = new HashMap<>();  map.put("targetObject", targetObject);  map.put("targetMethod", "execute");  factoryBean.setJobDataAsMap(map);  return factoryBean;  }   /**  * 創建觸發器工廠  * @param jobDetail  * @param cronExpression  * @return  */ private static CronTriggerFactoryBean dialogStatusTrigger(JobDetail jobDetail, String cronExpression) {   CronTriggerFactoryBean factoryBean = new CronTriggerFactoryBean();   factoryBean.setJobDetail(jobDetail);  factoryBean.setCronExpression (cronExpression);  return factoryBean;  } }

InvokingJobDetailDetailFactory對象：

public class InvokingJobDetailDetailFactory extends QuartzJobBean{ // 計劃任務所在類  private String targetObject; // 具體需要執行的計劃任務  private String targetMethod; private ApplicationContext ctx; @Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException {  try {   Object otargetObject = ctx.getBean(targetObject);   Method m = null;    try {     m = otargetObject.getClass().getMethod(targetMethod);     m.invoke(otargetObject);    } catch (SecurityException e) {     e.printStackTrace();    } catch (NoSuchMethodException e) {     e.printStackTrace();    }   } catch (Exception e) {    throw new JobExecutionException(e);   } }  public void setApplicationContext(ApplicationContext applicationContext) {   this.ctx = applicationContext;  }   public void setTargetObject(String targetObject) {   this.targetObject = targetObject;  }   public void setTargetMethod(String targetMethod) {   this.targetMethod = targetMethod;  }}

備注：set方法不能少，setApplicationContext中的applicationContext與factory.setApplicationContextSchedulerContextKey("applicationContext")填入的值有關，其原理由InvokingJobDetailDetailFactory父類中的BeanWrapper實現。

sql腳本：--

<em id="__mceDel">-- 表的結構 `qrtz_blob_triggers`-- CREATE TABLE IF NOT EXISTS `qrtz_blob_triggers` ( `SCHED_NAME` varchar(120) NOT NULL, `TRIGGER_NAME` varchar(120) NOT NULL, `TRIGGER_GROUP` varchar(120) NOT NULL, `BLOB_DATA` blob) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_calendars`-- CREATE TABLE IF NOT EXISTS `qrtz_calendars` ( `SCHED_NAME` varchar(120) NOT NULL, `CALENDAR_NAME` varchar(120) NOT NULL, `CALENDAR` blob NOT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_cron_triggers`-- CREATE TABLE IF NOT EXISTS `qrtz_cron_triggers` ( `SCHED_NAME` varchar(120) NOT NULL, `TRIGGER_NAME` varchar(120) NOT NULL, `TRIGGER_GROUP` varchar(120) NOT NULL, `CRON_EXPRESSION` varchar(120) NOT NULL, `TIME_ZONE_ID` varchar(80) DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_fired_triggers`-- CREATE TABLE IF NOT EXISTS `qrtz_fired_triggers` ( `SCHED_NAME` varchar(120) NOT NULL, `ENTRY_ID` varchar(95) NOT NULL, `TRIGGER_NAME` varchar(120) NOT NULL, `TRIGGER_GROUP` varchar(120) NOT NULL, `INSTANCE_NAME` varchar(120) NOT NULL, `FIRED_TIME` bigint(13) NOT NULL, `SCHED_TIME` bigint(13) NOT NULL, `PRIORITY` int(11) NOT NULL, `STATE` varchar(16) NOT NULL, `JOB_NAME` varchar(120) DEFAULT NULL, `JOB_GROUP` varchar(120) DEFAULT NULL, `IS_NONCONCURRENT` varchar(1) DEFAULT NULL, `REQUESTS_RECOVERY` varchar(1) DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_job_details`-- CREATE TABLE IF NOT EXISTS `qrtz_job_details` ( `SCHED_NAME` varchar(120) NOT NULL, `JOB_NAME` varchar(120) NOT NULL, `JOB_GROUP` varchar(120) NOT NULL, `DESCRIPTION` varchar(250) DEFAULT NULL, `JOB_CLASS_NAME` varchar(250) NOT NULL, `IS_DURABLE` varchar(1) NOT NULL, `IS_NONCONCURRENT` varchar(1) NOT NULL, `IS_UPDATE_DATA` varchar(1) NOT NULL, `REQUESTS_RECOVERY` varchar(1) NOT NULL, `JOB_DATA` blob) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_locks`-- CREATE TABLE IF NOT EXISTS `qrtz_locks` ( `SCHED_NAME` varchar(120) NOT NULL, `LOCK_NAME` varchar(40) NOT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_paused_trigger_grps`-- CREATE TABLE IF NOT EXISTS `qrtz_paused_trigger_grps` ( `SCHED_NAME` varchar(120) NOT NULL, `TRIGGER_GROUP` varchar(120) NOT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_scheduler_state`-- CREATE TABLE IF NOT EXISTS `qrtz_scheduler_state` ( `SCHED_NAME` varchar(120) NOT NULL, `INSTANCE_NAME` varchar(120) NOT NULL, `LAST_CHECKIN_TIME` bigint(13) NOT NULL, `CHECKIN_INTERVAL` bigint(13) NOT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_simple_triggers`-- CREATE TABLE IF NOT EXISTS `qrtz_simple_triggers` ( `SCHED_NAME` varchar(120) NOT NULL, `TRIGGER_NAME` varchar(120) NOT NULL, `TRIGGER_GROUP` varchar(120) NOT NULL, `REPEAT_COUNT` bigint(7) NOT NULL, `REPEAT_INTERVAL` bigint(12) NOT NULL, `TIMES_TRIGGERED` bigint(10) NOT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_simprop_triggers`-- CREATE TABLE IF NOT EXISTS `qrtz_simprop_triggers` ( `SCHED_NAME` varchar(120) NOT NULL, `TRIGGER_NAME` varchar(120) NOT NULL, `TRIGGER_GROUP` varchar(120) NOT NULL, `STR_PROP_1` varchar(512) DEFAULT NULL, `STR_PROP_2` varchar(512) DEFAULT NULL, `STR_PROP_3` varchar(512) DEFAULT NULL, `INT_PROP_1` int(11) DEFAULT NULL, `INT_PROP_2` int(11) DEFAULT NULL, `LONG_PROP_1` bigint(20) DEFAULT NULL, `LONG_PROP_2` bigint(20) DEFAULT NULL, `DEC_PROP_1` decimal(13,4) DEFAULT NULL, `DEC_PROP_2` decimal(13,4) DEFAULT NULL, `BOOL_PROP_1` varchar(1) DEFAULT NULL, `BOOL_PROP_2` varchar(1) DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; -- -------------------------------------------------------- ---- 表的結構 `qrtz_triggers`-- CREATE TABLE IF NOT EXISTS `qrtz_triggers` ( `SCHED_NAME` varchar(120) NOT NULL, `TRIGGER_NAME` varchar(120) NOT NULL, `TRIGGER_GROUP` varchar(120) NOT NULL, `JOB_NAME` varchar(120) NOT NULL, `JOB_GROUP` varchar(120) NOT NULL, `DESCRIPTION` varchar(250) DEFAULT NULL, `NEXT_FIRE_TIME` bigint(13) DEFAULT NULL, `PREV_FIRE_TIME` bigint(13) DEFAULT NULL, `PRIORITY` int(11) DEFAULT NULL, `TRIGGER_STATE` varchar(16) NOT NULL, `TRIGGER_TYPE` varchar(8) NOT NULL, `START_TIME` bigint(13) NOT NULL, `END_TIME` bigint(13) DEFAULT NULL, `CALENDAR_NAME` varchar(200) DEFAULT NULL, `MISFIRE_INSTR` smallint(2) DEFAULT NULL, `JOB_DATA` blob) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; ---- Indexes for dumped tables-- ---- Indexes for table `qrtz_blob_triggers`--ALTER TABLE `qrtz_blob_triggers` ADD PRIMARY KEY (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`), ADD KEY `SCHED_NAME` (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`); ---- Indexes for table `qrtz_calendars`--ALTER TABLE `qrtz_calendars` ADD PRIMARY KEY (`SCHED_NAME`,`CALENDAR_NAME`); ---- Indexes for table `qrtz_cron_triggers`--ALTER TABLE `qrtz_cron_triggers` ADD PRIMARY KEY (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`); ---- Indexes for table `qrtz_fired_triggers`--ALTER TABLE `qrtz_fired_triggers` ADD PRIMARY KEY (`SCHED_NAME`,`ENTRY_ID`), ADD KEY `IDX_QRTZ_FT_TRIG_INST_NAME` (`SCHED_NAME`,`INSTANCE_NAME`), ADD KEY `IDX_QRTZ_FT_INST_JOB_REQ_RCVRY` (`SCHED_NAME`,`INSTANCE_NAME`,`REQUESTS_RECOVERY`), ADD KEY `IDX_QRTZ_FT_J_G` (`SCHED_NAME`,`JOB_NAME`,`JOB_GROUP`), ADD KEY `IDX_QRTZ_FT_JG` (`SCHED_NAME`,`JOB_GROUP`), ADD KEY `IDX_QRTZ_FT_T_G` (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`), ADD KEY `IDX_QRTZ_FT_TG` (`SCHED_NAME`,`TRIGGER_GROUP`); ---- Indexes for table `qrtz_job_details`--ALTER TABLE `qrtz_job_details` ADD PRIMARY KEY (`SCHED_NAME`,`JOB_NAME`,`JOB_GROUP`), ADD KEY `IDX_QRTZ_J_REQ_RECOVERY` (`SCHED_NAME`,`REQUESTS_RECOVERY`), ADD KEY `IDX_QRTZ_J_GRP` (`SCHED_NAME`,`JOB_GROUP`); ---- Indexes for table `qrtz_locks`--ALTER TABLE `qrtz_locks` ADD PRIMARY KEY (`SCHED_NAME`,`LOCK_NAME`); ---- Indexes for table `qrtz_paused_trigger_grps`--ALTER TABLE `qrtz_paused_trigger_grps` ADD PRIMARY KEY (`SCHED_NAME`,`TRIGGER_GROUP`); ---- Indexes for table `qrtz_scheduler_state`--ALTER TABLE `qrtz_scheduler_state` ADD PRIMARY KEY (`SCHED_NAME`,`INSTANCE_NAME`); ---- Indexes for table `qrtz_simple_triggers`--ALTER TABLE `qrtz_simple_triggers` ADD PRIMARY KEY (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`); ---- Indexes for table `qrtz_simprop_triggers`--ALTER TABLE `qrtz_simprop_triggers` ADD PRIMARY KEY (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`); ---- Indexes for table `qrtz_triggers`--ALTER TABLE `qrtz_triggers` ADD PRIMARY KEY (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`), ADD KEY `IDX_QRTZ_T_J` (`SCHED_NAME`,`JOB_NAME`,`JOB_GROUP`), ADD KEY `IDX_QRTZ_T_JG` (`SCHED_NAME`,`JOB_GROUP`), ADD KEY `IDX_QRTZ_T_C` (`SCHED_NAME`,`CALENDAR_NAME`(191)), ADD KEY `IDX_QRTZ_T_G` (`SCHED_NAME`,`TRIGGER_GROUP`), ADD KEY `IDX_QRTZ_T_STATE` (`SCHED_NAME`,`TRIGGER_STATE`), ADD KEY `IDX_QRTZ_T_N_STATE` (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`,`TRIGGER_STATE`), ADD KEY `IDX_QRTZ_T_N_G_STATE` (`SCHED_NAME`,`TRIGGER_GROUP`,`TRIGGER_STATE`), ADD KEY `IDX_QRTZ_T_NEXT_FIRE_TIME` (`SCHED_NAME`,`NEXT_FIRE_TIME`), ADD KEY `IDX_QRTZ_T_NFT_ST` (`SCHED_NAME`,`TRIGGER_STATE`,`NEXT_FIRE_TIME`), ADD KEY `IDX_QRTZ_T_NFT_MISFIRE` (`SCHED_NAME`,`MISFIRE_INSTR`,`NEXT_FIRE_TIME`), ADD KEY `IDX_QRTZ_T_NFT_ST_MISFIRE` (`SCHED_NAME`,`MISFIRE_INSTR`,`NEXT_FIRE_TIME`,`TRIGGER_STATE`), ADD KEY `IDX_QRTZ_T_NFT_ST_MISFIRE_GRP` (`SCHED_NAME`,`MISFIRE_INSTR`,`NEXT_FIRE_TIME`,`TRIGGER_GROUP`,`TRIGGER_STATE`); ---- 限制導出的表-- ---- 限制表 `qrtz_blob_triggers`--ALTER TABLE `qrtz_blob_triggers` ADD CONSTRAINT `qrtz_blob_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`) REFERENCES `qrtz_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`); ---- 限制表 `qrtz_cron_triggers`--ALTER TABLE `qrtz_cron_triggers` ADD CONSTRAINT `qrtz_cron_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`) REFERENCES `qrtz_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`); ---- 限制表 `qrtz_simple_triggers`--ALTER TABLE `qrtz_simple_triggers` ADD CONSTRAINT `qrtz_simple_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`) REFERENCES `qrtz_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`); ---- 限制表 `qrtz_simprop_triggers`--ALTER TABLE `qrtz_simprop_triggers` ADD CONSTRAINT `qrtz_simprop_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`) REFERENCES `qrtz_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`); ---- 限制表 `qrtz_triggers`--ALTER TABLE `qrtz_triggers` ADD CONSTRAINT `qrtz_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `JOB_NAME`, `JOB_GROUP`) REFERENCES `qrtz_job_details` (`SCHED_NAME`, `JOB_NAME`, `JOB_GROUP`);<br><br><br></em>

quartz集群實現原理，利用數據庫記錄job行為，并通過鎖機制，使job在同一次中僅運行一次。

JobBean示例

//需要交由spring管理@Service("dialogJob")public class DialogJob { @Autowired private QuestionService questionService;// 方法名在quartz定義 public void execute() throws Exception{  //具體執行業務 　　　　questionService.XXXXX(); } }

總結

以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對VeVb武林網的支持。

注：相關教程知識閱讀請移步到JAVA教程頻道。

上一篇：JDBC連接MySql數據庫步驟以及查詢、插入、刪除、更新等

下一篇：JAVA代碼設置selector不同狀態下的背景顏色