camel-quartz2：集群配置

Question

我想设置带有集群选项的 camel-quartz2 调度程序。

这是我当前的编码/配置：

package com.foo.bar.quartz;


import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;

@Configuration
@EnableAutoConfiguration
@ComponentScan({"com.foo.bar.quartz.camel"})
public class Application {

    public static void main(String[] args) throws Exception {
        SpringApplication.run(Application.class, args);
    }
}

package com.foo.bar.quartz;

import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.context.web.SpringBootServletInitializer;

public class ApplicationWebXml extends SpringBootServletInitializer {

    @Override
    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
        application
            .showBanner(false)
            .sources(Application.class);

        return application;
    }   
}

package com.foo.bar.quartz.camel;

import org.apache.camel.LoggingLevel;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.context.annotation.Configuration;

@Configuration
public class CamelScheduler extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        from("quartz2://group1/trigger1?cron=0/2+*+*+*+*+?&stateful=true")
        .routeId("quartztimer")
        .setHeader("ROUTING_KEY", simple("'trigger1'"))
        .log(LoggingLevel.INFO, "Yeah quartz rocks, routingKey: ${header.ROUTING_KEY}");

    }

}

org.quartz.scheduler.skipUpdateCheck = true
org.quartz.scheduler.instanceName = MyClusteredScheduler
org.quartz.scheduler.instanceId = AUTO
org.quartz.scheduler.jobFactory.class = org.quartz.simpl.SimpleJobFactory
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.dataSource = myDS
org.quartz.jobStore.tablePrefix = QRTZ_
org.quartz.jobStore.isClustered=true
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10     
org.quartz.jobStore.clusterCheckinInterval = 20000

org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver
org.quartz.dataSource.myDS.URL = jdbc:mysql://localhost:3306/cntmx?characterEncoding=utf8
org.quartz.dataSource.myDS.user = blah
org.quartz.dataSource.myDS.password = hlab
org.quartz.dataSource.myDS.maxConnections = 12     

我将此应用程序复制到 2 个单独的项目中，并将它们命名为quartz-demo-1、quartz-demo-2。

然后我在同一个 Apache 服务器上运行这两个应用程序。

两个调度程序每 2 秒同时触发一次：

2015-09-14 14:23:28 quartz-demo-2 [MyClusteredScheduler-camel-1-1_Worker-3] INFO  quartztimer - Yeah quartz rocks, routingKey: 'trigger1' 
2015-09-14 14:23:28 quartz-demo-1 [MyClusteredScheduler-camel-1_Worker-3] INFO  quartztimer - Yeah quartz rocks, routingKey: 'trigger1' 
2015-09-14 14:23:30 quartz-demo-1 [MyClusteredScheduler-camel-1_Worker-4] INFO  quartztimer - Yeah quartz rocks, routingKey: 'trigger1' 
2015-09-14 14:23:30 quartz-demo-2 [MyClusteredScheduler-camel-1-1_Worker-4] INFO  quartztimer - Yeah quartz rocks, routingKey: 'trigger1' 
2015-09-14 14:23:32 quartz-demo-1 [MyClusteredScheduler-camel-1_Worker-5] INFO  quartztimer - Yeah quartz rocks, routingKey: 'trigger1' 
2015-09-14 14:23:32 quartz-demo-2 [MyClusteredScheduler-camel-1-1_Worker-5] INFO  quartztimer - Yeah quartz rocks, routingKey: 'trigger1' 

期望的行为是每两秒钟应该只有一个来自任一应用程序的触发来模拟故障转移。我该如何配置这种行为？即使从同一个石英表中读取数据，两个调度程序似乎也不知道彼此。

非常感谢您的帮助。

Answer 1

解决此问题的两种方法：

1) 在 QuartzComponent 上定义 propertiesFile 属性。请参阅http://camel.apache.org/quartz2.html

上的配置 quartz.properties 文件

--或--

2) 在不同的 JVM 上运行第二条路由。这就是修复它的原因：

这与与骆驼上下文关联的 JMX 管理名称有关。看起来 Quartz2 组件将管理名称 (http://camel.apache.org/maven/camel-2.15.0/camel-core/apidocs/org/apache/camel/CamelContext.html#getManagementName()) 附加到 org.quartz.scheduler.instanceName 属性中定义的名称，如果您没有像我上面描述的那样定义 propertiesFile 属性。

请参见此处的第 140 行： http://grepcode.com/file/repo1.maven.org/maven2/org.apache.camel/camel-quartz2/2.12.0/org/apache/camel/component/quartz2/QuartzComponent.java

由于您在同一个 JVM 上运行，因此两个骆驼上下文被分配了唯一的管理名称，从而产生了唯一的调度程序名称。这将阻止集群按预期工作。