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

类 MultipleServiceDiscovery

java.lang.Object

org.apache.dubbo.registry.multiple.MultipleServiceDiscovery

所有已实现的接口:

Comparable<Prioritized>, Prioritized, ServiceDiscovery

public class MultipleServiceDiscovery
extends Object
implements ServiceDiscovery

字段概要

字段

修饰符和类型	字段	说明
static String	REGISTRY_PREFIX_KEY

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

COMPARATOR, MAX_PRIORITY, MIN_PRIORITY, NORMAL_PRIORITY

构造器概要

构造器

构造器	说明
MultipleServiceDiscovery()

方法概要

修饰符和类型	方法	说明
void	addServiceInstancesChangedListener(ServiceInstancesChangedListener listener)	Add an instance of ServiceInstancesChangedListener for specified service
ServiceInstancesChangedListener	createListener(Set<String> serviceNames)
void	destroy()	Destroy the ServiceDiscovery
Page<ServiceInstance>	getInstances(String serviceName, int offset, int pageSize, boolean healthyOnly)	Get the pagination of service instances by the specified service name.
ServiceInstance	getLocalInstance()
Set<String>	getServices()	Gets all service names
URL	getUrl()
void	initialize(URL registryURL)	Initializes the ServiceDiscovery
boolean	isDestroy()
void	register(ServiceInstance serviceInstance)	Registers an instance of ServiceInstance.
void	unregister(ServiceInstance serviceInstance)	Unregisters an instance of ServiceInstance.
void	update(ServiceInstance serviceInstance)	Updates the registered ServiceInstance.

从类继承的方法 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

dispatchServiceInstancesChangedEvent, dispatchServiceInstancesChangedEvent, dispatchServiceInstancesChangedEvent, dispatchServiceInstancesChangedEvent, getDefaultPageSize, getDelay, getInstances, getInstances, getInstances, removeServiceInstancesChangedListener, toString

字段详细资料

REGISTRY_PREFIX_KEY

public static final String REGISTRY_PREFIX_KEY

另请参阅:

常量字段值

构造器详细资料

MultipleServiceDiscovery

public MultipleServiceDiscovery()

方法详细资料

initialize

public void initialize(URL registryURL)
                throws Exception

从接口复制的说明: ServiceDiscovery

Initializes the ServiceDiscovery

指定者:

initialize 在接口中 ServiceDiscovery

参数:

registryURL - the url to connect service registry

抛出:

Exception - If met with error

getUrl

public URL getUrl()

指定者:

getUrl 在接口中 ServiceDiscovery

destroy

public void destroy()
             throws Exception

从接口复制的说明: ServiceDiscovery

Destroy the ServiceDiscovery

指定者:

destroy 在接口中 ServiceDiscovery

抛出:

Exception - If met with error

isDestroy

public boolean isDestroy()

指定者:

isDestroy 在接口中 ServiceDiscovery

register

public void register(ServiceInstance serviceInstance)
              throws RuntimeException

从接口复制的说明: ServiceDiscovery

Registers an instance of ServiceInstance.

指定者:

register 在接口中 ServiceDiscovery

参数:

serviceInstance - an instance of ServiceInstance to be registered

抛出:

RuntimeException - if failed

update

public void update(ServiceInstance serviceInstance)
            throws RuntimeException

从接口复制的说明: ServiceDiscovery

Updates the registered ServiceInstance.

指定者:

update 在接口中 ServiceDiscovery

参数:

serviceInstance - the registered ServiceInstance

抛出:

RuntimeException - if failed

unregister

public void unregister(ServiceInstance serviceInstance)
                throws RuntimeException

从接口复制的说明: ServiceDiscovery

Unregisters an instance of ServiceInstance.

指定者:

unregister 在接口中 ServiceDiscovery

参数:

serviceInstance - an instance of ServiceInstance to be unregistered

抛出:

RuntimeException - if failed

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

指定者:

addServiceInstancesChangedListener 在接口中 ServiceDiscovery

参数:

listener - an instance of ServiceInstancesChangedListener

抛出:

NullPointerException

IllegalArgumentException

createListener

public ServiceInstancesChangedListener createListener(Set<String> serviceNames)

指定者:

createListener 在接口中 ServiceDiscovery

getInstances

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

从接口复制的说明: ServiceDiscovery

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

指定者:

getInstances 在接口中 ServiceDiscovery

参数:

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

抛出:

NullPointerException - if serviceName is null

IllegalArgumentException - if offset or pageSize is negative number

UnsupportedOperationException - if not supported

getServices

public Set<String> getServices()

从接口复制的说明: ServiceDiscovery

Gets all service names

指定者:

getServices 在接口中 ServiceDiscovery

返回:

non-null read-only Set

getLocalInstance

public ServiceInstance getLocalInstance()

指定者:

getLocalInstance 在接口中 ServiceDiscovery