Quartz 2.2多调度程序和@DisallowConcurrentExecution

Question

请考虑这个例子。

一个示例Web应用程序要求scheduler.start()其启动。调度程序配置为将其作业存储在DB中。

该应用程序被复制到六个Web服务器上。

因此，如果启动六个Web服务器，则在单个DB上将有六个具有相同名称的调度程序。如https://quartz-scheduler.org/documentation/quartz-2.1.x/cookbook/MultipleSchedulers中所述：

切勿针对运行（start（）ed）具有相同调度程序名称的任何其他实例的同一组数据库表启动（scheduler.start（））非集群实例。您可能会遇到严重的数据损坏，并且肯定会遇到不稳定的行为。

因此，这将失败。

我的问题是，如果我确定我所有的工作@DisallowConcurrentExecution都会胜任工作，否则仍然失败？

---

如果@DisallowConcurrentExecution没有帮助，我应该手动将一台服务器配置为某些主机

public class StartUp implements ServletContextListener {

   public void contextInitialized(ServletContextEvent event) {
       if(THIS_IS_MASTER_TOMCAT){
         scheduler.start()
       }
}

有更好的方法吗？

Answer 1

基本上Rene M.是正确的。这是与Quartz有关的文档：

http://www.quartz-scheduler.org/documentation/quartz-2.2.x/configuration/ConfigJDBCJobStoreClustering.html

现在介绍一些我们自己在公司使用的背景和概念示例。我们在 Wildfly群集中使用石英群集模式。也就是说，每个野生蝇群集节点都运行石英。由于quartz本身以群集模式运行，并且指向相同的数据库模式，因此我们保证每个群集运行一个作业。同样，请参阅文档。关键问题是：

1. 单个石英群集必须针对单个石英数据库
   架构运行。显然，您必须根据文档创建关系数据库表。没关系
2. 您必须正确设置quartz.property文件，并且集群中每个节点必须存在一个副本。完全相同的quartz.property文件
3. 最后，您必须使用NonJTA数据源，否则石英群集将失败。这通常意味着在Wildfly世界中，石英将需要其自己的数据源。

石英石属性示例：

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

org.quartz.scheduler.instanceName = BjondScheduler
org.quartz.scheduler.instanceId = AUTO

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

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

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

org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreCMT
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.PostgreSQLDelegate
org.quartz.jobStore.useProperties = false
org.quartz.jobStore.tablePrefix=QRTZ_
org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 5000

org.quartz.scheduler.wrapJobExecutionInUserTransaction = true
org.quartz.scheduler.userTransactionURL = java:jboss/UserTransaction

org.quartz.jobStore.dataSource = PostgreSQLDS
org.quartz.jobStore.nonManagedTXDataSource = PostgreSQLDSNoJTA

org.quartz.dataSource.PostgreSQLDSNoJTA.jndiURL=java:jboss/datasources/PostgreSQLDSNoJTA
org.quartz.dataSource.PostgreSQLDS.jndiURL=java:jboss/datasources/PostgreSQLDS


#============================================================================
# Configure Logging
#============================================================================
#org.quartz.plugin.jobHistory.class=org.quartz.plugins.history.LoggingJobHistoryPlugin
#org.quartz.plugin.jobHistory.jobToBeFiredMessage=Bjond Job [{1}.{0}] to be fired by trigger [{4}.{3}] at: {2, date, HH:mm:ss MM/dd/yyyy} re-fire count: {7}
#org.quartz.plugin.jobHistory.jobSuccessMessage=Bjond Job [{1}.{0}] execution complete and reports: {8}
#org.quartz.plugin.jobHistory.jobFailedMessage=Bjond Job [{1}.{0}] execution failed with exception: {8}
#org.quartz.plugin.jobHistory.jobWasVetoedMessage=Bjond Job [{1}.{0}] was vetoed. It was to be fired by trigger [{4}.{3}] at: {2, date, dd-MM-yyyy HH:mm:ss.SSS}

现在，standalone.xml中的数据源代码段：

            <datasource jta="false" jndi-name="java:jboss/datasources/PostgreSQLDSNoJTA" pool-name="PostgreSQLDSNoJTA" enabled="true" use-java-context="true" use-ccm="true">

您可以根据需要填写此数据源元素的其余部分。@DisallowConcurrentExecution是一个很好的主意，可以防止单个节点上的多个作业执行特定的方法，但是石英群集阻止了同一作业在多个VM上运行；不是这个注释。