2. 程式人生 > >spring boot + quartz 叢集

spring boot + quartz 叢集

阿新 • • 發佈：2018-11-08

spring boot bean配置：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

@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>　　　　　//直接使用配置檔案

//        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; 

    }

     

}

　　

1

InvokingJobDetailDetailFactory物件：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

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指令碼：--

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

<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();
    }
    
}

 

文章來源：https://www.cnblogs.com/vincent0928/p/6294792.html

相關推薦

spring boot + quartz 叢集

spring boot bean配置： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 4

Spring Boot Quartz 分散式叢集任務排程實現

Spring Boot Quartz 主要內容 Spring Scheduler 框架 Quartz 框架，功能強大，配置靈活 Quartz 叢集 mysql 持久化定時任務指令碼(tables_mysql.sql) 介紹 在工程中時常會遇到一些需求，例如定時重新整理一下配置、隔一段時間檢查下網路狀態併發

solr搭建叢集，以及spring boot連線叢集

參考連線：  https://ke.qq.com/mobilev2/courseDetail.html?_bid=167&_wv=3&course_id=304121#from=iosapp  https://lucene.apache.org/sol

spring boot quartz 使用 單機模式 多工

pom檔案依賴： <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version

spring+mybatis+quartz叢集

1. 定義資料來源 <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"init-method="init" destroy-method="close">   &

java spring-mvc spring-boot quartz定時器

1.java中定時任務類。java.util.Timer  java.util.TimerTask package com.jiayun.demo; import java.util.Timer; import java.util.TimerTask; public c

spring boot + quartz定時任務框架入坑指南

quartz Quartz是一個功能豐富的開源作業排程庫，可以整合到幾乎任何Java應用程式中 新增Maven依賴 <!-- druid阿里巴巴資料庫連線池 --> <dependency&

整合spring boot + quartz + spring batch + mybatis

quartz負責定時，spring batch負責批量，mybatis負責持久化資料庫，具體每個框架的介紹請參考其它文章，本節主要做spring boot + quartz + spring batch + mybatis的整合。 案例：指定距當前時間5s後，

Spring boot + Quartz實現分散式定時任務

在實際專案中經常會用到定時任務，且有些定時任務同時只能執行一個例項，下面介紹一下通過Spring boot + Quartz框架實現分散式定時任務。 1. 定時任務持久化到Mysql 2. 名稱為JobA的定時任務每10秒執行一次@ScheduledJo

JavaLib-quartz | 基於Spring Boot Quartz開發的定時任務

基於Spring Boot Quartz開發的JavaLib-quartz，目的是幫你快速構建定時任務系統，你可以專心編寫你的業務邏輯，而不必關注定時任務具體是如何實現的，他的效能如何，有沒有異常以及異常處理，監控等等問題。這些你可以在文件中得知。 快速使

spring boot整合quartz定時任務案例

blank pos jdk com post 4.0 learn int idea 1.運行環境 開發工具：intellij idea JDK版本：1.8 項目管理工具：Maven 4.0.0 2.GITHUB地址 https://github.com/nbfujx/spr

Quartz與Spring Boot集成使用

ack innodb edr iba sta hid support getprop eat 上次自己搭建Quartz已經是幾年前的事了，這次項目中需要定時任務，需要支持集群部署，想到比較輕量級的定時任務框架就是Quartz，於是來一波。 版本說明 通過搜索引擎很容易找到其

Quartz+Spring Boot實現動態管理定時任務

varchar 設置 ica key equals 修改 lean queryall 觸發器 項目實踐過程中碰到一個動態管理定時任務的需求：針對每個人員進行信息的定時更新，具體更新時間可隨時調整、啟動、暫定等。 思路 將每個人員信息的定時配置保存到數據庫中，這樣實現了任

Spring Boot專案配置RabbitMQ叢集

//具體參看了配置的原始碼 org.springframework.boot.autoconfigure.amqp.RabbitProperties //RabbitMQ單機 spring:   rabbitmq:     host: localh

《阿里巴巴MongoDB4.0高階實戰：基於Java Spring Boot 2.0》運維、監控、聚合、叢集、監控等高階面試題

《阿里巴巴MongoDB4.0高階實戰》阿里巴巴技術大牛 資深專家P9葉翔、專家徐雷.  NoSQL排名第一！最流行的NoSQL資料庫；谷歌、阿里巴巴、螞蟻金服、騰訊、百度等一線網際網路公司必備技能。 本系列課程涵蓋：MongoDB入門命令、管理、聚合分析、核心架構、資料庫管理、匯入匯出、索引、

spring boot 整合 quartz

1.建立一個springboot工程，選擇依賴。 2.標註啟動定時任務 @EnableScheduling 在啟動類中 package com.lzx.demo01; import org.springframework.boot.SpringApplication;

【Spring Cloud Finchley.SR + Spring Boot 2.0.6】 Eureka叢集

新增Eureka認證後，無法互相註冊。 官方文件：https://cloud.spring.io/spring-cloud-static/Finchley.SR2/single/spring-cloud.html#_securing_the_eureka_server 原因：將sp

spring-boot+Redis實現簡單的分散式叢集session共享

  寫在前面：      首先宣告，筆者是一名Java程式設計屆的小學生。前面一直在幾家公司裡面做開發，其實都是一些傳統的專案，對於像分散式啦，叢集啦一些大型的專案接觸的很少，所以一直沒有自己整合和實現過。由於最近幾天專案不是很忙，自己又有點時間

redis5叢集搭建，整合spring-boot測試

1.下載redis5.0.2 redis-5.0.2 2.安裝 tar -zxvf redis-5.0.2.tar.gz cd redis-5.0.2 make && make install 3.建立並使用叢集配置 建立redis-cluster目錄和相應的配置目錄 mkdir redis

Spring Boot介面畫管理Quartz定時任務及多執行緒併發執行定時任務

工程程式碼示例   : Spring Boot整合持久化Quartz定時任務管理和介面展示 工程地址  : https://github.com/tjfy1992/SpringBootQuartz 執行方法 Spring Boot工程已經集成了伺