天天看点

SpringCloud【源码分析】之EurakaServer

SpringCloud【源码分析】之EurakaServer

图片来源https://github.com/Netflix/eureka/wiki/Eureka-at-a-glance

从注解开始了解源码

SpringCloud【源码分析】之EurakaServer
SpringCloud【源码分析】之EurakaServer

继续跟进EurekaServerMarkerConfiguration.class 发现什么都没有做只是执行了一下marker()

SpringCloud【源码分析】之EurakaServer

@EnableEurekaServer 只是做了这点事情,那么猜测一定是在@SpringBootApplication 有相关操作,并且一定会有对marker()的处理 ,带着这些疑问我们继续看springbootApplication注解

SpringCloud【源码分析】之EurakaServer

关键在于@EnableAutoConfiguration

@EnableAutoConfiguration 自动配置。既然是自动配置 那么可以看下它都配置那些bean

最终继续跟进注解@import相关的class信息会找到AutoConfigurationImportSelector.class

这个类主要的功能是自动加载相关bean.

SpringCloud【源码分析】之EurakaServer

此方法就会看到加载的bean信息,我们本次需要关注EurekaServerAutoConfiguration就在其中,既然加载这个bean 就去看看这个bean都做些什么事情。

SpringCloud【源码分析】之EurakaServer

@ConditionalOnBean(Marker.class)  这个是表示只有在spring容器

里面含有Market这个实例的时候,才会加载当前这个Bean)也就是我们看到@EurekaServer注解里的做marker()调用,通知开启EurekaServer

SpringCloud【源码分析】之EurakaServer

关注EurekaServerAutoConfigutation.class 会发现都是注入一些相关的bean 其中有一个eurekaServerBootstrap的注入

SpringCloud【源码分析】之EurakaServer

继续跟进eurekaServerBootsrtap都提供了那些方法

SpringCloud【源码分析】之EurakaServer
SpringCloud【源码分析】之EurakaServer

// 初始化Eureka的环境变量

  initEurekaEnvironment();

  // 初始化Eureka的上下文

   initEurekaServerContext();

SpringCloud【源码分析】之EurakaServer

   // 从相邻的eureka节点复制清单 这个是集群处理同步通知

   int registryCount = this.registry.syncUp();

    // 开启一个定时任务 用于管理服务清单

   this.registry.openForTraffic(this.applicationInfoManager, registryCount);

继续跟进openfortraffic会找到PeerAwareInstanceRegistryImpl.class

SpringCloud【源码分析】之EurakaServer
SpringCloud【源码分析】之EurakaServer

 expectedNumberOfRenewsPerMin // 计算每分钟最大续约数

numberOfRenewsPerMinThreshold//每分钟最小续约数

发现调用postinit 这个方法主要是开启定时每60秒更新下清单类别 超时续约的剔除

SpringCloud【源码分析】之EurakaServer

这个定时就是一个timertask来执行的 EvictionTask---evict()方法

SpringCloud【源码分析】之EurakaServer
SpringCloud【源码分析】之EurakaServer

通过看evict方法 其实报存 服务清单列表的是一个map数据

private final ConcurrentHashMap<String, Map<String, Lease<InstanceInfo>>> registry = new ConcurrentHashMap();
           

key 存储服务的名字

value 存储元数据

我们知道 EurekaServer 管理清单的实现了

EurekaServerAutoConfiguration初始化完成之后EurekaServerInitializerConfiguration.class的start方法来完成启动

SpringCloud【源码分析】之EurakaServer

到此 EurakaServer的管理清单列表的代码分析完毕,集群通知数据同步也在EurekaServerAutoConfiguration中 有兴趣的可以自己看下 大致原理一样的

继续阅读