使用Eureka做服务发现(二)

╰半夏微凉° 2022-06-13 08:30 194阅读 0赞

# 概述 #

这不是一篇使用指南，使用指南应该是循序渐进的；也不是源码解析，源码解析应该高屋建瓴，然后层层递进。我只是轻松的把该文写成在看代码的过程中的简单记录，有空再详细整理吧。

Eureka Server提供了一个Web管理页面，还有一系列的基于HTTP的API，提供注册、解除绑定，查找服务等功能。API文档位于：[API文档][API]  
EurekaServer没有把信息在后端存储中持久化，而是存储在内存中。注册表中的每个服务实例都会采用向Server发送心跳的方式保持他们在注册表中的状态更新。Client端也在自己的内存中缓存了注册表信息，使得他们访问远程服务时，不必每次都向Server请求注册表信息。

默认情况下，每个Eureka Server同时也是一个Eureka Client，并且至少需要一个serviceUrl来定位Server。

为什么Eureka Server能够在提供HTTP API的同时，还是一个Eureka Client？Eureka Client主要完成什么工作？下面我们逐步的来解析。

# Web.xml #

Eureka Server是一个Web工程，所以我们就先来看一下web.xml，比较重要的有以下两个配置：

其中，系统启动的时候会调用com.netflix.eureka.EurekaBootStrap；并且，系统通过扫描com.sun.jersey;com.netflix中的Resource来对外提供HTTP服务。

# contextInitialized #

*  首先，会调用`contextInitialized`方法，该方法的主要作用是初始化Eureka，包括发布注册表和Eureka Server之间的同步功能。
    
    <table style="border-collapse:collapse; border-spacing:0px; margin:0px; width:auto; border:none; font-size:14px; table-layout:fixed"> 
     <tbody> 
      <tr style="background-color:rgb(249,249,249)"> 
       <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px 20px 1px 1px; color:rgb(102,102,102); background:rgb(247,247,247); line-height:1.6; border:none; text-align:right">
            
             
         <div style="height:20px">
          
              
             1
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             2
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             3
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             4
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             5
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             6
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             7
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             8
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             9
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             10
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             11
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             12
            
             
         </div></pre> </td> 
       <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px; color:rgb(77,77,76); background:rgb(247,247,247); line-height:1.6; border:none">
            
             
         <div style="height:20px">
             
              
          <span style="color:rgb(66,113,174)"><span style="color:rgb(137,89,168)">public</span> <span style="color:rgb(137,89,168)">void</span> <span style="color:rgb(62,153,159)">contextInitialized</span><span style="color:rgb(245,135,31)">(ServletContextEvent event)</span> </span>{
            
             
         </div>
            
             
         <div style="height:20px">        
             
              
          <span style="color:rgb(137,89,168)">try</span> {
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                         initEurekaEnvironment();
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                         initEurekaServerContext();
            
             
         </div>
            
             
         <div style="height:20px"></div>
            
             
         <div style="height:20px">
          
              
                         ServletContext sc = event.getServletContext();
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                         sc.setAttribute(EurekaServerContext.class.getName(), serverContext);
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                     } 
             
              
          <span style="color:rgb(137,89,168)">catch</span> (Throwable e) {
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                         logger.error(
             
              
          <span style="color:rgb(113,140,0)">"Cannot bootstrap eureka server :"</span>, e);
            
             
         </div>
            
             
         <div style="height:20px">            
             
              
          <span style="color:rgb(137,89,168)">throw</span> 
             
              
          <span style="color:rgb(137,89,168)">new</span> RuntimeException(
             
              
          <span style="color:rgb(113,140,0)">"Cannot bootstrap eureka server :"</span>, e);
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                     }
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                 }
            
             
         </div></pre> </td> 
      </tr> 
     </tbody> 
    </table>

从函数名称就可以看出，主要做了三件事情：

1.  初始化EurekaServer所需要的一些变量
2.  初始化ServerContext
3.  把ServerContext保存在attribute中  
    下面我们逐一进行分析。

## 初始化EurekaServer所需要变量 ##

initEurekaEnvironment()方法的作用是初始化Eureka的环境配置信息，Euerka基于Archaius，配置都是通过`ConfigurationManager.getConfigInstance().getXXX`来加载的。该方法主要配置了两个参数DataCenter和Environment。其中DataCenter配置我们是否使用了云；Environment配置我们是在测试环境、生产环境、开发环境等。

*  首先配置DataCenter, 默认情况下是`default`，另一个可配置的值是`cloud`，表示使用AWS。可以在配置文件中通过”eureka.datacenter”修改。
    
    <table style="border-collapse:collapse; border-spacing:0px; margin:0px; width:auto; border:none; font-size:14px; table-layout:fixed"> 
     <tbody> 
      <tr style="background-color:rgb(249,249,249)"> 
       <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px 20px 1px 1px; color:rgb(102,102,102); background:rgb(247,247,247); line-height:1.6; border:none; text-align:right">
            
             
         <div style="height:20px">
          
              
             1
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             2
            
             
         </div></pre> </td> 
       <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px; color:rgb(77,77,76); background:rgb(247,247,247); line-height:1.6; border:none">
            
             
         <div style="height:20px">
             
              
          <span style="color:rgb(137,89,168)">private</span> 
             
              
          <span style="color:rgb(137,89,168)">static</span> 
             
              
          <span style="color:rgb(137,89,168)">final</span> String CLOUD = 
             
              
          <span style="color:rgb(113,140,0)">"cloud"</span>;
            
             
         </div>
            
             
         <div style="height:20px">
             
              
          <span style="color:rgb(137,89,168)">private</span> 
             
              
          <span style="color:rgb(137,89,168)">static</span> 
             
              
          <span style="color:rgb(137,89,168)">final</span> String DEFAULT = 
             
              
          <span style="color:rgb(113,140,0)">"default"</span>;
            
             
         </div></pre> </td> 
      </tr> 
     </tbody> 
    </table>
 *  随后设置了Environment，默认情况下是test。可以在配置文件中通过”eureka.environment”修改。

## 初始化ServerContext ##

Eureka Server的启动需要很多配置信息，都在`initEurekaServerContext()`方法中进行加载。  
这里有几个概念需要明确一下：

*  **Eureka Server**：是一个注册中心，provider可以向注册中心注册自己，consumer可以在注册中心中查询provider
 *  **Eureka Client**：与Eureka Server相区别，是Server的使用者，provider和consumer都可以称作是Eureka Client。Client和Instance是完全不同的,Client的作用是和Server交互，而instance的作用是对外提供服务。
 *  **Eureka Service**：一个微服务，在Eureka中注册，通过一个ID获取到，是一组Eureka Instance。
 *  **Eureka Instance**：一个微服务的实例，一个微服务可以扩展为多个实例来提高可用性和可靠性。

配置信息：

*  **EurekaServerConfig** : `EurekaServerConfig eurekaServerConfig = new DefaultEurekaServerConfig();` 该配置都是Server需要的信息，在DefaultEurekaServerConfig中都提供了默认的配置, 可以加载”eureka-server.properties”配置文件覆盖默认的配置，当然，文件名是可以修改的。通过DefaultEurekaServerConfig提供的配置都是可以动态修改的。（但是否能够动态生效呢？）
 *  **EurekaInstanceConfig** : 该配置主要提供了注册到Eureka Server上的实例需要提供的信息，这样在服务注册后，就可以用通用的方式通过virtual hostname（VIPAddress, 可以简单想象成类似域名）获取信息，方便不同的实例之间进行调用通信。在不使用亚马逊云时，调用`new MyDataCenterInstanceConfig()`获取配置。MyDataCenterInstanceConfig只是PropertiesInstanceConfig的封装，配置信息都在PropertiesInstanceConfig中。
 *  **EurekaClientConfig** ： 是EurekaClient需要的信息，在DefaultEurekaClientConfig中提供了默认配置。默认读取”eureka-client.properties”配置。
 *  **ApplicationInfoManager**： 在EurekaInstanceConfig的基础上，能够提供初始化注册到Server所需要的信息，并且能够被其他模块获取。

### 新建EurekaClient ###

`EurekaClient eurekaClient = new DiscoveryClient(applicationInfoManager, eurekaClientConfig);`这行代码创建了一个EurekaClient，EurekaClient提供了以下功能：

*  能够以多种方式获取InstanceInfo信息（作为consumer）
 *  能够获取到本地Client的信息（regions，serviceUrl等）
 *  能够注册健康检查，获取健康检查handler  
    DiscoveryClient作为EurekaClient的一个实现，还提供了以下功能：
 *  向Eureka Server注册当前实例
 *  向Eureka Server更新租约
 *  当Eureka Server停止的时候取消租约
 *  查找Eureka Server中注册的服务和实例  
    Eureka Client需要一个Eureka Server列表来实现高可用，当其中某个实例出现故障时，请求其他实例。

##### 新建Executor #####

新建了两个ThreadPoolExecutor和一个ScheduledThreadPoolExecutor，其中scheduler用来实现定时调用，具体的工作还是通过调用heartbeatExecutor和cacheRefreshExecutor的execute完成的。其中heartbeatExecutor主要用于发送心跳，cacheRefreshExecutor主要用于同步信息。

<table style="border-collapse:collapse; border-spacing:0px; margin:0px; width:auto; border:none; font-size:14px; table-layout:fixed"> 
 <tbody> 
  <tr style="background-color:rgb(249,249,249)"> 
   <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px 20px 1px 1px; color:rgb(102,102,102); background:rgb(247,247,247); line-height:1.6; border:none; text-align:right">
      
       
     <div style="height:20px">
      
        
       1
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       2
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       3
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       4
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       5
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       6
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       7
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       8
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       9
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       10
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       11
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       12
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       13
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       14
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       15
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       16
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       17
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       18
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       19
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       20
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       21
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       22
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       23
      
       
     </div></pre> </td> 
   <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px; color:rgb(77,77,76); background:rgb(247,247,247); line-height:1.6; border:none">
      
       
     <div style="height:20px">
      
        
       scheduler = Executors.newScheduledThreadPool(
       
        
      <span style="color:rgb(113,140,0)">3</span>,
      
       
     </div>
      
       
     <div style="height:20px">                    
       
        
      <span style="color:rgb(137,89,168)">new</span> ThreadFactoryBuilder()
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                                   .setNameFormat(
       
        
      <span style="color:rgb(113,140,0)">"DiscoveryClient-%d"</span>)
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                                   .setDaemon(
       
        
      <span style="color:rgb(137,89,168)">true</span>)
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                                   .build());
      
       
     </div>
      
       
     <div style="height:20px"></div>
      
       
     <div style="height:20px">
      
        
                   heartbeatExecutor = 
       
        
      <span style="color:rgb(137,89,168)">new</span> ThreadPoolExecutor(
      
       
     </div>
      
       
     <div style="height:20px">                    
       
        
      <span style="color:rgb(113,140,0)">1</span>, clientConfig.getHeartbeatExecutorThreadPoolSize(), 
       
        
      <span style="color:rgb(113,140,0)">0</span>, TimeUnit.SECONDS,
      
       
     </div>
      
       
     <div style="height:20px">                    
       
        
      <span style="color:rgb(137,89,168)">new</span> SynchronousQueue&lt;Runnable&gt;(),
      
       
     </div>
      
       
     <div style="height:20px">                    
       
        
      <span style="color:rgb(137,89,168)">new</span> ThreadFactoryBuilder()
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                                   .setNameFormat(
       
        
      <span style="color:rgb(113,140,0)">"DiscoveryClient-HeartbeatExecutor-%d"</span>)
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                                   .setDaemon(
       
        
      <span style="color:rgb(137,89,168)">true</span>)
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                                   .build()
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                   );  
       
        
      <span style="color:rgb(142,144,140)">// use direct handoff</span>
      
       
     </div>
      
       
     <div style="height:20px"></div>
      
       
     <div style="height:20px">
      
        
                   cacheRefreshExecutor = 
       
        
      <span style="color:rgb(137,89,168)">new</span> ThreadPoolExecutor(
      
       
     </div>
      
       
     <div style="height:20px">                    
       
        
      <span style="color:rgb(113,140,0)">1</span>, clientConfig.getCacheRefreshExecutorThreadPoolSize(), 
       
        
      <span style="color:rgb(113,140,0)">0</span>, TimeUnit.SECONDS,
      
       
     </div>
      
       
     <div style="height:20px">                    
       
        
      <span style="color:rgb(137,89,168)">new</span> SynchronousQueue&lt;Runnable&gt;(),
      
       
     </div>
      
       
     <div style="height:20px">                    
       
        
      <span style="color:rgb(137,89,168)">new</span> ThreadFactoryBuilder()
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                                   .setNameFormat(
       
        
      <span style="color:rgb(113,140,0)">"DiscoveryClient-CacheRefreshExecutor-%d"</span>)
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                                   .setDaemon(
       
        
      <span style="color:rgb(137,89,168)">true</span>)
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                                   .build()
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                   );  
       
        
      <span style="color:rgb(142,144,140)">// use direct handoff</span>
      
       
     </div></pre> </td> 
  </tr> 
 </tbody> 
</table>

#### scheduleServerEndpointTask(eurekaTransport, args); ####

该方法中创建了两个EurekaHttpClient, newRegistrationClient和newQueryClient。EurekaHttpClient是用来与Eureka Server进行通信的Eureka Client的实现。

*  newRegistrationClient：生成时是通过装饰模式层层包装的，`SessionedEurekaHttpClient-> RetryableEurekaHttpClient-> RedirectingEurekaHttpClient`, RedirectingEurekaHttpClient中通过EurekaJerseyClientImpl发送HTTP请求。
 *  newQueryClient：与newRegistrationClient情况类似

#### fetchRegistry(false) ####

`getAndStoreFullRegistry();`： 从Eureka server获取所有的已注册的instance， 经过层层装饰，最终会调用RetryableEurekaHttpClient的execute方法，然后会调用JerseyApplicationClient的getApplications方法，请求“[http://localhost:8080/eureka/v2/apps/”][http_localhost_8080_eureka_v2_apps], 如果server还没有启动，则会抛出异常。随后就会调用`fetchRegistryFromBackup();`, 调用apps = backupRegistryInstance.fetchRegistry(); backupRegistryInstance是com.netflix.discovery.NotImplementedRegistryImpl，fetchRegistry()直接返回null。如果获取到了apps，则保存在`localRegionApps`中。

#### fetchRegistryFromBackup() ####

如果fetchRegistry没有获取到结果，返回false，则会继续调用fetchRegistryFromBackup()，实际上目前没有实现。

### initScheduledTasks(); ###

*  定时执行CacheRefreshThread，用来刷新注册表信息，调用流程与上面的fetchRegistry一致。
    
    <table style="border-collapse:collapse; border-spacing:0px; margin:0px; width:auto; border:none; font-size:14px; table-layout:fixed"> 
     <tbody> 
      <tr style="background-color:rgb(249,249,249)"> 
       <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px 20px 1px 1px; color:rgb(102,102,102); background:rgb(247,247,247); line-height:1.6; border:none; text-align:right">
            
             
         <div style="height:20px">
          
              
             1
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             2
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             3
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             4
            
             
         </div>
            
             
         <div style="height:20px">
          
              
             5
            
             
         </div></pre> </td> 
       <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px; color:rgb(77,77,76); background:rgb(247,247,247); line-height:1.6; border:none">
            
             
         <div style="height:20px">
             
              
          <span><span style="color:rgb(137,89,168)">class</span> <span style="color:rgb(62,153,159)">CacheRefreshThread</span> <span style="color:rgb(137,89,168)">implements</span> <span style="color:rgb(62,153,159)">Runnable</span> </span>{
            
             
         </div>
            
             
         <div style="height:20px">       
             
              
          <span style="color:rgb(66,113,174)"><span style="color:rgb(137,89,168)">public</span> <span style="color:rgb(137,89,168)">void</span> <span style="color:rgb(62,153,159)">run</span><span style="color:rgb(245,135,31)">()</span> </span>{
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                        refreshRegistry();
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                    }
            
             
         </div>
            
             
         <div style="height:20px">
          
              
                }
            
             
         </div></pre> </td> 
      </tr> 
     </tbody> 
    </table>

在refreshRegistry()中调用了fetchRegistry方法。

*  定时执行HeartbeatThread，用来发送心跳。调用renew方法，调用AbstractJerseyEurekaHttpClient的sendHeartBeat方法，urlPath是apps/EUREKA/WQ.local（PUT /eureka/v2/apps/appID/instanceID）， serviceUrl仍然是[http://localhost:8080/eureka/v2/。当server未启动时，提示“unable][http_localhost_8080_eureka_v2_server_unable] to send heartbeat!”

InstanceInfoReplicator：当当前实例发生变化时，把本地的信息复制到远程Server. 调用InstanceInfoReplicator的start方法。 Future next = scheduler.schedule(this, initialDelayMs, TimeUnit.SECONDS); 调用run()方法。

<table style="border-collapse:collapse; border-spacing:0px; margin:0px; width:auto; border:none; font-size:14px; table-layout:fixed"> 
 <tbody> 
  <tr style="background-color:rgb(249,249,249)"> 
   <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px 20px 1px 1px; color:rgb(102,102,102); background:rgb(247,247,247); line-height:1.6; border:none; text-align:right">
      
       
     <div style="height:20px">
      
        
       1
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       2
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       3
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       4
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       5
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       6
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       7
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       8
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       9
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       10
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       11
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       12
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       13
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       14
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       15
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       16
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       17
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       18
      
       
     </div></pre> </td> 
   <td style="padding:0px; vertical-align:middle; border:none"> <pre style="overflow:auto; font-family:consolas,Menlo,&quot;PingFang SC&quot;,&quot;Microsoft YaHei&quot;,monospace; font-size:13px; margin-top:0px; margin-bottom:0px; padding:1px; color:rgb(77,77,76); background:rgb(247,247,247); line-height:1.6; border:none">
      
       
     <div style="height:20px">
       
        
      <span style="color:rgb(66,113,174)"><span style="color:rgb(137,89,168)">public</span> <span style="color:rgb(137,89,168)">void</span> <span style="color:rgb(62,153,159)">run</span><span style="color:rgb(245,135,31)">()</span> </span>{
      
       
     </div>
      
       
     <div style="height:20px">    
       
        
      <span style="color:rgb(137,89,168)">try</span> {
      
       
     </div>
      
       
     <div style="height:20px">        
       
        
      <span style="color:rgb(142,144,140)">//刷新instance信息</span>
      
       
     </div>
      
       
     <div style="height:20px">
      
        
               discoveryClient.refreshInstanceInfo();
      
       
     </div>
      
       
     <div style="height:20px"></div>
      
       
     <div style="height:20px">
      
        
               Long dirtyTimestamp = instanceInfo.isDirtyWithTime();
      
       
     </div>
      
       
     <div style="height:20px">        
       
        
      <span style="color:rgb(137,89,168)">if</span> (dirtyTimestamp != 
       
        
      <span style="color:rgb(137,89,168)">null</span>) {
      
       
     </div>
      
       
     <div style="height:20px">            
       
        
      <span style="color:rgb(142,144,140)">//重新注册</span>
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                   discoveryClient.register();
      
       
     </div>
      
       
     <div style="height:20px">
      
        
                   instanceInfo.unsetIsDirty(dirtyTimestamp);
      
       
     </div>
      
       
     <div style="height:20px">
      
        
               }
      
       
     </div>
      
       
     <div style="height:20px">
      
        
           } 
       
        
      <span style="color:rgb(137,89,168)">catch</span> (Throwable t) {
      
       
     </div>
      
       
     <div style="height:20px">
      
        
               logger.warn(
       
        
      <span style="color:rgb(113,140,0)">"There was a problem with the instance info replicator"</span>, t);
      
       
     </div>
      
       
     <div style="height:20px">
      
        
           } 
       
        
      <span style="color:rgb(137,89,168)">finally</span> {
      
       
     </div>
      
       
     <div style="height:20px">
      
        
               Future next = scheduler.schedule(
       
        
      <span style="color:rgb(137,89,168)">this</span>, replicationIntervalSeconds, TimeUnit.SECONDS);
      
       
     </div>
      
       
     <div style="height:20px">
      
        
               scheduledPeriodicRef.set(next);
      
       
     </div>
      
       
     <div style="height:20px">
      
        
           }
      
       
     </div>
      
       
     <div style="height:20px">
      
        
       }
      
       
     </div></pre> </td> 
  </tr> 
 </tbody> 
</table>

# 提供HTTP服务 #

上面的代码新建了EurekaHttpClient进行HTTP请求，但是服务端是如何实现的呢？秘密就在com.netflix包下的众多Resource中。具体的包是：com.netflix.eureka.resources。就是使用jersey的一堆http服务，没什么过多可说的。

# 总结 #

对应《微服务注册发现概述》中的服务发现所需要的功能，梳理一下Eureka是如何实现的：

<table style="border-collapse:collapse; border-spacing:0px; margin:20px 0px; width:619px; border:1px solid rgb(221,221,221); font-size:14px; table-layout:fixed"> 
 <thead> 
  <tr> 
   <th style="padding:8px 8px 10px; text-align:left; vertical-align:middle; border-bottom:3px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> 功能</th> 
   <th style="padding:8px 8px 10px; text-align:left; vertical-align:middle; border-bottom:3px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> Eureka实现</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr style="background-color:rgb(249,249,249)"> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> 数据如何存储</td> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> 内存</td> 
  </tr> 
  <tr> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> 如何提供注册服务</td> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> jersey实现的HTTP服务</td> 
  </tr> 
  <tr style="background-color:rgb(249,249,249)"> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> 如何提供查询服务</td> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> jersey实现的HTTP服务</td> 
  </tr> 
  <tr> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> Provider变化时，如何通知Consumer</td> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> CacheRefreshThread定时执行时会更新本地缓存</td> 
  </tr> 
  <tr style="background-color:rgb(249,249,249)"> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> 服务注册表的节点之间如何进行信息的同步和复制</td> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> 每个Eureka Server同时也会启动一个Eureka Client，由Eureka Client负责复制和同步信息</td> 
  </tr> 
  <tr> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> 当所有的服务注册表节点都Down掉后重新启动，如何重新获取注册信息</td> 
   <td style="padding:8px; vertical-align:middle; border-bottom:1px solid rgb(221,221,221); border-right:1px solid rgb(238,238,238)"> Eureka Client重新连接</td> 
  </tr> 
 </tbody> 
</table>

[API]: https://github.com/Netflix/eureka/wiki/Eureka-REST-operations
[http_localhost_8080_eureka_v2_apps]: http://localhost:8080/eureka/v2/apps/%E2%80%9D
[http_localhost_8080_eureka_v2_server_unable]: http://localhost:8080/eureka/v2/%E3%80%82%E5%BD%93server%E6%9C%AA%E5%90%AF%E5%8A%A8%E6%97%B6%EF%BC%8C%E6%8F%90%E7%A4%BA%E2%80%9Cunable