首页  流程图  详情

Eureka_1.7.2源码全景图

2021-12-12 15:59:50   0  举报





为你推荐

查看更多



spring整套源码系列之【MVC关键源码】

全景相机

spring整套源码系列之【aop解析切面源码】

Eureka源码

大型电商产品全景图

Eureka_1.7.2源码全景图

eureka

Spring

作者其他创作

大纲/内容

appinfo.replicate.interval40秒后执行1次

调度线程池

请求类型

acceptorThread

for循环

主动过期缓存

lease.duration更新+90s

节点PeerEurekaNode

hash和服务端注册表一致

enableSelfPreservation

服务取消注册server

无

客户端主动关闭

执行run()

maxThreadsForPeerReplication默认开启20个线程

如果eureka节点A接受到服务注册请求，想要复制给eureka节点B。请求放入三层队列，在批量发送之前，节点A宕机了，此时eureka如何补救？答：服务会持续发送心跳，当发现节点A接收心跳失败，就会发送心跳给节点B，由节点B同步给集群内其他eureka节点。

Eureka集群管理器PeerEurekaNodes

最近变化队列recentlyChangedQueue

InstanceResourcecancelLease()取消注册请求

只读缓存readOnlyCacheMap

有，增量更新

registry.syncUp()从相邻的eureka节点拷贝注册信息

取出所有数据

更新

计算更新后的服务实例信息的hash值

client.refresh.interval30秒执行1次

renewalThresholdUpdateIntervalMs15分钟更新1次

get请求/v2/apps/delta

有无缓存

numberRegistrySyncRetries重试5次

TaskExecutors

一致

地址变更

isReplication

get请求/v2/apps

init初始化

InstanceInfoReplicator服务信息复制组件

否

加载客户端配置EurekaClientConfig

有

acceptorQueue请求队列

注册服务实例

预期每分钟会接收到多少次心跳（有bug）

增加

server启动

全量抓取注册表

是

处理请求

eureka-client.properties配置文件

开始

初始化

结束

本地注册表localRegionApps

Web容器启动监听器ServletContextListener

ApplicationResourceaddInstance()注册请求

定时同步

关闭节点shutdown

DiscoveryClient服务注册表localRegionApps

InstanceResourcerenewLease()服务续约请求

客户端启动

自动过期

读写guava缓存ReadWriteCacheMap

根据最新的注册表服务实例数量

加载服务端配置EurekaServerConfig

取消注册，更新-2

客户端增量拉取注册表

缓存刷新线程池

开启自我保护

post请求/v2/apps/ServiceA

初始化EurekaBootStrap

peerEurekaNodesUpdateIntervalMs10分钟执行1次

新增

初始化Eureka服务端上下文EurekaServerContext

responseCacheAutoExpirationInSeconds过期时间180秒

服务注册server

服务实例注册器PeerAwareInstanceRegistry

自动清理

服务实例状态变更监听器

从eureka-client.properties读取serviceUrl

增量抓取注册表

相邻节点有数据

统计一分钟发送了多少次心跳

eureka-server.properties配置文件

删除

post请求/v2/peerreplication/batch

ApplicationsResourcegetContainerDifferential()接收请求

Eureka Client初始化和销毁

maxElementsInPeerReplicationPool500毫秒一个批次且最大250个请求一个批次打包请求

更新+1

processingOrder请求队列

最后更新时间（有bug，当前时间+90s）

evictionIntervalTimerInMs60秒执行1次

发送请求

同步请求到其他eureka节点

获取增量变更的实例信息

registry.openForTraffic()服务实例是否故障宕机（包含自我保护机制）

故障发现定时任务

写入

健康检查

发送心跳HeartbeatThread

最多挑选15%的过期的服务实例数量下线

put请求/v2/apps/ServiceA/1

delete请求/v2/apps/ServiceA/1

是否满足预期心跳数量

batchWorkQueue批量请求队列

responseCacheUpdateIntervalMs30秒同步1次

服务注册到server

增量抓取注册表CacheRefreshThread

一. 服务注册到发现最多多久？1. 服务A的实例a1第一次注册上eureka的时候，服务B的client增量拉取需要花费30秒，能感知到a12. 服务A的实例a1已经注册上eureka，现在再加一个实例a2，server端的只读缓存30秒之后才能过期，服务B的client增量拉取需要花费30秒，共60秒才能感知到a2

有无数据

是否404

分发请求到以上的端点处理

初始化只执行1次post请求/v2/apps/ServiceA

registrySyncRetryWaitMs休眠30秒

不一致发生了意外的问题

加载服务实例配置EurekaInstanceConfig

缓存管理器ResponseCache

false

新增删除

删除缓存

设置值