我们有一个使用Quartz调度作业的Java应用程序。我们使用的Quartz版本是:quartz-2.2.1。
Quartz配置使用JDBC作业存储。
如果在调用Quartz调度程序对象的start方法时数据库连接断开(由于间歇性网络故障),则会出现以下异常:
为了确保Quartz调度程序成功启动,我们在代码中添加了重试机制,每隔1秒钟对Quartz调度程序对象的start方法进行一次调用。但是当数据库连接正常时,对Quartz调度程序start方法的调用是成功的(不会抛出任何异常),但是驻留在数据库中的相关触发器没有启动,也没有触发任何作业。
你有什么想法吗?任何帮助将不胜感激。
以下是Quartz配置,请注意,我们已经启用了验证查询以处理糟糕的连接(由于间歇性网络故障)。
Quartz配置使用JDBC作业存储。
如果在调用Quartz调度程序对象的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调度程序成功启动,我们在代码中添加了重试机制,每隔1秒钟对Quartz调度程序对象的start方法进行一次调用。但是当数据库连接正常时,对Quartz调度程序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