在上一篇已经了解到了服务注册与发现、Eureka、Eureka 简单示例、Eureka Server 中查看 Client 状态等。接下来需要了解 Eureka 的 REST API、核心类、调优等组件。

REST API

在 Eureka Server 的可视化页面中，我们可以看到每个微服务的注册信息。在 Server、Client 的配置文件中，都指定了一个 defaultZone: ip:port/eureka/，那么这个配置的作用是什么？为什么在 ip、端口 后面要加上一个 /eureka ？

/eureka 就是 Eureka 的 REST API 的端点地址。

/eureka/ 端点

启动 Eureka Server、Client，在浏览器中输入： http://localhost:8761/eureka/apps ，可以看到如下信息：

<!-- 所有工程 -->
<applications> 
    <versions__delta>1</versions__delta>   
    <apps__hashcode>UP_1_</apps__hashcode>    
    <application> 
        <!-- 单个实例的名称 -->
        <name>SPRING-CLOUD-EUREKA-CLIENT-SIMPLE</name>    
         <instance> 
            <!-- 单个实例的 instance-id -->
            <instanceId>spring-cloud-eureka-client-simple:8081</instanceId>    
            <!-- 实例的 hostname，没有指定时用 ip -->
            <hostName>10.10.10.141</hostName>    
            <app>SPRING-CLOUD-EUREKA-CLIENT-SIMPLE</app>    
            <!-- 实例的ip -->
            <ipAddr>10.10.10.141</ipAddr>    
            <!-- 实例状态 -->
            <status>UP</status>    
            <overriddenstatus>UNKNOWN</overriddenstatus>    
            <!-- 端口 -->
            <port enabled="true">8081</port>    
            <!-- https -->
            <securePort enabled="false">443</securePort>    
            <countryId>1</countryId>    
            <dataCenterInfo class="com.netflix.appinfo.InstanceInfo$DefaultDataCenterInfo"> 
                <name>MyOwn</name> 
            </dataCenterInfo>    
            <leaseInfo> 
                <!-- 每多长时间续约一次，单位 秒 -->
                <renewalIntervalInSecs>30</renewalIntervalInSecs>    
                <!-- 续约过期时间，单位秒。规定时间内没有续约会剔除 Eureka Server -->
                <durationInSecs>90</durationInSecs>    
                <!-- 注册时间 -->
                <registrationTimestamp>1547800471059</registrationTimestamp>    
                <!-- 上一次续约时间 -->
                <lastRenewalTimestamp>1547800471059</lastRenewalTimestamp>    
                <evictionTimestamp>0</evictionTimestamp>    
                <serviceUpTimestamp>1547800471059</serviceUpTimestamp> 
            </leaseInfo>    
            <metadata> 
                <management.port>8081</management.port>    
                <jmx.port>10235</jmx.port> 
            </metadata>    
            <!-- 主页面 -->
            <homePageUrl>http://10.10.10.141:8081/</homePageUrl>    
            <!-- 实例信息 -->
            <statusPageUrl>http://10.10.10.141:8081/actuator/info</statusPageUrl>    
            <!-- 实例健康检查 -->
            <healthCheckUrl>http://10.10.10.141:8081/actuator/health</healthCheckUrl>    
            <vipAddress>spring-cloud-eureka-client-simple</vipAddress>    
            <secureVipAddress>spring-cloud-eureka-client-simple</secureVipAddress>    
            <isCoordinatingDiscoveryServer>false</isCoordinatingDiscoveryServer>    
            <lastUpdatedTimestamp>1547800471059</lastUpdatedTimestamp>    
            <lastDirtyTimestamp>1547800470997</lastDirtyTimestamp>    
            <actionType>ADDED</actionType> 
        </instance> 
    </application> 
</applications>

此时看到的信息，是在 Eureka Server 中注册的所有Client 的信息。如果想要查询单个 Client 的信息，可以访问 http://localhost:8761/eureka/apps/{application.name} ，如：http://localhost:8761/eureka/apps/SPRING-CLOUD-EUREKA-CLIENT-SIMPLE

常用的 REST API

常用的 Eureka REST API 除了 /eureka/apps 之外，还有如下接口

在进行新实例的注册时，传入的 json、xml 的格式需要与调用获取单个实例所返回的数据格式一致。具体的数据需要自己指定，需要注意的是，如果要注册的实例的ip、端口已经存在的话，不会再次注册，需要修改 instanceId。

Eureka 核心类

Eureka 提供了一些核心的类，这些类中保存了 Eureka Server、Client 的注册信息、运行时的信息等。

InstanceInfo

InstanceInfo 代表了注册的服务实例(位置： com/netflix/appinfo/InstanceInfo.java)

可以看出，整个 InstanceInfo 的返回值信息，就是访问 /eureka/apps/{appId} 的返回值，也是通过 REST API 向 Eureka Server 注册时的 body。

LeaseInfo

LeaseInfo 标识应用实例的租约信息(位置： com/netflix/appinfo/LeaseInfo.java)

ServiceInstanceInfo

ServiceInstanceInfo 是一个标识一个应用实例的接口，约定了服务的发现的实例应用有哪些通用信息(位置： org/springframework/cloud/client/ServiceInstanceInfo.java)

对于 ServiceInstanceInfo 接口的实现为：EurekaRegistration(位置：org/springframework/cloud/netflix/eureka/serviceregistry/EurekaRegistration.java)，EurekaRegistration 同时还实现了 Closeable 接口，这个接口的作用之一是在 close 的时候调用 eurekaClient.shutdown() 方法，实现优雅关闭 Eureka Client。

InstanceStatus

InstanceStatus 是一个枚举类型，源码如下：

public static enum InstanceStatus {
    UP,
    DOWN,
    STARTING,
    OUT_OF_SERVICE,
    UNKNOWN;

    private InstanceStatus() {
    }

    public static InstanceInfo.InstanceStatus toEnum(String s) {
        if (s != null) {
            try {
                return valueOf(s.toUpperCase());
            } catch (IllegalArgumentException var2) {
                InstanceInfo.logger.debug("illegal argument supplied to InstanceStatus.valueOf: {}, defaulting to {}", s, UNKNOWN);
            }
        }

        return UNKNOWN;
    }
}

其中定义了 5 种状态，对应 Client 的 5 种状态。

服务的核心操作

对于服务发现来说，一般都是围绕几个核心的概念进行设计：

服务发现（register）
服务下线（cancel）
服务租约（renew）
服务剔除（evict）

围绕这几个概念，Eureka 设计了一些核心的操作类：

• com/netflix/eureka/lease/LeaseManager.java
• com/netflix/discovery/shared/LookupService.java
• com/netflix/eureka/registry/InstanceRegistry.java
• com/netflix/eureka/registry/AbstractInstanceRegistry.java
• com/netflix/eureka/registry/PeerAwareInstanceRegistry.java

在 Netflix Eureka 的基础上，Spring Cloud 抽象或定义了几个核心类:

• org/springframewor/cloud/netflix/eureka/server/InstanceRegistry.java
• org/springframewor/cloud/client/serviceregistry/ServiceRegistry.kava
• org/springframewor/cloud/netflix/eureka/serviceregistry/EurekaServiceRegistry.java
• org/springframewor/cloud/netflix/eureka/serviceregistry/EurekaRegistration.java
• org/springframewor/cloud/netflix/eureka/EurekaClientAutoConfiguration.java
• org/springframewor/cloud/netflix/eureka/EurekaClientConfigBean.java
• org/springframewor/cloud/netflix/eureka/EurekaInstanceConfigBean.java

其中：LeaseManager、LookupService 是 Eureka 关于服务发现相关操作操作定义的接口类，LeaseManager 定义了服务写操作相关方法，LookupService 定义查询操作的相关方法。

LeaseManager

public interface LeaseManager<T> {
    
    void register(T r, int leaseDuration, boolean isReplication);

    boolean cancel(String appName, String id, boolean isReplication);

    boolean renew(String appName, String id, boolean isReplication);

    void evict();
}、

• register：用于注册服务实例信息
• cancel：用于删除服务实例信息
• renew：用于和 Eureka Server 进行心跳操作，维持租约
• evict：Server 端的方法，用于剔除租约过期的服务实例。

LoopupService

public interface LookupService<T> {

    Application getApplication(String appName);

    Applications getApplications();

    List<InstanceInfo> getInstancesById(String id);

    InstanceInfo getNextServerFromEureka(String virtualHostname, boolean secure);
}

• getApplication：根据 appName 获取服务信息
• getApplications：获取所有注册的服务信息
• getInstancesById：根据 appid，获取所有实例
• getNextServerFromEureka：根据虚拟hostname、是否是 https，获取下一个服务实例方法（默认轮训获取）

Eureka 参数调优

Client 端

基本参数

定时任务参数

http 参数

Eureka Client 底层使用 HttpClient 与 Eureka Server 通信。

Server 端

Server 端的参数调优分为：基本参数，Response Cache、Peer、Http 等

基本参数

Response Cache 参数

Eureka Server 为了提升自身 REST API 接口的性能，提供了两个缓存：一个是基于 ContioncurrentMap 的 readOnlyCacheMap，一个是基于 Guava Chahe 的 readWriteCacheMap。

peer 参数

http 参数