Eureka源码

4、将注册请求同步peer2

基于eureka client配置和服务实例管理器来构造一个EurekaClient

peer1:8761peer2:8761peer3:8761

浏览器打开控制台可看到eureka-server服务实例status.jsp(eureka-resource工程里)

从注册表中移除该服务实例

eureka整体架构设计

否

4、收到batch的请求后进行任务拆分并分发到相应的处理方法

根据服务名和实例id，获取对应的租约

是

eureka-server(web工程)通过web容器来启动，监听器中执行Bootstrap，初始化eureka-server

AbstractJersey2EurekaHttpClient 发送http请求，调用eureka server的restful接口

1、从eureka-client.properties读取服务实例配置2、构造服务实例（InstanceInfo）3、构造服务实例管理器（ApplicationInfoManager）

是否使用readOnly缓存？

存入readOlny缓存

数据中心是啥东东？

启动一堆调度任务1、定时抓取注册表的任务2、定时发送心跳的调度任务3、定时复制实例信息的调度任务4、注册一个状态变更的监听器

Eureka-core

peer1:8761

12、服务下线

下线

初始化环境（数据中心，运行环境）

ApplicationResource

ReplicationTaskProcessor后台线程

注册

peer1:8761peer3:8761

peer2:8761

5、拉取注册表

9、同步下线请求

3、服务注册

Eureka-client

eureka server集群机制

从相邻eureka server节点拷贝注册表

每次发送心跳，MeasureRate计算出最近一分钟的心跳次数

DiscoveryClient类在销毁前会执行shutdown方法

多级缓存机制

3、while循环从batchWorkQueue中取batch，然后调用 Jersey2ApplicationClient发送同步请求

acceptorQueue

存入readWrite缓存

初始化了网络通信组件EurekaTransport

eureka server web.xml 里面的配置jersey servlet拦截所有的请求，将注册请求分发给ApplicationResources

batchingDispatcher

自我保护机制

InstanceResource

batch

peer2:8761peer3:8761

将本次的缓存全量注册表，计算一个hash值跟server端传过来的全量注册表的hash值，进行比对

是否为null？

2、同步注册表

返回注册表信息

将自已作为服务实例从eureka-client.properties中读取服务实例配置构造了服务实例信息（InstanceInfo）构造服务实例信息管理器（ApplicationInfoManager）

定时执行服务注册逻辑

eureka lient

如果两个hash值不一样，说明同步错了，就重新拉取全量的注册表

5、eureka-server将自已作为一个服务，有2个服务实例启动了

Jersey2ApplicationClient

1、eureka server启动时进行服务注册

从readWrite缓存读

期望心跳次数-2

Eureka sever启动流程

定时检查服务服务是否宕机

batchWorkQueue

每30秒抓取增量注册表

1个网络请求发送1个batch

心跳、下线

peer1:8761peer2:8761

2、eureka server启动时注册表拉取

将这个注册请求转发给了ApplicationResource的addInstance()方法

期望心跳次数+2

PeerReplicationResource#batchReplication

心跳

服务注册

如果抓取注册表以及服务注册的话，会创建两个ThresholdLevelsMetric，还有一些Monitor，先看起来是进行监控的一些东西

9、增量抓取注册表，recentChangeQueue最近3分钟的变化的服务实例

服务实例删除状态添加到最近变更队列中

服务下线

Eureka client启动流程

注册监控

4、同步注册表

6、第一次全量抓取注册表

7、同步续约请求

10、默认每隔30秒进行一次心跳

EurekaServerContext进行初始化（1）更新eureka server集群信息（2）基于eureka server集群信息初始化注册表信息

注销状态变更监听

11、最近一分钟的心跳是否大于预期的心跳

6、服务续约

初始化了2个线程池1、发送心跳2、刷新缓存

从readOnly缓存读

8、服务下线

增量抓取做一致性哈希校验

eureka server集群

发送心跳

acceptorExecutor

7、选择一个eureka server完成注册

peer3:8761

服务续约

保存到本地注册表

定时任务EvictionTask，60秒执行一次，如果某个服务实例故障了，就会摘除。摘除前先判断一下 最近一分钟心跳次数<期望心跳次数，就进入自我保护机制不会摘除服务实例

将自已作为eureka client从eureka-client.properties中读取服务eureka client配置基于服务实例和eureka client配置构造了EurekaClient(DiscoveryClient)

processingOrder

从注册表读

4、将注册请求同步peer3

2、默认每隔500ms将processingOrder中的任务打成一个batch，batch最大是250

第一次抓取全量注册表 和 每30秒抓取增量注册表执行的程序代码一样，但获取到的数据不一样区别是cacheKey不一样，前者是ALL_APPS，后者是ALL_APPS_DELTA，最终前者是从注册表（registry）读，后者是从最近变更队列读（recentlyChangedQueue ）。

第一次抓取全量注册表

从最近变更队列读

注册完成就可以服务管理界面看到

从eureka-client.properties读取eureka client配置

摘除服务实例时应该将期望心跳次数-2，但这里没有，应该是eureka的一个bug

构造感知eureka server集群的注册表PeerAwareInstanceRegistry

更新租约中的 evictionTimestamp=当前时间戳

尝试去抓取注册表，如果抓取不成功，会从备用的注册表地址去抓取

关闭资源

将服务实例、服务实例管理器、Eureka client配置、网络通信配置都保存一下

3层队列异步批处理机制

将最近3分钟有变化的增量注册表同步到本地注册表

acceptorRunner后台线程

构造一个eureka server集群信息PeerEurekaNodes

1、执行服务注册的逻辑2、执行获取注册表

1、将自已作为服务注册

3、将自已作为服务注册

ServiceA，服务A启动的时候，作为一个eureka client去启动

eureka server启动时从其它 eureka server 拉取注册表，将服务实例*2*0.85=每分钟期望心跳次数如果没有eureka server，那么刚开始期望的心跳次数就是0

更新租约中的 lastUpdateTimestamp=当前时间戳+90秒

readOnly缓存定时任务，每隔30秒将readWrite缓存同步到readOnly缓存中去readWrite缓存服务注册、下线、故障会自动过期服务对应的缓存180秒后缓存数据会自动过期

1、eureka client初始化的时候2、调度执行了一个InstanceInfoReplicator组件3、执行服务注册的逻辑

1、while循环从acceptorQueue里取，将取到的放到processingOrder中

8、同步服务注册的请求

读取 eureka-server.properties配置文件

基于euerka server配置、注册表、eureka server集群、服务实例、来构造一个eureka sever服务上下文EurekaServerContext

将自已注册一个监控

将实例信息放到，一个map中{ \"服务\": { \"服务实例1\"：Lease<InstanceInfo> }}

注意这里的流程仅包含主流程，还有一些异常流程未包含，比如各个环节处理失败的情况

取消eureka client的定时任务

定时执行抓取增量注册表逻辑