Spring Cloud Eureka原理分析（一）：注册过程-服务端
Eureka的官方文档和Spring Cloud Eureka文档都有很多含糊的地方，其他资料也不多，只有读读源码维持生活这样子……
本文将不会详细介绍每个细节，而是讲述一些关键的地方，便于查阅。
一些好的参考资料
- 对让人一脸懵逼的region和zone的解释
- 携程对Eureka机制的剖析
- 翟永超的博客
- 芋道源码解析
- 张哈希的专栏
Eureka-Server接受注册请求
正常情况下会进入 PeerAwareInstanceRegistryImpl#register(...) 方法：
@Override
public void register(final InstanceInfo info, final boolean isReplication) {
// 租约过期时间
int leaseDuration = Lease.DEFAULT_DURATION_IN_SECS;
if (info.getLeaseInfo() != null && info.getLeaseInfo().getDurationInSecs() > 0) {
leaseDuration = info.getLeaseInfo().getDurationInSecs();
}
// 注册应用实例信息
super.register(info, leaseDuration, isReplication);
// Eureka-Server 复制
replicateToPeers(Action.Register, info.getAppName(), info.getId(), info, null, isReplication);
}
复制代码
先调用父类 AbstractInstanceRegistry#register(...) 方法完成注册，再将这个注册信息复制到同伴节点。
我们先来看注册部分。
1 注册表registry的实际结构
registry在 AbstractInstanceRegistry 中声明：
private final ConcurrentHashMap<String, Map<String, Lease<InstanceInfo>>> registry; 复制代码
它就是一个ConcurrentHashMap, 其Key为应用的AppID，Value为一个Map，其中的键值对为该应用的各个实例。（InstanceId为键， Lease<InstanceInfo>> 为值）
Lease 表示一个应用实例（Instance）的注册期限，有租约到期和续租之说。 InstanceInfo 则表示一个实例的状态，基本由客户端（服务实例本身）提供。显然，因为服务可能朝生夕死，网络环境千变万化，需要知道服务的状态，决定可不可用。
上一个图，以对 Lease 和 InstanceInfo 有个初步印象：
2 核心注册过程
AbstractInstanceRegistry#register(...) 方法很长，这里不全部贴出来，否则看得太累。只说一些重要的片段。其余细节以后需要时补充。
- 首先从registry中找到应用所对应的数据，记为gMap。如果没有，说明之前没有注册过（或被删除了），那就创建一个Map，加到registry中去。
// 以AppName作为应用的ID Map<String, Lease<InstanceInfo>> gMap = registry.get(registrant.getAppName()); // 如果没有，就创建并添加，略 复制代码
- 在gMap中找此次注册的实例对应的Lease。 注意应用和实例之间的关系。 如果有，说明之前已经注册成功过，需要使用其中的一些信息，比如
serviceUpTimestamp等。然后设置lease的registrationTimestamp和lastUpdateTimestamp为当前时间。 - 经过一个OverriddenInstanceStatus计算，得出此应用实例当前的状态。计算输入包括registry中已有的该实例的lease的状态，和此次注册所声明的状态，以及服务端一系列rule来判断。（同样，这里的细节如有必要以后再讲）最终的InstanceStatus有如下几种状态：
lastUpdatedTimestamp serviceUpTimestamp recentlyChangedQueue invalidateCache()
正文到此结束
热门推荐
相关文章
Loading...
![[HBLOG]公众号](http://www.liuhaihua.cn/img/qrcode_gzh.jpg)
