EurekaServer自动装配及启动流程解析

在开始本篇文章之前，我想你对SpringCloud和SpringBoot的基本使用已经比较熟悉了，如果不熟悉的话可以参考我之前写过的文章
本篇文章的源码基于SpringBoot2.0,SpringCloud的Finchley.RELEASE

@EnableEurekaServer注解

我们知道，在使用Eureka作为注册中心的时候，我们会在启动类中增加一个@EnableEurekaServer注解，这个注解我们是一个自定义的EnableXXX系列的注解，主要作用我们之前也多次提到了，就是引入配置类而已。看一下源码吧

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import({EurekaServerMarkerConfiguration.class})
public @interface EnableEurekaServer {
}

引入了一个配置类EurekaServerMarkerConfiguration，看一下这个类的具体内容

@Configuration
public class EurekaServerMarkerConfiguration {

    @Bean
    public Marker eurekaServerMarkerBean() {
        return new Marker();
    }

    class Marker {
    }
}

现在看这里好像难以理解，这是啥意思，搞个空的类干啥的，不要着急，接着往下看

自动装配

既然注解上没有找到我们想要的东西，那么就看一下spring.factories文件吧，这里自动配置的实现类是EurekaServerAutoConfiguration

由于这个类涉及的代码实在是太多了，这里就不贴了，咱们直接来解析这个类：

1. 引入EurekaServerInitializerConfiguration类

看名字就知道了这个类是负责Eureka的初始化工作的，这个类实现了SmartLifecycle接口，所以在spring初始化和销毁的时候，就会分别调用它的start和stop方法

首先看一下start方法

public void start() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    //启动EurekaServer
eurekaServerBootstrap.contextInitialized(EurekaServerInitializerConfiguration.this.servletContext);
                    log.info("Started Eureka Server");

                    publish(new EurekaRegistryAvailableEvent(getEurekaServerConfig()));
                    EurekaServerInitializerConfiguration.this.running = true;
                    publish(new EurekaServerStartedEvent(getEurekaServerConfig()));
                }
                catch (Exception ex) {
                    // Help!
                    log.error("Could not initialize Eureka servlet context", ex);
                }
            }
        }).start();
    }

这个代码好像比较直接了当啊，直接就起个线程启动了EurekaServer，然后发布了一些启动事件，来看启动的过程吧


public void contextInitialized(ServletContext context) {
                try {
            //初始化执行环境
                        initEurekaEnvironment();
            //初始化上下文
                        initEurekaServerContext();

                        context.setAttribute(EurekaServerContext.class.getName(), this.serverContext);
                }
                catch (Throwable e) {
                        log.error("Cannot bootstrap eureka server :", e);
                        throw new RuntimeException("Cannot bootstrap eureka server :", e);
                }
        }

这里一共包含初始化环境和初始化上下文两个分支

初始化执行环境

这个不是很重要，可以过滤掉


protected void initEurekaEnvironment() throws Exception {
                log.info("Setting the eureka configuration..");
               //AWS相关的东西，可以忽略
                String dataCenter = ConfigurationManager.getConfigInstance()
                                .getString(EUREKA_DATACENTER);
                if (dataCenter == null) {
                        log.info(
                                        "Eureka data center value eureka.datacenter is not set, defaulting to default");
                        ConfigurationManager.getConfigInstance()
                                        .setProperty(ARCHAIUS_DEPLOYMENT_DATACENTER, DEFAULT);
                }
                else {
                        ConfigurationManager.getConfigInstance()
                                        .setProperty(ARCHAIUS_DEPLOYMENT_DATACENTER, dataCenter);
                }
        //设置 Eureka 环境，默认为test
                String environment = ConfigurationManager.getConfigInstance()
                                .getString(EUREKA_ENVIRONMENT);
                if (environment == null) {
                        ConfigurationManager.getConfigInstance()
                                        .setProperty(ARCHAIUS_DEPLOYMENT_ENVIRONMENT, TEST);
                        log.info(
                                        "Eureka environment value eureka.environment is not set, defaulting to test");
                }
                else {
                        ConfigurationManager.getConfigInstance()
                                        .setProperty(ARCHAIUS_DEPLOYMENT_ENVIRONMENT, environment);
                }
        }
初始化上下文

protected void initEurekaServerContext() throws Exception {
                // 设置json与xml序列化工具
                JsonXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(),
                                XStream.PRIORITY_VERY_HIGH);
                XmlXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(),
                                XStream.PRIORITY_VERY_HIGH);

                if (isAws(this.applicationInfoManager.getInfo())) {
                        this.awsBinder = new AwsBinderDelegate(this.eurekaServerConfig,
                                        this.eurekaClientConfig, this.registry, this.applicationInfoManager);
                        this.awsBinder.start();
                }

                EurekaServerContextHolder.initialize(this.serverContext);

                log.info("Initialized server context");

                // 同步Eureka集群数据
                int registryCount = this.registry.syncUp();
                this.registry.openForTraffic(this.applicationInfoManager, registryCount);

                // 注册监控统计信息
                EurekaMonitors.registerAllStats();
        }

这个方法中同步集群数据和注册监控信息都涉及的内容比较多，所以本篇文章就不再展开了，请关注我留意后续文章

@ConditionalOnBean({Marker.class})

看到这里就揭开了开篇@EnableEurekaServer注解注入的那个bean的含义了。也就是说如果咱们的启动类没有使用@EnableEurekaServer注解的话，这个自动配置类就不会执行，那也就没有Eureka的事了

@EnableConfigurationProperties({EurekaDashboardProperties.class, InstanceRegistryProperties.class})

深入这个注解发现这个还是使用的@Import注解的机制引入了两个类，这个注解在之前的源码解析文章中也多次提到了，这里就不展开了

EurekaDashboardProperties这个类比较简单，主要是Eureka的控制台的相关配置

//控制台默认路径
private String path = "/";
//是否开启控制台
private boolean enabled = true;

InstanceRegistryProperties，这个类是控制Eureka的注册时的配置信息

    //每分钟续约次数
    @Value("${eureka.server.expectedNumberOfRenewsPerMin:1}")
    private int expectedNumberOfRenewsPerMin = 1;
    //默认打开的通信数量
    @Value("${eureka.server.defaultOpenForTrafficCount:1}")
    private int defaultOpenForTrafficCount = 1;
@PropertySource("classpath:/eureka/server.properties")

相信大家比较熟悉这个注解，加载Eureka的配置文件而已

配置文件中也仅仅只包含这个信息

spring.http.encoding.force=false
自动注入的bean

EurekaServerAutoConfiguration类上几个注解就解析完了，接着看一下这个类中注入的几个比较重要的类吧

配置类EurekaServerConfigBeanConfiguration

EurekaServerConfig
如果当前应用允许注册到其他Eureka服务中时，也就是属性eureka.client.fetch-registry为true时。就设置属性registrySyncRetries的值为5，这个属性的意思是当Eureka服务器启动时尝试去获取集群里其他服务器上的注册信息的次数

EurekaController

这个就是Eureka自己的controller了，控制台的相关信息就是从这里获取的

ServerCodecs

设置Eureka的序列化工具

PeerAwareInstanceRegistry

集群注册信息同步相关的类，请期待后续深入解析文章

FilterRegistrationBean

EurekaServer接受请求的一个拦截器，感兴趣的同学可以研究一下

原文地址：https://www.cnblogs.com/zhixiang-org-cn/p/11657756.html

时间： 2024-11-09 09:36:34

EurekaServer自动装配及启动流程解析的相关文章

EurekaClient自动装配及启动流程解析

在上篇文章中,我们简单介绍了EurekaServer自动装配及启动流程解析,本篇文章则继续研究EurekaClient的相关代码 老规矩,先看spring.factories文件,其中引入了一个配置类EurekaDiscoveryClientConfigServiceBootstrapConfiguration @ConditionalOnClass(ConfigServicePropertySourceLocator.class) @ConditionalOnProperty(value =

Arm启动流程解析

谈到arm的启动流程不得不说的是bootloader,但是我这篇文章主要来谈谈arm启动流程的,所以bootloader只是跟大家简介一下就ok.这篇文章我会谈到以下内容: 1.bootloader简介以及其作用 2.2440.6410.210当下比较常见的3款处理器的启动流程进行简单分析,通过这三款处理器的分析希望大家掌握arm处理器的启动分析. Ok我们进入主题 l  Bootloader简介及其作用 在我看来bootloader的作用是初始化必要的硬件,引导内核启动.(当然这是主要作用,今

Nginx（一）：启动流程解析

nginx作为高效的http服务器和反向代理服务器,值得我们深入了解. 我们带着几个问题,深入了解下nginx的工作原理.首先是开篇:nginx是如何启动的? nginx是用c写的软件,github地址: https://github.com/nginx/nginx 其目录结构如下,我们主要关注 src 目录下的文件. nginx.c 是main函数入口,我们也是通过这里进行启动流程分析的. 零.启动流程时序图 我们先通过一个时序图进行全局观察nginx是如何跑起来的,然后后续再稍微深入了解些细

“无处不在” 的系统核心服务 —— ActivityManagerService 启动流程解析

本文基于 Android 9.0 , 代码仓库地址 : android_9.0.0_r45 系列文章目录: Java 世界的盘古和女娲 -- Zygote Zygote 家的大儿子 -- SystemServer Android 世界中,谁喊醒了 Zygote ? 文中相关源码链接: SystemServer.java ActivityManagerService.java 之前介绍 SystemServer 启动流程 的时候说到,SystemServer 进程启动了一系列的系统服务,Activ

庖丁解牛 Activity 启动流程

前言 这是 Android 9.0 AOSP 系列 的第五篇了,先来回顾一下前面几篇的大致内容. Java 世界的盘古和女娲 -- Zygote 主要介绍了 Android 世界的第一个 Java 进程 Zygote 的启动过程. 注册服务端 socket,用于响应客户端请求 各种预加载操作,类,资源,共享库等 强制 GC 一次 fork SystemServer 进程 循环等待客户端发来的 socket 请求(请求 socket 连接和请求 fork 应用进程) Zygote家的大儿子 --

SpringBoot启动流程分析（五）：SpringBoot自动装配原理实现

SpringBoot系列文章简介 SpringBoot源码阅读辅助篇: Spring IoC容器与应用上下文的设计与实现 SpringBoot启动流程源码分析: SpringBoot启动流程分析(一):SpringApplication类初始化过程 SpringBoot启动流程分析(二):SpringApplication的run方法 SpringBoot启动流程分析(三):SpringApplication的run方法之prepareContext()方法 SpringBoot启动流程分析(四

跟跟Springboot启动容器，自动装配的过程

-----------------------------------------------------本文只作为跟代码的一个参考,建议可以根据思路在指定类中断点调试学习------------------------------------------------------------ 运行被@SpringBootApplication修饰的程序入口,执行main方法,调用SpringApplication的run方法. 下面是从创建controller层bean的方法调用链如下:(备注:

android源码解析之（十四）-->Activity启动流程

好吧,终于要开始讲解Activity的启动流程了,Activity的启动流程相对复杂一下,涉及到了Activity中的生命周期方法,涉及到了Android体系的CS模式,涉及到了Android中进程通讯Binder机制等等, 首先介绍一下Activity,这里引用一下Android guide中对Activity的介绍: An activity represents a single screen with a user interface. For example, an email appl

android源码解析之（八）-->Zygote进程启动流程

大家都知道android系统的Zygote进程是所有的android进程的父进程,包括SystemServer和各种应用进程都是通过Zygote进程fork出来的.Zygote(孵化)进程相当于是android系统的根进程,后面所有的进程都是通过这个进程fork出来的,而Zygote进程则是通过linux系统的init进程启动的,也就是说,android系统中各种进程的启动方式 init进程 –> Zygote进程 –> SystemServer进程 –>各种应用进程 init进程:li