Eureka Server源码解析（增量拉取注册表）

港控/mmm° 2022-09-09 04:48 217阅读 0赞

> 原创不易，转载请注明出处

# 系列文章目录 #

1.  《[SpringCloud Eureka Server源码解析（启动流程）][SpringCloud Eureka Server]》
2.  《[Eureka Server源码解析（服务注册流程）][Eureka Server]》
3.  《[Eureka Server源码解析（服务续约流程）][Eureka Server 1]》
4.  《[Eureka Server源码解析（服务主动下线流程）][Eureka Server 2]》
5.  《[Eureka Server源码解析（服务故障下线剔除流程）][Eureka Server 3]》
6.  《[Eureka Server源码解析（全量拉取注册表流程）][Eureka Server 4]》
7.  《[深度解析Eureka的自我保护机制][Eureka]》

### 文章目录 ###

*  系列文章目录
 *  前言
 *  1.源码解析
 *  2.流程图
 *  总结

--------------------

# 前言 #

在《[Eureka Server源码解析（全量拉取注册表流程）][Eureka Server 4]》我们介绍了Eureka 客户端启动初始化的时候，获取去Eureka Server拉取一次全量的注册表信息，在Eureka 客户端启动初始化的时候还会创建一个定时任务，默认是30s执行一次，然后去Eureka Server端拉取一次增量注册表信息。本文基于《[Eureka Server源码解析（全量拉取注册表流程）][Eureka Server 4]》，对于Eureka Server 的三级缓存我们不再过多的赘述。

# 1.源码解析 #

Eureka 客户端发送get请求apps/delta uri 获取增量注册表信息。  
是由EurekaServer ApplicationsResource 的getContainerDifferential方法处理的。

Key cacheKey = new Key(Key.EntityType.Application,
            ResponseCacheImpl.ALL_APPS_DELTA,
            keyType, CurrentRequestVersion.get(), EurekaAccept.fromString(eurekaAccept), regions
    );
    final Response response= Response.ok(responseCache.getGZIP(cacheKey))
                .header(HEADER_CONTENT_ENCODING, HEADER_GZIP_VALUE)
                .header(HEADER_CONTENT_TYPE, returnMediaType)
                .build();

首先是先创建缓存key，注意是ALL\_APPS\_DELTA ，之后就是调用responseCache.getGZIP(cacheKey) 方法来获取对应的缓存信息了。

public byte[] getGZIP(Key key) { 
       Value payload = getValue(key, shouldUseReadOnlyResponseCache);
       if (payload == null) { 
           return null;
       }
       return payload.getGzipped();
    }

先是调用getValue 方法获取对应value ，如果value不是null的话，获取对应编码后的数据返回，这里我们重点看下getValue 方法。

Value getValue(final Key key, boolean useReadOnlyCache) { 
            Value payload = null;
            try { 
                if (useReadOnlyCache) { 
                    final Value currentPayload = readOnlyCacheMap.get(key);
                    if (currentPayload != null) { 
                        payload = currentPayload;
                    } else { 
                        payload = readWriteCacheMap.get(key);
                        readOnlyCacheMap.put(key, payload);
                    }
                } else { 
                    payload = readWriteCacheMap.get(key);
                }
            } catch (Throwable t) { 
                logger.error("Cannot get value for key : {}", key, t);
            }
            return payload;
        }

先是去一级缓存readOnly中获取，如果没有的话，就去二级缓存ReadWrite 缓存中获取，获取到后将数据缓存到一级缓存readOnly里面去。  
这个ReadWrite 是guava提供的一个本地缓存工具，并且创建的时候指定了CacheLoader对象，如果这个 ReadWrite 中也没有对应key的缓存的话，就会调用CacheLoader 的load方法进行自动加载。并将加载后的数据缓存到ReadWrite 二级缓存中。  
这里看下CacheLoader 的load方法。

new CacheLoader<Key, Value>() { 
        @Override
        public Value load(Key key) throws Exception { 
            if (key.hasRegions()) { 
                Key cloneWithNoRegions = key.cloneWithoutRegions();
                regionSpecificKeys.put(cloneWithNoRegions, key);
            }
            Value value = generatePayload(key);
            return value;
        }
    }

调用generatePayload 方法获取key对应的value。  
由于generatePayload 方法体比较长，我们只看下与之有关的核心代码。

payload = getPayLoad(key, registry.getApplicationDeltas());

先是调用注册表的 getApplicationDeltas()获取最近变更的实例信息集合，然后调用getPayLoad方法编码实例信息集合。这里我们重点看下getApplicationDeltas方法。  
方法比较长，主要分为2部分，1是遍历recentlyChangedQueue 队列（服务注册、续约、下线 的时候都会被塞到这最近改变队列中，这个队列只会保留最近三分钟的数据。）将recentlyChangedQueue 队列中的实例信息塞到一个集合中， 2是 获取全量注册表实例信息，生成一个hashcode，这个hashcode主要是带给Eureka 客户端，客户端收到响应后，先将最近变更是实例信息更新到自己的本地注册表中，然后对自己本地注册表实例信息生成一个hashcode ，与Eureka Server响应回来的那个hashcode做比较，如果一样的话，说明本地注册表与Eureka Server的一样，如果不一样的话，说明出现了差异，就会全量拉取一次注册表信息放到本地注册表中。

Applications apps = new Applications();
    write.lock();
    Iterator<RecentlyChangedItem> iter = this.recentlyChangedQueue.iterator();
    while (iter.hasNext()) { 
       Lease<InstanceInfo> lease = iter.next().getLeaseInfo();
       InstanceInfo instanceInfo = lease.getHolder();
       Application app = applicationInstancesMap.get(instanceInfo
               .getAppName());
       if (app == null) { 
           app = new Application(instanceInfo.getAppName());
           applicationInstancesMap.put(instanceInfo.getAppName(), app);
           apps.addApplication(app);
       }
       app.addInstance(new InstanceInfo(decorateInstanceInfo(lease)));
    }

这部分就是遍历最近变更队列recentlyChangedQueue里面的实例信息，将实例信息塞到Applications 集合中，还有一个要注意的点这里使用了写锁， 我们知道，服务注册、服务续约、服务下线都是使用的读锁，这里使用写锁就是为保证这一刻 注册表中的数据不发生变更。

Applications allApps = getApplications(!disableTransparentFallback);
    apps.setAppsHashCode(allApps.getReconcileHashCode());

这两行代码就是生成注册表全量信息的一个hash值，带回给Eureka 客户端使用。

# 2.流程图 #

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAJOeggeWHuuacquadpQ_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center]

# 总结 #

增量实例信息，主要是从最近变更队列中获取实例信息，这个队列只会保存最近3分钟变更的，再往后的会被一个定时任务给删除掉，还有一个点就是会对应注册表全量数据生成一个hash值，然后带回给Eureka 客户端，客户端更新完数据也会生成一个，进行比较，如果相同，说明客户端本地注册表数据与Eureka Server 的一样，如果不相等的话，说明不一样，就会重新全量拉取一次。

[SpringCloud Eureka Server]: https://blog.csdn.net/yuanshangshenghuo/article/details/119920341
[Eureka Server]: https://blog.csdn.net/yuanshangshenghuo/article/details/119931667
[Eureka Server 1]: https://blog.csdn.net/yuanshangshenghuo/article/details/119951880
[Eureka Server 2]: https://blog.csdn.net/yuanshangshenghuo/article/details/119960880
[Eureka Server 3]: https://blog.csdn.net/yuanshangshenghuo/article/details/119961592
[Eureka Server 4]: https://blog.csdn.net/yuanshangshenghuo/article/details/119972511
[Eureka]: https://inetyoung.blog.csdn.net/article/details/110131223
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAJOeggeWHuuacquadpQ_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center]: /images/20220829/2a41da8c97e94487a4ed75fc0aa03782.png