程序包 org.apache.dubbo.registry.zookeeper

类 ZookeeperServiceDiscovery

java.lang.Object

org.apache.dubbo.registry.client.AbstractServiceDiscovery

org.apache.dubbo.registry.zookeeper.ZookeeperServiceDiscovery

所有已实现的接口:

Comparable<Prioritized>, Prioritized, ServiceDiscovery

public class ZookeeperServiceDiscovery
extends AbstractServiceDiscovery

Zookeeper ServiceDiscovery implementation based on Apache Curator X Discovery

字段概要

从接口继承的字段 org.apache.dubbo.common.lang.Prioritized

COMPARATOR, MAX_PRIORITY, MIN_PRIORITY, NORMAL_PRIORITY

构造器概要

构造器

构造器	说明
ZookeeperServiceDiscovery()

方法概要

修饰符和类型	方法	说明
void	addServiceInstancesChangedListener(ServiceInstancesChangedListener listener)	Add an instance of ServiceInstancesChangedListener for specified service
void	doDestroy()
void	doInitialize(URL registryURL)
void	doRegister(ServiceInstance serviceInstance)
void	doUnregister(ServiceInstance serviceInstance)
void	doUpdate(ServiceInstance serviceInstance)
List<ServiceInstance>	getInstances(String serviceName)	Gets all service instances by the specified service name.
Page<ServiceInstance>	getInstances(String serviceName, int offset, int pageSize, boolean healthyOnly)	Get the pagination of service instances by the specified service name.
Set<String>	getServices()	Gets all service names
URL	getUrl()
void	removeServiceInstancesChangedListener(ServiceInstancesChangedListener listener)	unsubscribe to instances change event.
void	reRegisterWatcher(ZookeeperServiceDiscoveryChangeWatcher watcher)

从类继承的方法 org.apache.dubbo.registry.client.AbstractServiceDiscovery

destroy, getLocalInstance, initialize, isDestroy, register, unregister, update

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.dubbo.common.lang.Prioritized

compareTo, getPriority

从接口继承的方法 org.apache.dubbo.registry.client.ServiceDiscovery

createListener, dispatchServiceInstancesChangedEvent, dispatchServiceInstancesChangedEvent, dispatchServiceInstancesChangedEvent, dispatchServiceInstancesChangedEvent, getDefaultPageSize, getDelay, getInstances, getInstances, toString

构造器详细资料

ZookeeperServiceDiscovery

public ZookeeperServiceDiscovery()

方法详细资料

doInitialize

public void doInitialize(URL registryURL)
                  throws Exception

指定者:

doInitialize 在类中 AbstractServiceDiscovery

抛出:

Exception

getUrl

public URL getUrl()

doDestroy

public void doDestroy()
               throws Exception

指定者:

doDestroy 在类中 AbstractServiceDiscovery

抛出:

Exception

doRegister

public void doRegister(ServiceInstance serviceInstance)

指定者:

doRegister 在类中 AbstractServiceDiscovery

doUpdate

public void doUpdate(ServiceInstance serviceInstance)

指定者:

doUpdate 在类中 AbstractServiceDiscovery

doUnregister

public void doUnregister(ServiceInstance serviceInstance)
                  throws RuntimeException

指定者:

doUnregister 在类中 AbstractServiceDiscovery

抛出:

RuntimeException

getServices

public Set<String> getServices()

从接口复制的说明: ServiceDiscovery

Gets all service names

返回:

non-null read-only Set

getInstances

public List<ServiceInstance> getInstances(String serviceName)
                                   throws NullPointerException

从接口复制的说明: ServiceDiscovery

Gets all service instances by the specified service name.

参数:

serviceName - the service name

返回:

non-null List

抛出:

NullPointerException - if serviceName is null

getInstances

public Page<ServiceInstance> getInstances(String serviceName,
                                          int offset,
                                          int pageSize,
                                          boolean healthyOnly)

从接口复制的说明: ServiceDiscovery

Get the pagination of service instances by the specified service name. If healthyOnly == true, filter healthy instances only.

参数:

serviceName - the service name

offset - the offset of request , the number "0" indicates first page

pageSize - the number of request, the max value indicates the range is unlimited

healthyOnly - if true , filter healthy instances only

返回:

non-null Page object

addServiceInstancesChangedListener

public void addServiceInstancesChangedListener(ServiceInstancesChangedListener listener)
                                        throws NullPointerException,
                                               IllegalArgumentException

从接口复制的说明: ServiceDiscovery

Add an instance of ServiceInstancesChangedListener for specified service

Default, Current method will be invoked by the ServiceDiscoveryRegistry on the subscription, this method is used to trigger or adapt the vendor's change notification mechanism typically, like Zookeeper Watcher, Nacos EventListener. If the registry observes the change, It's suggested that the implementation could invoke ServiceDiscovery.dispatchServiceInstancesChangedEvent(String) method or variants

参数:

listener - an instance of ServiceInstancesChangedListener

抛出:

NullPointerException

IllegalArgumentException

removeServiceInstancesChangedListener

public void removeServiceInstancesChangedListener(ServiceInstancesChangedListener listener)
                                           throws IllegalArgumentException

从接口复制的说明: ServiceDiscovery

unsubscribe to instances change event.

抛出:

IllegalArgumentException

reRegisterWatcher

public void reRegisterWatcher(ZookeeperServiceDiscoveryChangeWatcher watcher)
                       throws Exception

抛出:

Exception