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群集中使用石英群集模式。也就是说，每个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上运行。不是这个注释。