2

我有两个应用程序,一个将自己注册到 zookeeper 服务,另一个尝试列出已注册的服务。

但是,当我列出它们时,我没有找到任何服务

我正在注册服务如下

private ServiceDiscovery<InstanceDetails> getDiscovery() {
        return ServiceDiscoveryBuilder.builder(InstanceDetails.class)
            .basePath(Config.basePath)
            .client(curatorFramework)
            .serializer(jacksonInstanceSerializer)
            .build();
    }

public void advertiseAvailability() {
        try {
            ServiceDiscovery<InstanceDetails> discovery = getDiscovery();
            discovery.start();
            discovery.registerService(getInstance());
            discovery.close();
            System.out.println("Advertised");
        } catch (Exception e) {
            throw Throwables.propagate(e);
        }
    }

当我尝试获得服务时,我有以下内容:

public Collection<ServiceInstance<InstanceDetails>> getWorkers(String serviceName) {
        Collection<ServiceInstance<InstanceDetails>> instances;

        try {
            instances = discovery.queryForInstances(serviceName);
        } catch (Exception e) {
            throw Throwables.propagate(e);
        }

        return instances;
    }

请注意,discovery.queryForNames()返回一个包含我serviceName和“动物园管理员”的数组

4

1 回答 1

0

好的,我基本上有同样的问题。解决起来很简单,实际上很奇怪。所以你实际上不能关闭你的ServiceDiscovery实例,它对我有用。但在这种情况下,他们不应该为 discovery.queryForNames() 给出任何结果。

于 2019-03-10T17:32:04.850 回答