常规监听器
public class JobMain {
public static void main(String[] args) {
new ScheduleJobBootstrap(createRegistryCenter(), createJobConfiguration()).schedule();
}
private static CoordinatorRegistryCenter createRegistryCenter() {
CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration("zk_host:2181", "elastic-job-demo"));
regCenter.init();
return regCenter;
}
private static JobConfiguration createJobConfiguration() {
JobConfiguration jobConfiguration = JobConfiguration.newBuilder("test", 2)
.jobListenerTypes("simpleListener", "distributeListener").build();
}
}
分布式监听器
public class JobMain {
public static void main(String[] args) {
new ScheduleJobBootstrap(createRegistryCenter(), createJobConfiguration()).schedule();
}
private static CoordinatorRegistryCenter createRegistryCenter() {
CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration("zk_host:2181", "elastic-job-demo"));
regCenter.init();
return regCenter;
}
private static JobConfiguration createJobConfiguration() {
JobConfiguration jobConfiguration = JobConfiguration.newBuilder("test", 2)
.jobListenerTypes("simpleListener", "distributeListener").build();
}
}
