自动配置相关配置类
InstanceRegistryProperties
EurekaServerConfigBean 服务端配置信息
EurekaClientConfigBean 客户端配置信息
EurekaInstanceConfigBean 实例信息
EurekaDashboardProperties
客户端注册实现:
(1) EurekaClientConfiguration#eurekaApplicationInfo 初始化当前实例信息ManagerInstanceInfoFactory#create
(2) EurekaClientConfiguration#eurekaClient 实例化 DiscoveryClient的一个子类
(3) DiscoveryClient#register#renew 过程中,如果返回404状态码,则进行注册
(4) AbstractJerseyEurekaHttpClient#register rest http请求
客户端下架:
(1) EurekaDiscoveryClientConfiguration#onApplicationEvent spring上下文关闭时下架eureka服务
(2) DiscoveryClient#shutdown 改成DOWN
(3) DiscoveryClient#unregister 调用cancel接口
客户端获取服务信息
(1) DiscoveryClient#refreshRegistry()
(2) EurekaHttpClient#getApplications()
客户端心跳检查机制
(1) HeartbeatThread
(2) DiscoveryClient#renew
服务端高可用实现
p2p机制
(1) EurekaServerAutoConfiguration#eurekaServerContext 上下文初始化
(2) PeerEurekaNodes#start 刷新peer集群列表并启动更新任务,配置中获取 (eureka还提供dns发现机制,不推荐使用)
(3) PeerEurekaNodes.updatePeerEurekaNodes 维护peer列表
信息同步
(1) PeerAwareInstanceRegistryImpl 用来同步renew/register/cancel..
(2) isReplication 表示这个请求是否来自其他peer,防止循环传播
服务端获取请求注册
(1) EurekaServerAutoConfiguration#jerseyApplication
集成eureka原生包中的Jersey RESTful接口 #jerseyFilterRegistration filter形式
(2) ApplicationResource#addInstance() 受理请求
(3) InstanceRegistry#register() 发布EurekaInstanceRegisteredEvent事件
(4) PeerAwareInstanceRegistryImpl#register() 集群同步replicateToPeers
(5) AbstractInstanceRegistry#regiter() 存在ConcurrentHashMap
服务端存储服务信息
(1) AbstractInstanceRegistry.registry() 内存中存储ConcurrentHashMap
服务剔除
(1) EurekaServerInitializerConfiguration#start(), EurekaServerBootstrap#contextInitialized(), EurekaServerBootstrap#initEurekaServerContext() 初始化 上下文
(2) InstanceRegistry#openForTraffic()
(3) AbstractInstanceRegistry#postInit() 执行EvictionTask
(4) 自我保护状态下不剔除
自我保护
(1) PeerAwareInstanceRegistryImpl#isLeaseExpirationEnabled()
(2) numberOfRenewsPerMinThreshold 正常态下,一分钟会收到多少客户端的renewx = size * renewalPercentThreshold
新服务注册时会重新计算这个值