注册中心 Eureka 源码解析 —— Eureka-Client 初始化（二）之 EurekaClientConfig

栏目: Java · 发布时间: 6年前

内容简介：注册中心 Eureka 源码解析 —— Eureka-Client 初始化（二）之 EurekaClientConfig

摘要: 原创出处 http://www.iocoder.cn/Eureka/eureka-client-init-second/ 「芋道源码」欢迎转载，保留摘要，谢谢！

本文主要基于 Eureka 1.8.X 版本

注册中心 Eureka 源码解析 —— Eureka-Client 初始化（二）之 EurekaClientConfig

关注 微信公众号：【芋道源码】 有福利：

RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
您对于源码的疑问每条留言都将得到认真回复。 甚至不知道如何读源码也可以请教噢 。
新的源码解析文章实时收到通知。 每周更新一篇左右 。
认真的 源码交流微信群。

1. 概述

本文接《Eureka 源码解析 —— Eureka-Client 初始化（一）之 EurekaInstanceConfig》，主要分享 Eureka-Client 自身初始化的过程 的第二部分 —— EurekaClientConfig ，不包含 Eureka-Client 向 Eureka-Server 的注册过程( 后面会另外文章分享 )。

Eureka-Client 自身初始化过程中，涉及到主要对象如下图：

注册中心 Eureka 源码解析 —— Eureka-Client 初始化（二）之 EurekaClientConfig

创建 EurekaInstanceConfig对象
使用 EurekaInstanceConfig对象创建 InstanceInfo对象
使用 EurekaInstanceConfig对象 + InstanceInfo对象创建 ApplicationInfoManager对象
创建 EurekaClientConfig对象
使用 ApplicationInfoManager对象 + EurekaClientConfig对象创建 EurekaClient对象

考虑到整个初始化的过程中涉及的配置特别多，拆分成三篇文章：

（一）EurekaInstanceConfig)
【本文】 （二）EurekaClientConfig
（三）EurekaClient

下面我们来看看每个类的实现。

2. EurekaClientConfig

com.netflix.discovery.EurekaClientConfig ， Eureka-Client 配置接口。

2.1 类关系图

EurekaClientConfig 整体类关系如下图：

注册中心 Eureka 源码解析 —— Eureka-Client 初始化（二）之 EurekaClientConfig

本文只解析红圈部分类。
EurekaArchaius2ClientConfig 基于 Netflix Archaius 2.x 实现，目前还在开发中，因此暂不解析。

2.2 配置属性

点击 EurekaClientConfig 查看配置属性简介，已经添加中文注释，可以对照着英文注释一起理解。这里笔者摘出部分较为重要的属性：

Region、Zone 相关

#getRegion() ：Eureka-Client 所在区域( region )。

#getAvailabilityZones() ：Eureka-Client 所在地区( region ) 可用区( zone )集合。 该参数虽然是数组，第一个元素代表其所在的可用区 。实现代码如下：

// InstanceInfo.java
public static String getZone(String[] availZones, InstanceInfo myInfo){
 String instanceZone = ((availZones == null || availZones.length == 0) ? "default"
 : availZones[0]);
 if (myInfo != null
 && myInfo.getDataCenterInfo().getName() == DataCenterInfo.Name.Amazon) {
 
 String awsInstanceZone = ((AmazonInfo) myInfo.getDataCenterInfo())
 .get(AmazonInfo.MetaDataKey.availabilityZone);
 if (awsInstanceZone != null) {
 instanceZone = awsInstanceZone;
 }
 
 }
 return instanceZone;
}

进步一步理解 Region、Zone 查看《周立 —— Region、Zone解析》。

使用 DNS 获取 Eureka-Server URL 相关
- #shouldUseDnsForFetchingServiceUrls() ：是否使用 DNS 方式获取 Eureka-Server URL 地址。
- #getEurekaServerDNSName() ：Eureka-Server 的 DNS 名。
- #getEurekaServerPort() ：Eureka-Server 的端口。
- #getEurekaServerURLContext() ：Eureka-Server 的 URL Context 。
- #getEurekaServiceUrlPollIntervalSeconds() ：轮询获取 Eureka-Server 地址变更频率，单位：秒。默认：300 秒。
- #shouldPreferSameZoneEureka() ：优先使用相同区( zone )的 Eureka-Server。
直接配合 Eureka-Server URL 相关
- #getEurekaServerServiceUrls() ： Eureka-Server 的 URL 集合。
发现：从 Eureka-Server 获取注册信息相关
- #shouldFetchRegistry() ：是否从 Eureka-Server 拉取注册信息。
- #getRegistryFetchIntervalSeconds() ：从 Eureka-Server 拉取注册信息频率，单位：秒。默认：30 秒。
- #shouldFilterOnlyUpInstances() ：是否过滤，只获取状态为开启( Up )的应用实例集合。
- #fetchRegistryForRemoteRegions() ：TODO[0009]：RemoteRegionRegistry
- #getCacheRefreshExecutorThreadPoolSize() ：注册信息缓存刷新线程池大小。
- #getCacheRefreshExecutorExponentialBackOffBound() ：注册信息缓存刷新执行超时后的延迟重试的时间。
- #getRegistryRefreshSingleVipAddress() ：只获得一个 vipAddress 对应的应用实例们的注册信息。
  - 实现逻辑和《Eureka 源码解析 —— 应用实例注册发现（六）之全量获取》
  - 本系列暂时写对它的源码解析，感兴趣的同学可以看 com.netflix.discovery.shared.transport.EurekaHttpClient#getVip(String, String...) 和 com.netflix.eureka.resources.AbstractVIPResource 。
注册：向 Eureka-Server 注册自身服务
- #shouldRegisterWithEureka() ：是否向 Eureka-Server 注册自身服务。
- #shouldUnregisterOnShutdown() ：是否向 Eureka-Server 取消注册自身服务，当进程关闭时。
- #getInstanceInfoReplicationIntervalSeconds() ：向 Eureka-Server 同步应用实例信息变化频率，单位：秒。
- #getInitialInstanceInfoReplicationIntervalSeconds() ：向 Eureka-Server 同步应用信息变化初始化延迟，单位：秒。
- #getBackupRegistryImpl() ：获取备份注册中心实现类。当 Eureka-Client 启动时，无法从 Eureka-Server 读取注册信息（可能挂了），从备份注册中心读取注册信息。目前 Eureka-Client 未提供合适的实现。
- #getHeartbeatExecutorThreadPoolSize() ：心跳执行线程池大小。
- #getHeartbeatExecutorExponentialBackOffBound() ：心跳执行超时后的延迟重试的时间。

2.3 DefaultEurekaClientConfig

com.netflix.discovery.DefaultEurekaClientConfig ，基于 配置文件 的 Eureka-Client 配置 实现类 ，实现代码如下：

public class DefaultEurekaClientConfig implements EurekaClientConfig{

 public static final String DEFAULT_ZONE = "defaultZone";

 /**
* 命名空间
*/
 private final String namespace;
 /**
* 配置文件对象
*/
 private final DynamicPropertyFactory configInstance;
 /**
* HTTP 传输配置
*/
 private final EurekaTransportConfig transportConfig;

 public DefaultEurekaClientConfig(String namespace){
 // 设置 namespace，为 "." 结尾
 this.namespace = namespace.endsWith(".")
 ? namespace
 : namespace + ".";
 // 初始化 配置文件对象
 this.configInstance = Archaius1Utils.initConfig(CommonConstants.CONFIG_FILE_NAME);
 // 创建 HTTP 传输配置
 this.transportConfig = new DefaultEurekaTransportConfig(namespace, configInstance);
 }
}

类似 PropertiesInstanceConfig，点击《Eureka 源码解析 —— Eureka-Client 初始化（一）之 EurekaInstanceConfig》「2.4 PropertiesInstanceConfig」查看详细解析。
在 com.netflix.discovery.PropertyBasedClientConfigConstants 可以看到配置文件的每个属性 KEY 。
transportConfig 属性，在「3. EurekaTransportConfig」详细解析。

2.4 DefaultEurekaClientConfigProvider

com.netflix.discovery.providers.DefaultEurekaClientConfigProvider ，创建 DefaultEurekaClientConfig 的工厂，实现代码如下：

public class DefaultEurekaClientConfigProvider implements Provider<EurekaClientConfig>{

 @Inject(optional = true)
 @EurekaNamespace
 private String namespace;

 private DefaultEurekaClientConfig config;
 
 @Override
 public synchronized EurekaClientConfig get(){
 if (config == null) {
 config = (namespace == null)
 ? new DefaultEurekaClientConfig()
 : new DefaultEurekaClientConfig(namespace);
 
 // TODO: Remove this when DiscoveryManager is finally no longer used
 DiscoveryManager.getInstance().setEurekaClientConfig(config);
 }

 return config;
 }
}

2.5 小结

推荐参考阅读：

程序猿DD —— 《Spring Cloud微服务实战》 Spring Cloud Eureka —— 配置详解
风中程序猿 —— 《微服务架构：Eureka参数配置项详解》

3. EurekaTransportConfig

3.1 类关系图

EurekaTransportConfig 整体类关系如下图：

注册中心 Eureka 源码解析 —— Eureka-Client 初始化（二）之 EurekaClientConfig

本文只解析红圈部分类。
EurekaArchaius2TransportConfig 基于 Netflix Archaius 2.x 实现，目前还在开发中，因此暂不解析。

3.2 配置属性

点击 EurekaTransportConfig 查看配置属性简介，已经添加中文注释，可以对照着英文注释一起理解。这里笔者摘出部分较为重要的属性：

#getSessionedClientReconnectIntervalSeconds() ：EurekaHttpClient 会话周期性重连时间，单位：秒。在《Eureka 源码解析 —— 网络通信》「5.4 SessionedEurekaHttpClient」》有详细解析。
#getRetryableClientQuarantineRefreshPercentage() ：重试 EurekaHttpClient ，请求失败的 Eureka-Server 隔离集合占比 Eureka-Server 全量集合占比，超过该比例，进行清空。在《Eureka 源码解析 —— 网络通信》「5.3 RetryableEurekaHttpClient」》有详细解析。
异步 EndPoint 集群解析器 ：
- 在《Eureka 源码解析 —— EndPoint 与解析器》「3.6 AsyncResolver」》有详细解析。
- #getAsyncResolverRefreshIntervalMs() ：异步解析 EndPoint 集群频率，单位：毫秒。
- #getAsyncResolverWarmUpTimeoutMs() ：异步解析器预热解析 EndPoint 集群超时时间，单位：毫秒。
- #getAsyncExecutorThreadPoolSize() ：异步解析器线程池大小。
TODO[0028]：写入集群和读取集群。Eureka 2.x 兼容：
- #getApplicationsResolverDataStalenessThresholdSeconds()
- #applicationsResolverUseIp()
- #getWriteClusterVip()
- #getReadClusterVip()
- #getBootstrapResolverStrategy()
- #useBootstrapResolverForQuery()

3.3 DefaultEurekaTransportConfig

com.netflix.discovery.shared.transport.DefaultEurekaTransportConfig ，基于 配置文件 的 网络传输 配置 实现类 ，实现代码如下：

public class DefaultEurekaTransportConfig implements EurekaTransportConfig{

 private static final String SUB_NAMESPACE = TRANSPORT_CONFIG_SUB_NAMESPACE + ".";

 /**
* 命名空间
*/
 private final String namespace;
 /**
* 配置文件对象
*/
 private final DynamicPropertyFactory configInstance;

 public DefaultEurekaTransportConfig(String parentNamespace, DynamicPropertyFactory configInstance){
 // 命名空间
 this.namespace = parentNamespace == null
 ? SUB_NAMESPACE
 : (parentNamespace.endsWith(".")
 ? parentNamespace + SUB_NAMESPACE
 : parentNamespace + "." + SUB_NAMESPACE);
 // 配置文件对象
 this.configInstance = configInstance;
 }
}

类似 PropertiesInstanceConfig，点击《Eureka 源码解析 —— Eureka-Client 初始化（一）之 EurekaInstanceConfig》「2.4 PropertiesInstanceConfig」查看详细解析。
在 com.netflix.discovery.shared.transport.PropertyBasedTransportConfigConstants 可以看到配置文件的每个属性 KEY 。

666. 彩蛋

涉及到配置，内容初看起来会比较多，慢慢理解后，就会变得很“啰嗦”，请保持耐心。

胖友，分享一个朋友圈可好。

以上所述就是小编给大家介绍的《注册中心 Eureka 源码解析 —— Eureka-Client 初始化（二）之 EurekaClientConfig》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对码农网的支持！

查看所有标签

猜你喜欢:

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。

码农书籍

PHP高级开发技术与应用

曹铁群、孙一江、张永学 / 清华大学出版社 / 2002-5-1 / 32.00

作为一本介绍PHP高级开发技术的书籍，本书并不像一般介绍PHP语言的书籍那样讲述大量的语法规则，罗列大量的函数，而是着眼于PHP在Web中的实际应用，特别是PHP对最新技术的支持，比如WAP技术、XML技术等。本书涉及到的内容主要有：高级环境配置、高级语法和应用、正则表达式、面向对象技术、高级图像技术、用PHPLIB实现模板的处理、用PHPDoc实现文档的自动生成、PHP与组件技术、PH......一起来看看《PHP高级开发技术与应用》这本书的介绍吧!

码农工具

注册中心 Eureka 源码解析 —— Eureka-Client 初始化（二）之 EurekaClientConfig

本文主要基于 Eureka 1.8.X 版本

1. 概述

推荐 Spring Cloud 书籍：

2. EurekaClientConfig

2.1 类关系图

2.2 配置属性

Region、Zone 相关

2.3 DefaultEurekaClientConfig

2.4 DefaultEurekaClientConfigProvider

2.5 小结

3. EurekaTransportConfig

3.1 类关系图

3.2 配置属性

3.3 DefaultEurekaTransportConfig

666. 彩蛋

PHP高级开发技术与应用

JSON 在线解析

XML 在线格式化

html转js在线工具