Spring-cloud & Netflix 源碼解析：Eureka 服務註冊發現接口 ****

http://www.idouba.net/spring-cloud-source-eureka-client-api/?utm_source=tuicool&utm_medium=referral

***************************

 先關注下netflix eureka server 原生提供的接口。https://github.com/Netflix/eureka/wiki/Eureka-REST-operations 這是對非java的服務使用eureka時能夠使用的rest接口。對於java應用，直接使用java的接口就能夠

Netxflix 提供的主要操做定義在com.netflix.discovery.EurekaClient中。主要操做有：

其實現類是 com.netflix.discovery.DiscoveryClient。

Spring cloud中對其進行了封裝，定義在org.springframework.cloud.client.discovery.DiscoveryClient中，

能夠看到比netflix原生的接口簡單了不少，其實現類是org.springframework.cloud.netflix.eureka.EurekaDiscoveryClient，裏面全部的操做都是對netflix 原生的接口的封裝，能夠認爲這是eureka 客戶端須要向外提供的功能。

主要提供的服務以下：

1. 獲取服務名爲serviceId的全部服務實例。實現就是調用netflix的eurekaClient來獲取。

public List<ServiceInstance> getInstances(String serviceId) { List<InstanceInfo> infos = this.eurekaClient.getInstancesByVipAddress(serviceId, false); List<ServiceInstance> instances = new ArrayList<>(); for (InstanceInfo info : infos) { instances.add(new EurekaServiceInstance(info)); } return instances; }

1 2 3 4 5 6 7 8 9

public List<ServiceInstance> getInstances(String serviceId) { List<InstanceInfo> infos = this.eurekaClient.getInstancesByVipAddress(serviceId, false); List<ServiceInstance> instances = new ArrayList<>(); for (InstanceInfo info : infos) { instances.add(new EurekaServiceInstance(info)); } return instances; }

2. 獲取本地發服務實例。解析EurekaInstanceConfig類型的服務實例配置，是本身當前服務的配置，原本這個對象就是在client中要註冊到服務端的。

public ServiceInstance getLocalServiceInstance() { return new ServiceInstance() { @Override public String getServiceId() { return EurekaDiscoveryClient.this.config.getAppname(); } @Override public String getHost() { return EurekaDiscoveryClient.this.config.getHostName(false); } @Override public int getPort() { return EurekaDiscoveryClient.this.config.getNonSecurePort(); } @Override public boolean isSecure() { return EurekaDiscoveryClient.this.config.getSecurePortEnabled(); } @Override public URI getUri() { return DefaultServiceInstance.getUri(this); } @Override public Map<String, String> getMetadata() { return EurekaDiscoveryClient.this.config.getMetadataMap(); } }; }

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33

public ServiceInstance getLocalServiceInstance() { return new ServiceInstance() { @Override public String getServiceId() { return EurekaDiscoveryClient.this.config.getAppname(); }   @Override public String getHost() { return EurekaDiscoveryClient.this.config.getHostName(false); }   @Override public int getPort() { return EurekaDiscoveryClient.this.config.getNonSecurePort(); }   @Override public boolean isSecure() { return EurekaDiscoveryClient.this.config.getSecurePortEnabled(); }   @Override public URI getUri() { return DefaultServiceInstance.getUri(this); }   @Override public Map<String, String> getMetadata() { return EurekaDiscoveryClient.this.config.getMetadataMap(); } }; }

3. 獲取全部的服務。不一樣於netflix的的eurekaClient須要獲得一個Applications的複雜對象，只是獲得用戶關心的服務名便可。

public List<String> getServices() { Applications applications = this.eurekaClient.getApplications(); if (applications == null) { return Collections.emptyList(); } List<Application> registered = applications.getRegisteredApplications(); List<String> names = new ArrayList<>(); for (Application app : registered) { if (app.getInstances().isEmpty()) { continue; } names.add(app.getName().toLowerCase()); } return names; }

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

public List<String> getServices() { Applications applications = this.eurekaClient.getApplications(); if (applications == null) { return Collections.emptyList(); } List<Application> registered = applications.getRegisteredApplications(); List<String> names = new ArrayList<>(); for (Application app : registered) { if (app.getInstances().isEmpty()) { continue; } names.add(app.getName().toLowerCase()); } return names; }

spring cloud 前面接口中涉及的主要數據結構是ServiceInstance

其實現類org.springframework.cloud.netflix.eureka.EurekaDiscoveryClient.EurekaServiceInstance，定義在spring-cloud-netflix-eureka-client 包中，是EurekaDiscoveryClient的一個內部靜態類，能夠看到是對netflix原生的com.netflix.appinfo.InstanceInfo的一種封裝。

public static class EurekaServiceInstance implements ServiceInstance { private InstanceInfo instance; ...

1 2 3

public static class EurekaServiceInstance implements ServiceInstance { private InstanceInfo instance; ...

看到實現的接口 org.springframework.cloud.client.ServiceInstance，定義在spring-cloud-commons中。也體現了spring clound的一種設計哲學，在common中只是規定（定義）行爲，而實如今其餘包中。

org.springframework.cloud.client.discovery.DiscoveryClient 也是定義在common中，而其實現類org.springframework.cloud.netflix.eureka.EurekaDiscoveryClient定義在spring-cloud-netflix-eureka-client中，即spring cloud須要有服務發現功能，eureka只是其中的一種選擇。

@RequiredArgsConstructor public class EurekaDiscoveryClient implements DiscoveryClient { public static final String DESCRIPTION = 「Spring Cloud Eureka Discovery Client」; ...

1 2 3 4

@RequiredArgsConstructor public class EurekaDiscoveryClient implements DiscoveryClient { public static final String DESCRIPTION = 「Spring Cloud Eureka Discovery Client」; ...

完。

 

原創文章。爲了維護文章的版本一致、最新、可追溯，轉載請註明： 轉載自idouba

本文連接地址: Netflix源碼解析之Eureka：Eureka 服務註冊發現接口