by shihang.mai

1. 启动

1.1 查看注解注解@EnableEurekaServer
找到类EurekaServerMarkerConfiguration,发现只是new Marker()类

@Configuration(proxyBeanMethods = false)
public class EurekaServerMarkerConfiguration {

    @Bean
    public Marker eurekaServerMarkerBean() {
        return new Marker();
    }

    class Marker {

    }

}

1.2 查看jar中spring.factories文件

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
  org.springframework.cloud.netflix.eureka.server.EurekaServerAutoConfiguration

找到类EurekaServerAutoConfiguration，看到@ConditionalOnBean(EurekaServerMarkerConfiguration.Marker.class)

@Configuration(proxyBeanMethods = false)
@Import(EurekaServerInitializerConfiguration.class)
@ConditionalOnBean(EurekaServerMarkerConfiguration.Marker.class)
@EnableConfigurationProperties({ EurekaDashboardProperties.class,
        InstanceRegistryProperties.class })
@PropertySource("classpath:/eureka/server.properties")
public class EurekaServerAutoConfiguration implements WebMvcConfigurer {
     .....
}

加载条件是有Maker对象,再看@Import(EurekaServerInitializerConfiguration.class)，这个类就是初始化核心类

2. eureka的CAP

eureka是典型的AP,原因如下:

2.1 三级缓存

设置3级缓存是为了减少读写冲突

#是否读取3级缓存，默认为true
eureka.server.use-read-only-response-cache=true/false
#2级缓存到3级缓存的定时间隔
eureka.server.response-cache-update-interval-ms=1000

1. 在eureka-server启动时，会初始化三级缓存。由上向下分别是

• registry
• readWriteCacheMap
• readOnlyCacheMap

2. 每次注册服务时，先向registry注册，然后清除readWriteCacheMap中自己服务的缓存
3. 在eureka-client获取服务时，

• 默认先从readOnlyCacheMap获取，获取不到再向readWriteCacheMap获取
• 当eureka.server.use-read-only-response-cache=false时，直接从readWriteCacheMap获取
  ps:在获取readWriteCacheMap时，会从LocalCache加载数据到readWriteCacheMap

4. 通过定时任务每30s,将readWriteCacheMap的数据同步到readOnlyCacheMap

2.2 集群同步

场景如下,开启相互拉取:
现有eureka-server1(es1),微服务A已注册到es1
当有eureka-server1(es2)启动做集群，那么会拉取es1的服务列表,之后再向es1注册微服务B时，并不会去同步数据到es2.每间一段时间,es2才会去拉取es1数据

#默认拉取服务列表时间为30s
eureka.client.registry-fetch-interval-seconds=30

3. eureka-server服务承受计算

模拟注册和读取算一个，得出10万/s，除去其他代码，我算除以100倍，那么1k/s

服务数:20个
每个服务集群数:5个
接受心跳:2次/分钟
接受拉取:2次/分钟

那么每秒承受访问:20 * 5 * 2 * 2 =400/s

集群没提高承受能力，只是做了HA,因为节点间是全量镜像

4. eureka-server能力

1. 提供注册
   eureka-client向其注册时，只会向一个节点注册。其他节点通过定时任务拉取服务列表
2. 接受心跳(续约)
   eureka-client向其发送心跳时,会触发集群同步
3. 接受下线
   eureka-client向其发送下线时,会触发集群同步
4. 剔除服务
   每个eureka-server都有自己的剔除,剔除也是定时任务，配置如下

#剔除服务的时间
eureka.server.eviction-interval-timer-in-ms=1000

• 默认开启自我保护机制，配置如下。当关闭了自我保护机制，那么直接剔除

#是否开启自我保护
eureka.server.enable-self-preservation=true/false

• 开启自我保护，最后一分钟续约数大于阈值(配置如下)，剔除，少于阈值，开启自我保护，不剔除

#自我保护阈值
eureka.server.renewal-percent-threshold=0.80

5. 接受拉取注册表

• 每个eureka-client都会定时拉取eureka-server注册表，分全量拉取和增量拉取
• eureka-client在注册到eureka-server，就会立刻拉取注册表(开启互相拉取模式的eureka-server集群,它们之间互为eureka-client)
• eureka-client40秒后拉取

6. 集群同步

7. 区域访问

eureka-server端http://server1:8080/eureka,http://server2:8081/eureka

eureka.client.region=gz
eureka.client.availability-zones.gz=z1,z2
eureka.client.service-url.z1=http://server1:8080/eureka,http://server2:8081/eureka
eureka.client.service-url.z2=http://server3:8083/eureka,http://server4:8084/eureka

eureka-server端http://server3:8083/eureka,http://server4:8084/eureka

eureka.client.region=gz
eureka.client.availability-zones.gz=z2,z1
eureka.client.service-url.z1=http://server1:8080/eureka,http://server2:8081/eureka
eureka.client.service-url.z2=http://server3:8083/eureka,http://server4:8084/eureka

eureka-client端无论是provider还是consumer

eureka.client.region=gz
eureka.client.availability-zones.gz=z1,z2
eureka.client.service-url.z1=http://server1:8080/eureka,http://server2:8081/eureka
eureka.client.service-url.z2=http://server3:8083/eureka,http://server4:8084/eureka
eureka.client.prefer-same-zone-eureka=true
#用这个定位
eureka.instance.metadata-map.zone=z1

eureka-client端无论是provider还是consumer

eureka.client.region=gz
eureka.client.availability-zones.gz=z2,z1
eureka.client.service-url.z1=http://server1:8080/eureka,http://server2:8081/eureka
eureka.client.service-url.z2=http://server3:8083/eureka,http://server4:8084/eureka
eureka.client.prefer-same-zone-eureka=true
#用这个定位
eureka.instance.metadata-map.zone=z2

就是就近访问

5. 吐槽

1. 源码中使用了Timer。在多线程并行处理定时任务时，Timer运行多个TimerTask时，只要其中之一没捕获异常，其他任务都会自动终止.使用ScheduleExcutorServer代替
2. eureka-client端只会拉取地址列表的一个的注册表，失败之后才拉取下一个。而且代码中写死了3个。所以超过3个集群是没用的。