我有两个应用程序,一个将自己注册到 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
和“动物园管理员”的数组