本文基于SpringCloud-Dalston.SR5spring
是的,马上会。缓存
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 ):app
@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执行一次这个任务异步
首先,EurekaClient会选择eureka.client.service-url.defaultZone配置的第一个EurekaServer,以后若是和这个EurekaServer没有网络问题,就会一直用这个。 在EurekaClient向EurekaServer发送注册,下线,心跳,状态改变等一切事件时,这些会在EurekaServer上面同步到集群(EurekaServer集群配置就是eureka.client.service-url.defaultZone,集群内每一个EurekaServer)的全部Server上ide
这样的机制有没有问题?微服务
网络抖动时,致使访问到另外一个Eureka,重启才能恢复。。。url
经过EurekaServer内部定时检查过时实例任务,扫描Registry里面过时的实例并删除,而且使对应的ReadWriteMap缓存失效 注意,ReadOnlyMap里面的并不会马上失效,而是经过下一个只读缓存刷新从ReadWriteMap刷到ReadOnlyMap感知变化。由于EurekaClient获取实例信息只从ReadOnlyMap读取,因此EurekaClient感知变化也会有这个延迟设计
SpringCloud环境下,EurekaClient有缓存,Ribbon对于调用的服务列表也有缓存,因此能够继续调用,但不会更新服务与实例列表了。 根据Eureka的self-preservation的设计思路,能够理解这种设计也是符合Eureka初衷的(CAP中的A)code