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
- 在eureka-server启动时，会初始化三级缓存。由上向下分别是
- registry
- readWriteCacheMap
- readOnlyCacheMap
- 每次注册服务时，先向registry注册，然后清除readWriteCacheMap中自己服务的缓存
- 在eureka-client获取服务时，
- 默认先从readOnlyCacheMap获取，获取不到再向readWriteCacheMap获取
- 当eureka.server.use-read-only-response-cache=false时，直接从readWriteCacheMap获取
ps:在获取readWriteCacheMap时，会从LocalCache加载数据到readWriteCacheMap
- 通过定时任务每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能力
- 提供注册
eureka-client向其注册时，只会向一个节点注册。其他节点通过定时任务拉取服务列表 - 接受心跳(续约)
eureka-client向其发送心跳时,会触发集群同步 - 接受下线
eureka-client向其发送下线时,会触发集群同步 - 剔除服务
每个eureka-server都有自己的剔除,剔除也是定时任务，配置如下
#剔除服务的时间
eureka.server.eviction-interval-timer-in-ms=1000
- 默认开启自我保护机制，配置如下。当关闭了自我保护机制，那么直接剔除
#是否开启自我保护
eureka.server.enable-self-preservation=true/false
- 开启自我保护，最后一分钟续约数大于阈值(配置如下)，剔除，少于阈值，开启自我保护，不剔除
#自我保护阈值
eureka.server.renewal-percent-threshold=0.80
- 接受拉取注册表
- 每个eureka-client都会定时拉取eureka-server注册表，分全量拉取和增量拉取
- eureka-client在注册到eureka-server，就会立刻拉取注册表(开启互相拉取模式的eureka-server集群,它们之间互为eureka-client)
- eureka-client40秒后拉取
集群同步
区域访问
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. 吐槽
- 源码中使用了Timer。在多线程并行处理定时任务时，Timer运行多个TimerTask时，只要其中之一没捕获异常，其他任务都会自动终止.使用ScheduleExcutorServer代替
- eureka-client端只会拉取地址列表的一个的注册表，失败之后才拉取下一个。而且代码中写死了3个。所以超过3个集群是没用的。
