系列目录:
- Spring Cloud Eureka 全解 (1) - 总览篇
- Spring Cloud Eureka 全解 (2) - 整体流程篇
- Spring Cloud Eureka 全解 (3) - 核心流程-服务注册与取消详解
- Spring Cloud Eureka 全解 (4) - 核心流程-服务与实例列表获取详解
- Spring Cloud Eureka 全解 (5) - 自我保护机制
- Spring Cloud Eureka 全解 (6) - 一些热门QA
- Spring Cloud Eureka 全解 (7) - 生产配置最佳实践
- Spring Cloud Eureka 全解 (8) - 安全配置
Eureka服务实例启动时,是否会立刻向EurekaServer注册?
是的,立刻会。
EurekaClient在每次实例状态发生改变时,有一个Listener:
statusChangeListener = new ApplicationInfoManager.StatusChangeListener() { @Override public String getId() { return "statusChangeListener"; } @Override public void notify(StatusChangeEvent statusChangeEvent) { if (InstanceStatus.DOWN == statusChangeEvent.getStatus() || InstanceStatus.DOWN == statusChangeEvent.getPreviousStatus()) { // log at warn level if DOWN was involved logger.warn("Saw local status change event {}", statusChangeEvent); } else { logger.info("Saw local status change event {}", statusChangeEvent); } //这个会触发调用register接口将实例信息注册上去 instanceInfoReplicator.onDemandUpdate(); } };
实例初始化完毕时,会发送一个状态为UP的事件,触发这个Listener(状态从STARTING变成UP ):
@Override public void register(EurekaRegistration reg) { maybeInitializeClient(reg); if (log.isInfoEnabled()) { log.info("Registering application " + reg.getInstanceConfig().getAppname() + " with eureka with status " + reg.getInstanceConfig().getInitialStatus()); } reg.getApplicationInfoManager() .setInstanceStatus(reg.getInstanceConfig().getInitialStatus()); if (reg.getHealthCheckHandler() != null) { reg.getEurekaClient().registerHealthCheck(reg.getHealthCheckHandler()); } }
那么,官网这两个配置有啥用:
其实这个Initially是另外一个逻辑,就是在应用启动40s后,检查实例信息是否老旧,或者第一次注册是否失败,如果失败,就再次注册。之后每隔30s执行一次这个任务
EurekaServer集群内部信息如何同步?
首先,EurekaClient会选择eureka.client.service-url.defaultZone配置的第一个EurekaServer,之后如果和这个EurekaServer没有网络问题,就会一直用这个。
在EurekaClient向EurekaServer发送注册,下线,心跳,状态改变等一切事件时,这些会在EurekaServer上面同步到集群(EurekaServer集群配置就是eureka.client.service-url.defaultZone,集群内每个EurekaServer)的所有Server上
这样的机制有没有问题?
1. 这个同步到其他EurekaServer与本次EurekaClient请求是否是同步的?
不是同步的,例如注册到EurekaServerA,EurekaServerA将注册请求同步到EurekaServerB与当前注册请求是异步的
2. 某次异步同步请求失败如何补偿?
例如服务实例A注册到EurekaServerA,但是同步到EurekaServerB失败。这时EurekaServerB就没有这个实例,在下次A心跳时,EurekaServerA同步心跳请求到EurekaServerB时,会返回404,触发重新注册
推论:
为了减少和均匀EurekaServer压力和访问便利,我们对于每个微服务的不同实例,配置Eureka集群都要写的顺序不一样,和自己网段一样的写的靠前
网络抖动时,导致访问到另一个Eureka,重启才能恢复。。。
服务实例怎么过期?
通过EurekaServer内部定时检查过期实例任务,扫描Registry里面过期的实例并删除,并且使对应的ReadWriteMap缓存失效
注意,ReadOnlyMap里面的并不会立刻失效,而是通过下一个只读缓存刷新从ReadWriteMap刷到ReadOnlyMap感知变化。因为EurekaClient获取实例信息只从ReadOnlyMap读取,所以EurekaClient感知变化也会有这个延迟
为何EurekaServer挂了,客户端依然可以调通?
SpringCloud环境下,EurekaClient有缓存,Ribbon对于调用的服务列表也有缓存,所以可以继续调用,但不会更新服务与实例列表了。
根据Eureka的self-preservation的设计思路,可以理解这种设计也是符合Eureka初衷的(CAP中的A)