数据库连接失败时重试Quartz调度程序启动

Question

我们有一个Java应用程序，它使用Quartz来调度作业。我们使用的quartz版本是:Quartz-2.2.1

quartz配置使用JDBC作业存储。

如果在quartz scheduler对象上调用start方法时数据库连接关闭（由于断断续续的网络故障），它将以以下异常失败：

2017-05-28 00:05:45 org.quartz.SchedulerConfigException: Failure occured during job recovery. [See nested exception: org.quartz.JobPersistenceException: Couldn't recover jobs: The connection is closed. [See nested exception: com.microsoft.sqlserver.jdbc.SQLServerException: The connection is closed.]]
2017-05-28 00:05:45     at org.quartz.impl.jdbcjobstore.JobStoreSupport.schedulerStarted(JobStoreSupport.java:692)
2017-05-28 00:05:45     at org.quartz.core.QuartzScheduler.start(QuartzScheduler.java:567)
2017-05-28 00:05:45     at org.quartz.impl.StdScheduler.start(StdScheduler.java:142)

为了确保quartz scheduler成功启动，我们在代码中添加了重试，它在每1秒后调用quartz scheduler对象上的start方法。但是，当数据库连接打开时，对quartz scheduler start方法的调用是成功的（它不会引发任何异常）--但是驻留在数据库中的相关触发器不会启动，也不会触发任何作业。

这里是quartz的配置，请注意我们已经启用了验证查询来处理糟糕的连接（由于间歇性网络故障）

#============================================================================
# Configure Main Scheduler Properties  
#============================================================================

org.quartz.scheduler.instanceName = TestScheduler
org.quartz.scheduler.instanceId = AUTO
org.quartz.scheduler.skipUpdateCheck=true

#============================================================================
# Configure ThreadPool  
#============================================================================

org.quartz.threadPool.class =     org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount =  50
org.quartz.threadPool.threadPriority = 5

#============================================================================
# Configure JobStore  
#============================================================================

org.quartz.jobStore.misfireThreshold = 60000
org.quartz.jobStore.maxMisfiresToHandleAtATime = 15

org.quartz.jobStore.class =     org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass =     org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties = false
org.quartz.jobStore.dataSource = aBPM
org.quartz.jobStore.tablePrefix = ABPM_
org.quartz.jobStore.isClustered = false
org.quartz.jobStore.useDBLocks = false
org.quartz.jobStore.acquireTriggersWithinLock = true

#============================================================================
# Configure Datasources  
#============================================================================
org.quartz.dataSource.aBPM.driver = org.hsqldb.jdbcDriver
org.quartz.dataSource.aBPM.URL = jdbc:hsqldb:file:embeddedDb/db/abpmquartz
org.quartz.dataSource.aBPM.user = sa
org.quartz.dataSource.aBPM.encryptPassword = yes
org.quartz.dataSource.aBPM.password = fMFVvEFk3gFmM9ewWQkTNg==
org.quartz.dataSource.aBPM.maxConnections = 55
org.quartz.dataSource.aBPM.validationQuery= SELECT 1

Answer 1

你可能有工作失败的问题。

TL；DR：在构建触发器时使用适当的misfire指令，或者增加misfire阈值。

如果在触发器应该触发的时候调度器关闭了，那就是无效触发。一旦调度器启动，Quartz就会检查错误的作业，并寻找如何处理它们的指示。马上运行它们？等到他们下一次预定的开火时间？为了让它知道要做什么，您可以通过使用misfire指令来明确表示，或者直接默认使用Quartz的smart策略，这取决于触发器类型（例如，CronTrigger具有不同于SimpleTrigger的默认misfire策略）。

另一个选项是将org.quartz.jobstore.misfirethreshold设置为高于调度程序启动所需的值。
现在将其设置为1分钟。这意味着，任何比预期发射时间晚1分钟的作业，都不会被认为是无效发射，并将正常运行。然而，对于迟到超过1分钟的工作，Quartz将为他们检查不匹配政策。

说你知道调度器总是不到5分钟就上线；然后，您可以尝试设置org.Quartz.jobstore.misfirethreshold=3000000，这样，当调度器启动时作业启动时，Quartz会看到它们迟到了不到5分钟，并会让它们执行，而不首先检查Misfireme策略。