如何解决石英触发器未触发
我有一个在Tomcat上运行的Java Web应用程序。
我正在使用Quartz 2.3.0
(已更新为2.3.2
,仍然无法正常工作)
我正在使用Properties
初始化石英,如下所示:
Properties properties = new Properties();
properties.put("org.quartz.scheduler.instanceName",hostname);
properties.put("org.quartz.scheduler.instanceId",hostname);
properties.put("org.quartz.threadPool.threadCount","5");
properties.put("org.quartz.jobStore.class","org.quartz.impl.jdbcjobstore.JobStoreTX");
properties.put("org.quartz.jobStore.isClustered","true");
properties.put("org.quartz.jobStore.misfireThreshold","600000");//until 10 minutes,dont count as a misfire
properties.put("org.quartz.jobStore.clusterCheckinInterval","100000");
properties.put("org.quartz.jobStore.driverDelegateClass","org.quartz.impl.jdbcjobstore.StdJDBCDelegate");
properties.put("org.quartz.jobStore.dataSource","QCP");
properties.put("org.quartz.dataSource.QCP.connectionProvider.class","mypackage.quartz.QuartzConnectionProvider");
properties.put("org.quartz.plugin.shutdownhook.class","org.quartz.plugins.management.ShutdownHookPlugin");//This plugin catches the event of the JVM terminating (such as upon a CRTL-C) and tells the scheuler to shutdown.
properties.put("org.quartz.plugin.shutdownhook.cleanShutdown","false");
properties.put("org.quartz.scheduler.skipUpdateCheck","true");
Scheduler quartzScheduler quartzScheduler = new StdSchedulerFactory(properties).getScheduler();
quartzScheduler.start();
然后我添加工作:
JobDetail runnableDetail = JobBuilder.newJob(RunnableJob.class)
.withIdentity("runnable_JOB","runnable")
.storeDurably(true)
.requestRecovery(false)
.build();
quartzScheduler.addJob(runnableDetail,true);
,然后为它创建一个触发器,如下所示:
String uuid = UUID.randomUUID().toString();
Trigger trigg = TriggerBuilder.newTrigger()
.withIdentity("runnable_TRIGGER_"+uuid,"runnable")
.forJob("runnable_JOB","runnable")
.withSchedule(SimpleScheduleBuilder.simpleSchedule().withMisfireHandlingInstructionFireNow().withRepeatCount(0))
.startAt(DateBuilder.futureDate(startDelaySeconds,IntervalUnit.SECOND)) //startDelaySeconds is between 1-300
.build();
quartzScheduler.scheduleJob(trigg);
这是我的RunnableJob
班:
public class RunnableJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
try {
//some code
} catch (Exception e) {
//log the exception
};
}
}
但是触发器永远不会触发,当我在MySQL数据库中看到QRTZ_TRIGGERS
表时,我可以看到该触发器和作业已成功添加,但是当触发该触发器的正确时间时,我看到了几秒钟后NEXT_FIRE_TIME
列就会改变。
我已经阅读this并检查了这些值:
quartzScheduler.isStarted();
quartzScheduler.isInStandbyMode();
分别是:true
和false
,这意味着调度程序处于正确的状态,而我的Trigger
的状态也是WAITING
。
奇怪的是,它在我的系统上运行正常,但是在生产系统上部署它时失败。
我的系统上有Windows 10
,服务器上有Centos
和Tomcat 9
,我正在使用Java 14
。
更新:
经过一些更改(而不是创建触发器和作业的方式)之后,NEXT_FIRE_TIME
并没有更新,我检查了catalina.out
并充满了以下异常:
31-Aug-2020 11:04:56.986 INFO [QuartzScheduler_demo123.domain.co-demo123.domain.co_ClusterManager] org.apache.catalina.loader.WebappClassLoaderBase.checkStateForResourceLoading Illegal access: this web application instance has been stopped already. Could not load [META-INF/services/javax.naming.spi.InitialContextFactory]. The following stack trace is thrown for debugging purposes as well as to attempt to terminate the thread which caused the illegal access.
java.lang.IllegalStateException: Illegal access: this web application instance has been stopped already. Could not load [META-INF/services/javax.naming.spi.InitialContextFactory]. The following stack trace is thrown for debugging purposes as well as to attempt to terminate the thread which caused the illegal access.
at org.apache.catalina.loader.WebappClassLoaderBase.checkStateForResourceLoading(WebappClassLoaderBase.java:1385)
at org.apache.catalina.loader.WebappClassLoaderBase.findResources(WebappClassLoaderBase.java:985)
at org.apache.catalina.loader.WebappClassLoaderBase.getResources(WebappClassLoaderBase.java:1086)
at java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.nextProviderClass(ServiceLoader.java:1197)
at java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNextService(ServiceLoader.java:1222)
at java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNext(ServiceLoader.java:1266)
at java.base/java.util.ServiceLoader$2.hasNext(ServiceLoader.java:1301)
at java.base/java.util.ServiceLoader$3.hasNext(ServiceLoader.java:1386)
at java.naming/javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:697)
at java.naming/javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:305)
at java.naming/javax.naming.InitialContext.init(InitialContext.java:236)
at java.naming/javax.naming.InitialContext.<init>(InitialContext.java:184)
at mypackage.quartz.QuartzConnectionProvider.getConnection(QuartzConnectionProvider.java:25)
at org.quartz.utils.DBConnectionManager.getConnection(DBConnectionManager.java:108)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.getConnection(JobStoreSupport.java:780)
at org.quartz.impl.jdbcjobstore.JobStoreTX.getNonManagedTXConnection(JobStoreTX.java:71)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.doCheckin(JobStoreSupport.java:3307)
at org.quartz.impl.jdbcjobstore.JobStoreSupport$ClusterManager.manage(JobStoreSupport.java:3920)
at org.quartz.impl.jdbcjobstore.JobStoreSupport$ClusterManager.run(JobStoreSupport.java:3957)
- ClusterManager: Error managing cluster: Failed to obtain DB connection from data source 'QCP': java.lang.NoClassDefFoundError: java/lang/Thread
org.quartz.JobPersistenceException: Failed to obtain DB connection from data source 'QCP': java.lang.NoClassDefFoundError: java/lang/Thread [See nested exception: java.lang.NoClassDefFoundError: java/lang/Thread]
at org.quartz.impl.jdbcjobstore.JobStoreSupport.getConnection(JobStoreSupport.java:789)
at org.quartz.impl.jdbcjobstore.JobStoreTX.getNonManagedTXConnection(JobStoreTX.java:71)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.doCheckin(JobStoreSupport.java:3307)
at org.quartz.impl.jdbcjobstore.JobStoreSupport$ClusterManager.manage(JobStoreSupport.java:3920)
at org.quartz.impl.jdbcjobstore.JobStoreSupport$ClusterManager.run(JobStoreSupport.java:3957)
Caused by: java.lang.NoClassDefFoundError: java/lang/Thread
at mypackage.quartz.QuartzConnectionProvider.getConnection(QuartzConnectionProvider.java:25)
at org.quartz.utils.DBConnectionManager.getConnection(DBConnectionManager.java:108)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.getConnection(JobStoreSupport.java:780)
... 4 more
重启tomcat服务器并不能解决问题。
更新2:
问题似乎出在我试图与之建立连接的数据源中。
我的tomcat实例是在server.xml
文件中定义的,带有不同的<Host>
标签
及其资源在<Context>
标签中为我的应用程序的每个实例定义:
<Resource name="jdbc/mysql/hamkelasi" auth="Container" type="javax.sql.DataSource"
initialSize="1" maxTotal="50" maxIdle="1"
maxWaitMillis="20000" removeAbandonedOnBorrow="true" removeAbandonedTimeout="600"
validationQuery="select now();" timeBetweenEvictionRunsMillis="1800000"
username="user" password="pass" driverClassName="com.mysql.jdbc.Driver"
url="..."
/>
然后在我的ContextListener
中实例化一个javax.naming.InitialContext
,然后使用.lookup(poolLookupString)
。我在这里尝试过通过缓存InitialContext
或缓存数据源的不同方法,但是没有成功。
仍然,问题仅出在具有相同配置和相同库的生产服务器上。
启动QuartsScheduler
并尝试从数据库获取连接时发生错误。服务器和应用程序都正常运行,只有石英失败,并显示一个非常奇怪的错误:
java.lang.NoClassDefFoundError: java/lang/Thread
而且我只在我的一个应用程序(用于测试porpuses)上使用QuartzScheduler
解决方法
当石英作业线程接收到一个触发器时,它将锁定该行并更新其下一次触发时间,否则它将进入未触发状态。
如果您想深入研究代码并检查发生了什么 (https://github.com/quartz-scheduler/quartz/blob/master/quartz-core/src/main/java/org/quartz/impl/jdbcjobstore/JobStoreSupport.java#L2831)
尝试为工作和触发器注册侦听器,并检查是否被侦听
http://www.quartz-scheduler.org/documentation/quartz-2.3.0/tutorials/tutorial-lesson-07.html
,通过将MySQL连接器版本更新为8,并使用com.mysql.cj.jdbc.Driver
,我的问题消失了,一切似乎都正常了。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。