elstic-job的zk连接注册问题

elstic-job的zk注册问题

问题

使用elstic-job时,zk注册有问题,报错如下:

在这里插入图片描述

@Bean(initMethod = "init")
    public ZookeeperRegistryCenter regCenter(@Value("${regCenter.serverList}") final String serverList,
            @Value("${regCenter.namespace}") final String namespace) {
        return new ZookeeperRegistryCenter(new ZookeeperConfiguration(serverList, namespace));
    }

解决方案

更改zk的连接方式,采用CoordinatorRegistryCenter

 @Bean(initMethod = "init")
    public CoordinatorRegistryCenter regCenter(@Value("${regCenter.serverList}") final String serverList,
                                               @Value("${regCenter.namespace}") final String namespace) {
        ZookeeperConfiguration zkConfig = new ZookeeperConfiguration(serverList, namespace);
        zkConfig.setMaxSleepTimeMilliseconds(60000);  //设置最大超时时间,默认 3*3000- 9S可能不满足
        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(zkConfig);
        regCenter.init();
        return regCenter;
    }```



版权声明:本文为qq_36094023原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。