图片来源https://github.com/Netflix/eureka/wiki/Eureka-at-a-glance
从注解开始了解源码
继续跟进EurekaServerMarkerConfiguration.class 发现什么都没有做只是执行了一下marker()
@EnableEurekaServer 只是做了这点事情,那么猜测一定是在@SpringBootApplication 有相关操作,并且一定会有对marker()的处理 ,带着这些疑问我们继续看springbootApplication注解
关键在于@EnableAutoConfiguration
@EnableAutoConfiguration 自动配置。既然是自动配置 那么可以看下它都配置那些bean
最终继续跟进注解@import相关的class信息会找到AutoConfigurationImportSelector.class
这个类主要的功能是自动加载相关bean.
此方法就会看到加载的bean信息,我们本次需要关注EurekaServerAutoConfiguration就在其中,既然加载这个bean 就去看看这个bean都做些什么事情。
@ConditionalOnBean(Marker.class) 这个是表示只有在spring容器
里面含有Market这个实例的时候,才会加载当前这个Bean)也就是我们看到@EurekaServer注解里的做marker()调用,通知开启EurekaServer
关注EurekaServerAutoConfigutation.class 会发现都是注入一些相关的bean 其中有一个eurekaServerBootstrap的注入
继续跟进eurekaServerBootsrtap都提供了那些方法
// 初始化Eureka的环境变量
initEurekaEnvironment();
// 初始化Eureka的上下文
initEurekaServerContext();
// 从相邻的eureka节点复制清单 这个是集群处理同步通知
int registryCount = this.registry.syncUp();
// 开启一个定时任务 用于管理服务清单
this.registry.openForTraffic(this.applicationInfoManager, registryCount);
继续跟进openfortraffic会找到PeerAwareInstanceRegistryImpl.class
expectedNumberOfRenewsPerMin // 计算每分钟最大续约数
numberOfRenewsPerMinThreshold//每分钟最小续约数
发现调用postinit 这个方法主要是开启定时每60秒更新下清单类别 超时续约的剔除
这个定时就是一个timertask来执行的 EvictionTask---evict()方法
通过看evict方法 其实报存 服务清单列表的是一个map数据
private final ConcurrentHashMap<String, Map<String, Lease<InstanceInfo>>> registry = new ConcurrentHashMap();
key 存储服务的名字
value 存储元数据
我们知道 EurekaServer 管理清单的实现了
EurekaServerAutoConfiguration初始化完成之后EurekaServerInitializerConfiguration.class的start方法来完成启动
到此 EurakaServer的管理清单列表的代码分析完毕,集群通知数据同步也在EurekaServerAutoConfiguration中 有兴趣的可以自己看下 大致原理一样的