该方法中的eurekaClient.getApplications()是通过http调用,获取集群中的其他节点的所有服务实例。然后遍历获取到的apps,根据isRegisterable(instance)判断是否可注册,如果可以注册就调用register(instance, instance.getLeaseInfo().getDurationInSecs(), true)进行注册,注册实质就是往AbstractInstanceRegistry的属性private final ConcurrentHashMap>> registry = new ConcurrentHashMap>>();中加入服务实例信息。
1719963881
发表于 4个月前
该方法中的eurekaClient.getApplications()是通过http调用,获取集群中的其他节点的所有服务实例。然后遍历获取到的apps,根据isRegisterable(instance)判断是否可注册,如果可以注册就调用register(instance, instance.getLeaseInfo().getDurationInSecs(), true)进行注册,注册实质就是往AbstractInstanceRegistry的属性private final ConcurrentHashMap>> registry = new ConcurrentHashMap>>();中加入服务实例信息。
⑤ PeerAwareInstanceRegistryImpl.openForTraffic()方法:
该方法核心第一步:applicationInfoManager.setInstanceStatus(InstanceStatus.UP)修改状态为UP,第二步:调用super.postInit();开启一个剔除定时任务,每隔60执行一次,从当前服务清单中把超时(默认90秒)没有续约剔除。
⑥ 进入AbstractInstanceRegistry.postInit()方法:
评论列表
加载数据中...
896452247
发表于 4个月前
执行AbstractInstanceRegistry.evict(),剔除逻辑:主要的功能是将注册表registry,其实就是一个ConcurrentHashMap的所有注册实例遍历下,看哪些是过期的,过期了就加入到expiredLeases中,然后遍历expiredLeases,执行internalCancel方法把实例状态修改成DELETED状态,这样客户端就拿不到。
评论列表
加载数据中...
2430658640
发表于 4个月前
① EurekaServerConfig:初始化eurekaServer配置;
② EurekaController:初始化dashboard的相关接口,用户获取eurekaServer的相关信息;
③ PeerAwareInstanceRegistry:初始化集群注册表;
④ PeerEurekaNodes:初始化集群节点;
⑤ EurekaServerContext:基于eurekaServer配置,注册表,集群节点,以及服务实例初始化eurekaServer上下文;
⑥ EurekaServerBootstrap:初始化eureka启动类;
⑦ FilterRegistrationBean:往Filter注册表里面注册一个Jsrsey过滤器;
其中EurekaServerContext的默认实现DefaultEurekaServerContext在初始化的时候会调用initialize()方法,流程图如下:
评论列表
加载数据中...
896452247
发表于 4个月前
3.1 服务注册接口
ApplicationResource.addInstance()方法,核心逻辑就是调用PeerAwareInstanceRegistryImpl.register(final InstanceInfo info, final boolean isReplication)方法如下:
评论列表
加载数据中...
klmk
发表于 4个月前
ApplicationsResource.getContainers()方法如下:
评论列表
加载数据中...
神麤詭末
发表于 4个月前
InstanceResource.cancelLease()方法,核心就是调用PeerAwareInstanceRegistryImpl.cancel(final String appName, final String id,final boolean isReplication)方法进行服务下线,其实就是把实例的状态设置成DELETE,然后执行invalidateCache(),把读写缓存readWriteCacheMap失效掉
评论列表
加载数据中...
hcat
发表于 4个月前
ApplicationsResource.getContainerDifferential()方法,逻辑同获取全量实例信息接口一样,不同在于构建缓存key的时候传入的ALL_APPS_DELTA,而获取全量实例信息接口传入的是ALL_APPS。
3.4 心跳接口
InstanceResource.renewLease()方法,核心逻辑就是调用PeerAwareInstanceRegistryImpl.renew(final String appName, final String id, final boolean isReplication)方法进行续约,其实就是设置实例的lastUpdateTimestamp为当前时间+duration
public void renew() {
//设置lastUpdateTimestamp为当前时间+duration
lastUpdateTimestamp = System.currentTimeMillis() + duration;
}
评论列表
加载数据中...
1679644933
发表于 4个月前
评论列表
加载数据中...
1008611
发表于 4个月前
评论列表
加载数据中...
admin
发表于 4个月前
评论列表
加载数据中...