elastic-job-lite在只有一个分片的情况下不同服务器之间是如何抢占job的？

Question

首先，在一台机器上启动一个服务，代码是这样的

public class JobDemo 
{
    public static void main(String[] args)
    {
        new JobScheduler(createRegistryCenter(), createJobConfiguration()).init();
//        new JobScheduler(createRegistryCenter(), createJobConfiguration1()).init();
//        new JobScheduler(createRegistryCenter(), createJobConfiguration(), new MyElasticJobListener()).init();
    }
    
    private static CoordinatorRegistryCenter createRegistryCenter()
    {
        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration("99.48.70.4:2181", "test"));
        regCenter.init();
        return regCenter;
    }
    
    private static LiteJobConfiguration createJobConfiguration()
    {
        // 定义作业核心配置
        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder("demoSimpleJob", "0/6 * * * * ?", 1).build();
        // 定义SIMPLE类型配置
        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, MyElasticJob.class.getCanonicalName());
        // 定义Lite作业根配置
        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
        
        return simpleJobRootConfig;
    }
    
    private static LiteJobConfiguration createJobConfiguration1()
    {
        // 定义作业核心配置
        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder("demoSimpleJob1", "0/6 * * * * ?", 1).build();
        // 定义SIMPLE类型配置
        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, MyElasticJob2.class.getCanonicalName());
        // 定义Lite作业根配置
        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
        
        return simpleJobRootConfig;
    }
}

在监控页面是这样的

然后我本机启动同样的代码之后

 

我本机是如何抢占成这个服务器的，而原先起的服务却处于等待的高可用状态？

 

Answer 1

使用zookeeper的分布式锁