我有两个应用程序,一个注册到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
和“zookeeper”的数组
好的,我基本上有同样的问题。这很简单,实际上非常奇怪。因此,您实际上无法关闭ServiceDiscovery实例,它对我有用。但在这种情况下,他们不应该为discovery.queryForNames()提供任何结果。