SpringCloud组件 & 源码剖析：Eureka服务注册方式流程全面分析

时间  2019-12-19
标签 springcloud 组件 源码 剖析 eureka 服务 注册 方式 流程 全面 分析 繁體版
原文   原文链接

在SpringCloud组件：Eureka服务注册是采用主机名仍是IP地址？文章中咱们讲到了服务注册的几种注册方式，那么这几种注册方式的源码是怎么实现的呢？咱们带着这一个疑问来阅读本章内容可以让你更深刻了解这块的知识点！！！git

本章目标

分析每一种服务注册方式源码执行流程。github

构建项目

本章以分析源码为主，因此不去新建立项目来说解相关内容，咱们使用SpringCloud组件：Eureka服务注册是采用主机名仍是IP地址？源码做为注册服务，SpringCloud组件：搭建Eureka服务注册中心源码做为服务注册中心，仍是按照以前的运行流程：spring

  1. 启动服务注册中心
  2. 启动本章服务项目
  3. 查看服务列表，服务注册方式

配置信息获取执行流程

在开始讲解本章注册方式以前，咱们须要了解总体的配置信息获取的流程信息，这样才能够分析指定的注册方式执行流程。数据库

第一步：实例化EurekaInstanceConfigBean配置实体

在项目启动时因为依赖spring-cloud-starter-netflix-eureka-client内经过配置spring.factories文件来让项目启动时自动加载并实例化org.springframework.cloud.netflix.eureka.EurekaClientAutoConfiguration配置类，EurekaClientAutoConfiguration内会自动实例化EurekaInstanceConfigBean而且自动绑定eureka.instance开头的配置信息（具体为何会自动映射能够去了解下@ConfigurationProperties注解做用），部分源码以下所示：bash

......
public class EurekaClientAutoConfiguration {
    //省略部分源码
    @Bean
    @ConditionalOnMissingBean(value = EurekaInstanceConfig.class, search        = SearchStrategy.CURRENT)
    public EurekaInstanceConfigBean eurekaInstanceConfigBean(InetUtils inetUtils,													    ManagementMetadataProvider managementMetadataProvider) {
      //省略部分源码
      // 传递
      EurekaInstanceConfigBean instance = new EurekaInstanceConfigBean(inetUtils);
      // 省略部分源码
    }
    //省略部分源码
}
复制代码

EurekaClientAutoConfiguration#eurekaInstanceConfigBean方法只有知足@ConditionalOnMissingBean(value = EurekaInstanceConfig.class, search = SearchStrategy.CURRENT)表达式后才会去实例化，而且把实例化对象放入到IOC容器内容，BeanId为eurekaInstanceConfigBean，也就是方法的名称。 在EurekaClientAutoConfiguration#eurekaInstanceConfigBean方法中有这么一行代码咱们能够进行下一步的分析微信

// 经过有参构造函数实例化EurekaInstanceConfigBean配置实体
EurekaInstanceConfigBean instance = new EurekaInstanceConfigBean(inetUtils);
复制代码

经过调用EurekaInstanceConfigBean(InetUtils inetUtils)构造函数来进行实例化EurekaInstanceConfigBean对象，在这个构造函数内也有一些实例化的工做，源码以下：网络

public EurekaInstanceConfigBean(InetUtils inetUtils) {
    this.inetUtils = inetUtils;
    this.hostInfo = this.inetUtils.findFirstNonLoopbackHostInfo();
    this.ipAddress = this.hostInfo.getIpAddress();
    this.hostname = this.hostInfo.getHostname();
}
复制代码
第二步：InetUtils#findFirstNonLoopbackHostInfo获取主机基本信息

在构造函数EurekaInstanceConfigBean(InetUtils inetUtils)源码实现内hostInfo主机信息经过了InetUtils#findFirstNonLoopbackHostInfo方法来进行实例化，咱们来看看这个方法的具体实现逻辑，它会自动读取系统网卡列表然再进行循环遍历查询正在UP状态的网卡信息，若是没有查询到网卡信息，则使用默认的HostName、IpAddress配置信息，源码以下所示：mybatis

public HostInfo findFirstNonLoopbackHostInfo() {
    InetAddress address = findFirstNonLoopbackAddress();
    if (address != null) {
        return convertAddress(address);
    }
    HostInfo hostInfo = new HostInfo();
    hostInfo.setHostname(this.properties.getDefaultHostname());
    hostInfo.setIpAddress(this.properties.getDefaultIpAddress());
    return hostInfo;
}

public InetAddress findFirstNonLoopbackAddress() {
    InetAddress result = null;
    try {
        int lowest = Integer.MAX_VALUE;
        for (Enumeration<NetworkInterface> nics = NetworkInterface
                .getNetworkInterfaces(); nics.hasMoreElements();) {
            NetworkInterface ifc = nics.nextElement();
            if (ifc.isUp()) {
                log.trace("Testing interface: " + ifc.getDisplayName());
                if (ifc.getIndex() < lowest || result == null) {
                    lowest = ifc.getIndex();
                }
                else if (result != null) {
                    continue;
                }

                // @formatter:off
                if (!ignoreInterface(ifc.getDisplayName())) {
                    for (Enumeration<InetAddress> addrs = ifc
                            .getInetAddresses(); addrs.hasMoreElements();) {
                        InetAddress address = addrs.nextElement();
                        if (address instanceof Inet4Address
                                && !address.isLoopbackAddress()
                                && isPreferredAddress(address)) {
                            log.trace("Found non-loopback interface: "
                                    + ifc.getDisplayName());
                            result = address;
                        }
                    }
                }
                // @formatter:on
            }
        }
    }
    catch (IOException ex) {
        log.error("Cannot get first non-loopback address", ex);
    }

    if (result != null) {
        return result;
    }

    try {
        return InetAddress.getLocalHost();
    }
    catch (UnknownHostException e) {
        log.warn("Unable to retrieve localhost");
    }

    return null;
}
复制代码

默认的HostName、IpAddress属性配置信息在InetUtilsProperties配置实体类内，若是不进行设置则直接使用默认值，若是你想更换默认值，那么你能够在application.yml配置文件内经过设置spring.cloud.inetutils.defaultHostname、spring.cloud.inetutils.defaultIpAddress进行修改默认值，源码以下所示：app

public class InetUtilsProperties {
	public static final String PREFIX = "spring.cloud.inetutils";

	/**
	 * The default hostname. Used in case of errors.
	 */
	private String defaultHostname = "localhost";

	/**
	 * The default ipaddress. Used in case of errors.
	 */
	private String defaultIpAddress = "127.0.0.1";
}
复制代码
第三步：EurekaInstanceConfigBean#getHostName方法实现

getHostName是一个Override的方法，继承于com.netflix.appinfo.EurekaInstanceConfig接口，该方法有个boolean类型的参数refresh来判断是否须要刷新从新获取主机网络基本信息，当传递refresh=false而且在application.yml配置文件内并无进行手动设置eureka.instance.hostname以及eureka.instance.ip-address参数则会根据eureka.instance.prefer-ip-address设置的值进行返回信息，源码以下所示：框架

@Override
public String getHostName(boolean refresh) {
    if (refresh && !this.hostInfo.override) {
        this.ipAddress = this.hostInfo.getIpAddress();
        this.hostname = this.hostInfo.getHostname();
    }
    return this.preferIpAddress ? this.ipAddress : this.hostname;
}
复制代码

默认注册方式源码分析

因为在实例化EurekaInstanceConfigBean配置实体类时，构造函数进行了获取第一个非回环主机信息，默认的hostName以及ipAddress参数则是会直接使用InetUtils#findFirstNonLoopbackHostInfo方法返回的相对应的值。

IP优先注册方式源码分析

EurekaInstanceConfigBean#getHostName方法直接调用本类重载方法getHostName(boolean refresh)而且传递参数为false，根据第三步源码咱们就能够看到：

return this.preferIpAddress ? this.ipAddress : this.hostname;
复制代码

若是eureka.instance.prefer-ip-address参数设置了true就会返回eureka.instance.ip-address的值，这样咱们就能够从中明白为何主动设置eureka.instance.ip-address参数后须要同时设置eureka.instance.prefer-ip-address参数才能够生效。

指定IP、HostName源码分析

咱们经过application.yml配置文件进行设置eureka.instance.hostname以及eureka.instance.ip-address后会直接替换原默认值，在EurekaInstanceConfigBean#getHostName中也是返回的this.hostname、this.ipAddress因此在这里设置后会直接生效做为返回的配置值。

总结

咱们经过源码进行分析服务注册方式执行流程，这样在之后进行配置eureka.instance.hostname、eureka.instance.prefer.ip-address、eureka.instance.ip-address三个配置信息时就能够根据优先级顺序达到预期的效果，避免没有必要的错误出现。

源码位置

有问题要问？

若是你有技术相关的问题想要咨询恒宇少年，请去博客首页左侧导航栏，点击知识星球微信扫码加入个人星球。

与恒宇少年面对面

若是你喜欢恒宇少年的相关文章，那么就去微信公众号（恒宇少年）关注我吧！！！ 固然你也能够去 SpringCloud码云源码 项目底部扫描微信公众号二维码关注我，感谢阅读！！！

学习目录推荐

开源信息

这段时间一直在编写开源的相关框架，致力于公司使用的框架升级以及开源计划，将公司使用到的工具以及插件进行升级重构而且开源。

  • 代码生成器（Code-Builder） code-builder代码生成器根据你提供的模板文件（目前支持freemarker）自动生成实体类，能够很大颇有效的提升开发效率。 Gitee地址：gitee.com/hengboy/cod… Github地址：github.com/hengyuboy/c…
  • 持久化框架（MyBatis-Enhance） mybatis-enhance是一个对mybatis框架的加强封装，提供一系列的内部方法来完成单表数据的操做，多表数据提供DSL方式进行操做。 Gitee地址：gitee.com/hengboy/myb… Github地址：github.com/hengyuboy/m…
  • 自动分页插件 MyBatis-Pageable是一款自动化分页的插件，基于MyBatis内部的插件Interceptor拦截器编写完成，拦截Executor.query的两个重载方法计算出分页的信息以及根据配置的数据库Dialect自动执行不一样的查询语句完成总数量的统计。 Gitee地址：gitee.com/hengboy/myb…
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程