在多实例环境中只执行一次 Quartz Job

Question

我正在尝试在 Quartz 1.6 中创建一个 Job，但只需要执行一次，因为我有两个具有相同版本的 .war 文件的测试实例。

这是我的TestPlugin 类，Job 将每 60 秒执行一次：

public class TestPlugin implements PlugIn {

    public TestPlugin() {
        super();
    }

    public void destroy() {
    }

    public void init(ActionServlet arg0, ModuleConfig arg1)
            throws ServletException {

        try {
            JobDetail job = JobBuilder.newJob(TestDemonio.class)
                    .withIdentity("anyJobName", "group1").build();
            Trigger trigger = TriggerBuilder
                    .newTrigger()
                    .withIdentity("anyTriggerName", "group1")
                    .withSchedule(CronScheduleBuilder.cronSchedule("0/60 * * ? * * *"))
                    .build();

            Scheduler scheduler = new StdSchedulerFactory().getScheduler();
            scheduler.scheduleJob(job, trigger);
            scheduler.start();

        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }
}

然后我让我的班级TestExecute 打印一个简单的输出：

@DisallowConcurrentExecution
public class TestDemonio implements Job {

    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        System.out.println("QUARTZ JOB MESSAGE");
    }
}

我研究了如何通过添加注释@DisallowConcurrentExecution 来实现我想要的，只执行一次作业，但我收到了打印在每个实例上的消息。

这是我的quartz.properties 文件：

# Default Properties file for use by StdSchedulerFactory
# to create a Quartz Scheduler Instance, if a different
# properties file is not explicitly specified.
#

org.quartz.scheduler.instanceName: DefaultQuartzScheduler
org.quartz.scheduler.rmi.export: false
org.quartz.scheduler.rmi.proxy: false
org.quartz.scheduler.wrapJobExecutionInUserTransaction: false

org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount: 10
org.quartz.threadPool.threadPriority: 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true

org.quartz.jobStore.misfireThreshold: 60000

org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore

Answer 1

您需要将以下属性添加到您的quartz.property 文件中（来源：click here）：

org.quartz.jobStore.isClustered : true

阅读本文以了解有关isClustered 属性的更多信息，请参阅this 链接。

请注意：

@DisallowConcurrentExecution 在您有 2 个不同作业且在同一节点上运行具有相同作业密钥的作业时有效。

而 isClustered 属性用于确保在应用程序运行多个节点时执行作业的单个实例，这些节点通过数据库表进行通信以实现原子性。