首页 / JAVA / java – 重新启动quartz调度程序而不会出现错误

java – 重新启动quartz调度程序而不会出现错误

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java – 重新启动quartz调度程序而不会出现错误，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含10803字，纯文字阅读大概需要16分钟。

内容图文

上下文

我正在尝试使用jdbc在集群模式下使用quartz调度程序.

问题

在我开始使用集群模式的jdbc之前,我刚刚通过RAM存储测试了调度程序.这没有问题,我能够重启调度程序(主类),没有任何错误.我现在的问题是,当我停止执行(ctrl c)然后重新启动它时,我总是收到错误消息：

org.quartz.ObjectAlreadyExistsException: Unable to store Job : 'MyTestJob', because one already exists with this identification.

我不明白这里发生了什么. quartz不支持重新启动调度程序吗？我的意思是,如果发生崩溃并且调度程序在恢复后重新启动会发生什么？那么从石英数据库中删除作业的唯一选择是什么？也许还有另外一种我错过的方法或东西.使用不能应对重启的库感觉不太舒服.

另一个奇怪的事情是,当更改为jdbc时,我的工作不再被触发,我只看到DB中的状态WAITING.这可能是什么？作业(cron-schedule)在RAM模式下没有问题.

我对文档的水平和我遇到的这个简单任务遇到的问题感到有些惊讶,因为我已经听说过石英调度程序多年了,但从来没有使用它.古德尔建议我不是唯一有这个问题的人.我希望这只是我和我的问题有一个简单的解决方案,否则在2.2.x版本中第一次尝试这个库并且已经不得不寻找其他东西会非常令人失望.

这是我的配置：

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

org.quartz.scheduler.skipUpdateCheck = true
org.quartz.scheduler.instanceName = Test-Scheduler
org.quartz.scheduler.instanceId = AUTO

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

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

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

org.quartz.jobStore.misfireThreshold = 60000

org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties = true
org.quartz.jobStore.dataSource = quartzDS
org.quartz.jobStore.tablePrefix = QRTZ_

org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000

这是我的代码：

    SchedulerFactory sf = new StdSchedulerFactory();
    Scheduler scheduler = sf.getScheduler();

    scheduler.start();

                JobDetail jobDetail = newJob(job.getClass())
                    .withIdentity("test-name", "test-group")
                    .build();

                CronTrigger trigger = newTrigger()
                    .withIdentity("test-name-trigger", "test-group")
                    .withSchedule(cronSchedule("0 0/1 * * * ?"))
                    .build();

                scheduler.scheduleJob(jobDetail, trigger);

                System.out.println(trigger.getNextFireTime());

编辑

这是有趣的.

1)RAM模式工作.

2)带有集群启用的jdbc不起作用,并且(几乎)无声地失败 – 即使启用了日志记录也是如此.在日志输出中,我看到以下内容：

19:57:29,913  INFO StdSchedulerFactory:1184 - Using default implementation for ThreadExecutor
19:57:29,936  INFO SchedulerSignalerImpl:61 - Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl
19:57:29,936  INFO QuartzScheduler:240 - Quartz Scheduler v.2.2.1 created.
19:57:29,938  INFO JobStoreTX:667 - Using db table-based data access locking (synchronization).
19:57:29,940  INFO JobStoreTX:59 - JobStoreTX initialized.
19:57:29,941  INFO QuartzScheduler:305 - Scheduler meta-data: Quartz Scheduler (v2.2.1) 'Test-Scheduler' with instanceId 'Michael-PC1405447049916'
  Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
  NOT STARTED.
  Currently in standby mode.
  Number of jobs executed: 0
  Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 25 threads.
  Using job-store 'org.quartz.impl.jdbcjobstore.JobStoreTX' - which supports persistence. and is clustered.

19:57:29,941  INFO StdSchedulerFactory:1339 - Quartz scheduler 'Test-Scheduler' initialized from default resource file in Quartz package: 'quartz.properties'
19:57:29,941  INFO StdSchedulerFactory:1343 - Quartz scheduler version: 2.2.1
19:57:29,995  INFO AbstractPoolBackedDataSource:462 - Initializing c3p0 pool... com.mchange.v2.c3p0.ComboPooledDataSource [ acquireIncrement -> 3, acquireRetryAttempts -> 30, acquireRetryDelay -> 1000, autoCommitOnClose -> false, automaticTestTable -> null, breakAfterAcquireFailure -> false, checkoutTimeout -> 0, connectionCustomizerClassName -> null, connectionTesterClassName -> com.mchange.v2.c3p0.impl.DefaultConnectionTester, dataSourceName -> 1hgeby993gf1xpdmdc44s|7ec4d0, debugUnreturnedConnectionStackTraces -> false, description -> null, driverClass -> com.mysql.jdbc.Driver, factoryClassLocation -> null, forceIgnoreUnresolvedTransactions -> false, identityToken -> 1hgeby993gf1xpdmdc44s|7ec4d0, idleConnectionTestPeriod -> 50, initialPoolSize -> 3, jdbcUrl -> jdbc:mysql://localhost:3306/scheduler, maxAdministrativeTaskTime -> 0, maxConnectionAge -> 0, maxIdleTime -> 0, maxIdleTimeExcessConnections -> 0, maxPoolSize -> 5, maxStatements -> 0, maxStatementsPerConnection -> 120, minPoolSize -> 1, numHelperThreads -> 3, numThreadsAwaitingCheckoutDefaultUser -> 0, preferredTestQuery -> SELECT 1 FROM QRTZ_JOB_DETAILS, properties -> {user=******, password=******}, propertyCycle -> 0, testConnectionOnCheckin -> true, testConnectionOnCheckout -> false, unreturnedConnectionTimeout -> 0, usesTraditionalReflectiveProxies -> false ]
19:57:30,243 DEBUG StdRowLockSemaphore:107 - Lock 'TRIGGER_ACCESS' is desired by: main
19:57:30,262 DEBUG StdRowLockSemaphore:92 - Lock 'TRIGGER_ACCESS' is being obtained: main
19:58:21,328 DEBUG StdRowLockSemaphore:141 - Lock 'TRIGGER_ACCESS' was not obtained by: main - will try again.
19:58:22,329 DEBUG StdRowLockSemaphore:92 - Lock 'TRIGGER_ACCESS' is being obtained: main
19:59:13,389 DEBUG StdRowLockSemaphore:141 - Lock 'TRIGGER_ACCESS' was not obtained by: main - will try again.
19:59:14,389 DEBUG StdRowLockSemaphore:92 - Lock 'TRIGGER_ACCESS' is being obtained: main

虽然,就像我要再次启用集群模式一样,我看到了异常：

Exception in thread "main" org.quartz.impl.jdbcjobstore.LockException: Failure obtaining db row lock: Lock wait timeout exceeded; try restarting transaction [See nested exception: java.sql.SQLException: Lock wait timeout exceeded; try restarting transaction]
    at org.quartz.impl.jdbcjobstore.StdRowLockSemaphore.executeSQL(StdRowLockSemaphore.java:157)
    at org.quartz.impl.jdbcjobstore.DBSemaphore.obtainLock(DBSemaphore.java:113)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.executeInNonManagedTXLock(JobStoreSupport.java:3780)
    at org.quartz.impl.jdbcjobstore.JobStoreTX.executeInLock(JobStoreTX.java:93)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.clearAllSchedulingData(JobStoreSupport.java:1956)
    at org.quartz.core.QuartzScheduler.clear(QuartzScheduler.java:1572)
    at org.quartz.impl.StdScheduler.clear(StdScheduler.java:239)
    at com.scs.core.cron.TaskRunner.main(TaskRunner.java:52)

3)在禁用集群的jdbc模式下它也不起作用,但我得到一个异常：

  20:04:15,993 DEBUG SimpleSemaphore:132 - Lock 'TRIGGER_ACCESS' retuned by: main
  20:04:15,993 DEBUG JobStoreTX:703 - JobStore background threads started (as scheduler was started).
  20:04:15,994  INFO QuartzScheduler:575 - Scheduler Test-Scheduler_$_NON_CLUSTERED started.
  20:04:15,994 DEBUG JobStoreTX:3933 - MisfireHandler: scanning for misfires...
  20:04:16,000 DEBUG JobStoreTX:3182 - Found 0 triggers that missed their scheduled fire-time.
  20:04:16,004 DEBUG QuartzSchedulerThread:276 - batch acquisition of 0 triggers
  20:04:16,008 DEBUG SimpleSemaphore:81 - Lock 'TRIGGER_ACCESS' is desired by: main
  20:04:16,008 DEBUG SimpleSemaphore:88 - Lock 'TRIGGER_ACCESS' is being obtained: main
  20:04:16,008 DEBUG SimpleSemaphore:105 - Lock 'TRIGGER_ACCESS' given to: main
        20:04:16,052 DEBUG SimpleSemaphore:132 - Lock 'TRIGGER_ACCESS' retuned by: main
        Found job: class to.test.cron.ImportProducts
        Tue Jul 15 20:05:00 CEST 2014
        isStarted=true
        isShutdown=false
        isInStandbyMode=false
        20:04:16,058 DEBUG QuartzSchedulerThread:276 - batch acquisition of 0 triggers
        20:04:42,961 ERROR ErrorLogger:2425 - An error occurred while scanning for the next triggers to fire.
        org.quartz.JobPersistenceException: Couldn't acquire next trigger: to.test.cron.ImportProducts [See nested exception: java.lang.ClassNotFoundException: to.test.cron.ImportProducts]
            at org.quartz.impl.jdbcjobstore.JobStoreSupport.acquireNextTrigger(JobStoreSupport.java:2848)
            at org.quartz.impl.jdbcjobstore.JobStoreSupport$40.execute(JobStoreSupport.java:2759)
            at org.quartz.impl.jdbcjobstore.JobStoreSupport$40.execute(JobStoreSupport.java:2757)
            at org.quartz.impl.jdbcjobstore.JobStoreSupport.executeInNonManagedTXLock(JobStoreSupport.java:3787)
            at org.quartz.impl.jdbcjobstore.JobStoreSupport.acquireNextTriggers(JobStoreSupport.java:2756)
            at org.quartz.core.QuartzSchedulerThread.run(QuartzSchedulerThread.java:272)
        Caused by: java.lang.ClassNotFoundException: to.test.cron.ImportProducts
            at java.net.URLClassLoader$1.run(Unknown Source)
            at java.net.URLClassLoader$1.run(Unknown Source)
            at java.security.AccessController.doPrivileged(Native Method)
            at java.net.URLClassLoader.findClass(Unknown Source)
            at java.lang.ClassLoader.loadClass(Unknown Source)
            at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source)
            at java.lang.ClassLoader.loadClass(Unknown Source)
            at org.quartz.simpl.InitThreadContextClassLoadHelper.loadClass(InitThreadContextClassLoadHelper.java:72)
            at org.quartz.simpl.CascadingClassLoadHelper.loadClass(CascadingClassLoadHelper.java:114)
            at org.quartz.simpl.CascadingClassLoadHelper.loadClass(CascadingClassLoadHelper.java:138)
            at org.quartz.impl.jdbcjobstore.StdJDBCDelegate.selectJobDetail(StdJDBCDelegate.java:852)
            at org.quartz.impl.jdbcjobstore.JobStoreSupport.acquireNextTrigger(JobStoreSupport.java:2816)
            ... 5 more

我不太明白为什么我在3种不同的模式中得到3种完全不同的行为.如果可以在RAM模式下找到类,那么为什么它不能在jdbc模式下找到它？为什么它没有以群集模式登录？该类实际上是一个osgi类型的模块.这会导致问题(在jdbc模式下)吗？有什么我可以做的,所以可以找到类,就像将类加载器等传递给石英一样？

我现在很迷茫,真的很感激任何帮助.如果不得不回到标准的cron工作岗位,那将是一件令人遗憾的事情,特别是因为石英有更多的东西可以提供.

提前感谢您提供的任何帮助,

迈克尔

解决方法:

这是持久性作业存储的一般“问题”.您的应用程序显然会尝试添加作业存储中已存在的作业,因为您的应用程序过去已添加该作业.您有两种选择：

>在尝试添加作业/触发器之前,在应用程序初始化期间擦除作业存储的内容.从Quartz 2.x开始,您可以使用一种新方法Scheduler.clear().
>您修改应用程序代码以处理您尝试添加的作业/触发器可能已存在于作业存储中的事实.如果存在,您只需在必要时更新作业/触发器,或完全跳过作业/触发器.

当您想到它时,这种Quartz行为实际上是有意义的,因为可以从应用程序外部修改作业存储中的作业/触发器(例如,使用Quartz远程API的外部系统).

您可能还需要查看允许您将作业和触发器定义从应用程序外部化到XML文件/资源??的XMLSchedulingDataProcessorPlugin,它可以处理作业/触发器名称冲突.此article提供了XML文件结构的示例.

希望这可以帮助.

内容总结

以上是互联网集市为您收集整理的java – 重新启动quartz调度程序而不会出现错误全部内容，希望文章能够帮你解决java – 重新启动quartz调度程序而不会出现错误所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/803607.html

来源：【匿名】

【上一篇】java – 公式中的幻数【下一篇】JAVA/JSP学习系列之五

更多 ►

【java – 重新启动quartz调度程序而不会出现错误】教程文章相关的互联网学习教程文章

java-如何使用具体调度程序启动@Scheduled方法？【代码】

我有调度程序：@Bean("one") ThreadPoolTaskScheduler taskScheduler(){ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();threadPoolTaskScheduler.setPoolSize(5);threadPoolTaskScheduler.setAwaitTerminationSeconds(60);threadPoolTaskScheduler.setThreadNamePrefix("Test-");return threadPoolTaskScheduler; }@Bean("two") ThreadPoolTaskScheduler taskScheduler2(){ThreadPoolTaskSched...

Java-Quartz 2.2多调度程序和@DisallowConcurrentExecution【代码】

请考虑这个例子. 一个示例Web应用程序在启动时会调用scheduler.start().调度程序配置为将其作业存储在DB中. 该应用程序被复制到六个Web服务器上. 因此,如果启动六个Web服务器,则在单个DB上将有六个具有相同名称的调度程序.如https://quartz-scheduler.org/documentation/quartz-2.1.x/cookbook/MultipleSchedulers中所述：Never start (scheduler.start()) a non-clustered instance against the same set of database tables that...

java-Spring：使用声明的多个调度程序访问正确的WebApplicationContext【代码】

我在应用程序中声明了两个Spring上下文-一个用于Spring-MVC请求,另一个用于Flex / BlazeDS messagebroker请求,它们已映射到不同的url模式：<servlet-mapping><servlet-name>spring-mvc</servlet-name><url-pattern>/app/*</url-pattern> </servlet-mapping> <servlet-mapping><servlet-name>flex</servlet-name><url-pattern>/messagebroker/*</url-pattern> </servlet-mapping>有一个声明的通用上下文配置(/WEB-INF/applicationCo...

调度程序初始化失败. java.lang.ClassNotFoundException：org.apache.struts2.views.gxp.inject.InjectedObjectContai【代码】

我正在使用Struts 2.3.14.2 jar,但是当我创建简单的应用程序时,我收到以下错误/异常.我几乎完成了一切.我在类路径中添加了几乎所有的jar.但仍然得到这个例外. 我错过了什么吗？SEVERE: Dispatcher initialization failed Unable to load configuration. - bean - jar:file:/C:/Users/Nisha/Downloads/ecplise/util/.metadata/.plugins/org.eclipse.wst.server.core/tmp1/wtpwebapps/StrutsUtil/WEB-INF/lib/struts2-gxp-plugin-2.3...

java – 在Apache Felix中运行的任务调度程序？

我想实现一个任务调度程序在Apache Felix中运行.我们的想法是任务调度程序将读取crontab文件,并定期执行任务(任务由已安装的服务或软件包定义).做这个的最好方式是什么？我是OSGI的新手,我很感激很好的建议.解决方法:好吧,它不是真正的OSGi问题(OSGi不包括crontab类型的事件调度),我会说使用像Quartz这样的第三方开源调度程序： http://quartz-scheduler.org/ 但是,它不是一个开箱即用的OSGi软件包,因此仍然可能需要一些努力才能使...

java – 调度程序可以挂起一个线程并执行另一个线程/工作吗？【代码】

让我们有以下代码(我们将在单核CPU上运行它)：Runnable runnable1 = new Runnable() {@Overridepublic void run() {System.out.println("runnable_1_1");System.out.println("runnable_1_2");} }; Runnable runnable2 = new Runnable() {@Overridepublic void run() {System.out.println("runnable_2_1");System.out.println("runnable_2_2");} }; ExecutorService executorService = Executors.newSingleThreadExecutor(); // or ...

java调度程序

哪种是在调度程序中运行进程的最佳方法.我可以做crontab或Spring-Batch.还有其他更好的选择？解决方法:QuartzQuartz is a full-featured, open sourcejob scheduling system that can beintegrated with, or used along sidevirtually any J2EE or J2SE application– from the smallest stand-alone application to the largest e-commercesystem. Quartz can be used to createsimple or complex schedules forexecuting tens, h...

java – Spring调度程序的cron表达式 – 每年只运行一次【代码】

我的春季服务喜欢@Scheduled( cron="0 0 7 * * SUN") public void doSomething() {// do something }我知道你不能拥有为指定一年保留的第7个值.使用表达式我可以告诉spring在特定时间每年运行一次,比如说在2020年12月25日上午6点？谢谢解决方法:是的你可以.刚看看this答案.简而言之,您可以使用以下格式：0 0 6 6 9 ? 2010 | | | | | | | | | | | | | +- 2010 only. | | | | | +----- any day of the week. | | | | +------- ...

java – 应该从事件调度程序或主线程控制Swing GUI应用程序吗？【代码】

我读了几本关于Java的书.在所有这些中,至少有一章教授GUI编程.在所有这些中,创建一个简单的表单应用程序遵循以下逻辑： MyFrame.javapublic class MyFrame extends JFrame {JButton button1;public MyFrame(){button1 = new JButton("Click here.");} }FrameTest.java：public class FrameTest {public static void main(String[] args){MyFrame myFrame = new MyFrame();myFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);...

java – 如何在quartz调度程序中暂停作业？

您好我正在创建一个基于cron表达式执行类方法的应用程序.为此,我使用spring quartz,我必须在我的spring文件中配置所有这些东西,它工作正常,并且作业正在基于cron表达式执行,但现在我想暂停基于java类的特定作业的下一次执行从UI中选择用户.那有什么办法可以做到这一点？我可以在上下文中获得所有正在运行的工作的详细信息吗？如果是这样,那么我可以过滤作业并尝试暂停该作业以便下次执行.解决方法:注入SchedulerFactoryBean.使用它...

java – SOS – 柏林调度程序无法继续下一份工作【代码】

我现在正在将sun solaris的SOS调度程序迁移到Oracle linux, SOS Berlin调度程序是1.5.3253的最新版本 – Linux X64 withJava JDK 1.7.0.45 – 64位上次使用JavaScript但64位不支持,所以我改为使用javax.script：javascript 很高兴每个工作都能够运行,但现在问题是,一旦第一个工作被触发,工作就不会继续下一个工作. 这是我更改的脚本：<?xml version="1.0" encoding="UTF-8"?> <job order="yes" title="F0001"><params><param n...

java – 使用线程池和优先级队列的调度程序？

我将使用线程池和放大器来实现一个调度程序. Java中的优先级队列我想问是否有人知道任何现有的实现,所以我没有花时间在它上面： – )… 基本上,java.util.concurrent包中的ScheduledThreadPoolExecutor提供了除“优先级队列”之外的几乎所需的功能.当我粗略检查内置的java库时,我找不到任何支持修改&的优先级队列.在将元素放入队列后从外部更新元素的“优先级”值. 我需要这种优先级队列用于下载器喜欢的项目.我希望允许用户即时修...

java – 如何获取注册到Quartz调度程序的触发器列表

我需要建立一个显示某种“工作队列”的gui. 我动态创建触发器并使用jobScheduler.scheduleJob(trigger);来安排它们.我还通过触发器的dataMap传递了一些数据. 我怎样才能找回尚未触发的触发器列表？我找到了获取当前正在运行的作业的方法,但无法获得已注册触发器的列表. 我应该自己维护这个列表,并在通过实现触发器监听器完成执行后删除它们吗？我可以获取底层JobStore并调用getTriggerNames()或类似的东西吗？但是我怎样才能获得...

java – 使用调度程序按下多个键【代码】

我应该如何修改我的调度程序类以捕获多个按键？现在我只想打印它们……class MyDispatcher implements KeyEventDispatcher { public boolean dispatchKeyEvent(KeyEvent e) {if (e.getID() == KeyEvent.KEY_PRESSED) {System.out.println(e.getKeyChar());} return false; } }解决方法:我解决了我的问题：class MyDispatcher implements KeyEventDispatcher { ArrayList<String>typedKeys = new ArrayList<String>(); public boole...