本文整理了Java中org.apache.twill.discovery.ZKDiscoveryService类的一些代码示例，展示了ZKDiscoveryService类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZKDiscoveryService类的具体详情如下：
包路径：org.apache.twill.discovery.ZKDiscoveryService
类名称：ZKDiscoveryService

ZKDiscoveryService介绍

[英]Zookeeper implementation of DiscoveryService and DiscoveryServiceClient.

Discoverable services are registered within Zookeeper under the namespace 'discoverable' by default. If you would like to change the namespace under which the services are registered then you can pass in the namespace during construction of ZKDiscoveryService.

Following is a simple example of how ZKDiscoveryService can be used for registering services and also for discovering the registered services.

DiscoveryService service = new ZKDiscoveryService(zkClient);@Override 
public InetSocketAddress getSocketAddress()  
return new InetSocketAddress(hostname, port); 
} 
}); 
... 
... 
ServiceDiscovered services = service.discovery("service-name"); 
... 
}

[中]Zookeeper实施DiscoveryService和DiscoveryServiceClient。
默认情况下，可发现服务在Zookeeper中的命名空间“Discoverable”下注册。如果您想更改服务注册时使用的名称空间，那么可以在构造ZKDiscoveryService时传入名称空间。
下面是一个简单的示例，说明如何使用ZKDescoveryService注册服务，以及如何发现已注册的服务。

DiscoveryService service = new ZKDiscoveryService(zkClient);@Override 
public InetSocketAddress getSocketAddress()  
return new InetSocketAddress(hostname, port); 
} 
}); 
... 
... 
ServiceDiscovered services = service.discovery("service-name"); 
... 
}

代码示例

代码示例来源：origin: apache/phoenix

ZKDiscoveryService zkDiscoveryService = new ZKDiscoveryService(zkClientService);
PooledClientProvider pooledClientProvider = new PooledClientProvider(
    config, zkDiscoveryService);

代码示例来源：origin: caskdata/cdap

@Override
 protected void shutDown() throws Exception {
  if (discoveryService != null) {
   discoveryService.close();
  }
 }
}

代码示例来源：origin: org.apache.twill/twill-core

@Override
public final synchronized ServiceDiscovered discoverService(String serviceName) {
 if (discoveryServiceClient == null) {
  discoveryServiceClient = new ZKDiscoveryService(zkClient);
 }
 return discoveryServiceClient.discover(serviceName);
}

代码示例来源：origin: cdapio/cdap

zkClient.startAndWait();
try (ZKDiscoveryService discoveryService = new ZKDiscoveryService(zkClient)) {
 Cancellable cancellable = discoveryService.register(
  new Discoverable("test", new InetSocketAddress(InetAddress.getLoopbackAddress(), 1234)));
 try {

代码示例来源：origin: cdapio/cdap

@Override
public Cancellable announce(String serviceName, int port, byte[] payload) {
 Discoverable discoverable = new Discoverable(serviceName, new InetSocketAddress(getHostname(), port), payload);
 return discoveryService.register(discoverable);
}

代码示例来源：origin: caskdata/cdap

@Override
public ServiceDiscovered discover(final String name) {
 for (DiscoverableProgramType type : DiscoverableProgramType.values()) {
  if (type.isPrefixOf(name)) {
   return clients.getUnchecked(name).discover(name);
  }
 }
 return masterDiscoveryService.discover(name);
}

代码示例来源：origin: cdapio/cdap

zkClient.startAndWait();
try (ZKDiscoveryService discoveryService = new ZKDiscoveryService(zkClient)) {
 Cancellable cancellable = discoveryService.register(
  new Discoverable("test", new InetSocketAddress(InetAddress.getLoopbackAddress(), 1234)));
 try {

代码示例来源：origin: caskdata/cdap

@Override
public Cancellable announce(String serviceName, int port, byte[] payload) {
 Discoverable discoverable = new Discoverable(serviceName, new InetSocketAddress(getHostname(), port), payload);
 return discoveryService.register(discoverable);
}

代码示例来源：origin: co.cask.tephra/tephra-core

@Override
 public ServiceDiscovered discover(String s) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.discover(s);
 }
};

代码示例来源：origin: caskdata/cdap

@Override
 public ZKDiscoveryService get() {
  return new ZKDiscoveryService(zkClient);
 }
}

代码示例来源：origin: cdapio/cdap

try (ZKDiscoveryService twillDiscoveryService = new ZKDiscoveryService(twillZKClient)) {
 InetSocketAddress socketAddr = new InetSocketAddress(InetAddress.getLoopbackAddress(), 43210);
 Cancellable cancellable = twillDiscoveryService.register(new Discoverable(discoverableName, socketAddr));
 try {

代码示例来源：origin: apache/twill

@Override
public final synchronized ServiceDiscovered discoverService(String serviceName) {
 if (discoveryServiceClient == null) {
  discoveryServiceClient = new ZKDiscoveryService(zkClient);
 }
 return discoveryServiceClient.discover(serviceName);
}

代码示例来源：origin: co.cask.cdap/cdap-spark-core2

@Override
public Cancellable announce(String serviceName, int port, byte[] payload) {
 Discoverable discoverable = new Discoverable(serviceName, new InetSocketAddress(getHostname(), port), payload);
 return discoveryService.register(discoverable);
}

代码示例来源：origin: cdapio/cdap

@Override
 protected void shutDown() throws Exception {
  if (discoveryService != null) {
   discoveryService.close();
  }
 }
}

代码示例来源：origin: org.apache.tephra/tephra-core

@Override
 public ServiceDiscovered discover(String s) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.discover(s);
 }
};

代码示例来源：origin: caskdata/cdap

@Override
protected void startUp() throws Exception {
 discoveryService = new ZKDiscoveryService(zkClient);
}

代码示例来源：origin: org.apache.tephra/tephra-core

@Override
 public Cancellable register(Discoverable discoverable) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.register(discoverable);
 }
};

代码示例来源：origin: co.cask.cdap/cdap-spark-core2

@Override
 protected void shutDown() throws Exception {
  if (discoveryService != null) {
   discoveryService.close();
  }
 }
}

代码示例来源：origin: caskdata/tephra

@Override
 public ServiceDiscovered discover(String s) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.discover(s);
 }
};

代码示例来源：origin: co.cask.cdap/cdap-spark-core2

@Override
protected void startUp() throws Exception {
 discoveryService = new ZKDiscoveryService(zkClient);
}