原来一个 Map 就能搞定注册表了

（一）领导让我研究 Eureka 源码 | 启动过程

（二）领导“叕”让我研究 Eureka 源码：注册过程

（三）值得收藏的 Eureka 控制台详解

接下来，会从以下几个方面讲解：

• 客户端发送注册请求。
• Eureka 注册中心接收注册请求。
• 服务端将客户端注册信息保存到一个 Map 里面。

关于源码的获取直接到官网下载就好了。https://github.com/Netflix/eureka

本文已收录到我的 github：https://github.com/Jackson0714/PassJava-Learning

一、注册入口

上一讲我们知道了 Eureka Client 是通过发送 http 请求来注册的，那么肯定是有一个地方来接收这个 http 请求的，也就是注册入口。这是怎么玩的呢？

其实是用到了 jersey 框架，这个框架不用深究，我们只需要知道这个框架在哪引用以及做什么事情的就可以了。

可以把 jersey 类比 mvc 框架，jersey 有 servlet 专门处理 http 请求。引用 jersey 框架的地方：

\eureka\eureka-server\src\main\webapp\WEB-INF\web.xml

然后处理 HTTP 请求的 controller 在哪呢？

其实是在 eureka-core 项目的 resources 目录下，里面定义了很多的 Resource 结尾的类，它们就是用来处理 HTTP 请求的。

\eureka\eureka-core\src\main\java\com\netflix\eureka\resources

通过XxResource 类的英文注释我们也可以知道，这个 jersey resource 类是用来处理 HTTP 请求的。

A jersey resource that handles request

后找到了 ApplicationResource 类的 addInstance 方法就是我们要找的处理注册请求的方法。

二、接收注册请求

整体流程如下：

2.1 接收注册请求的方法

addInstance 方法里面的核心代码就是

registry.register(info, true);

registry 就是 PeerAwareInstanceRegistryImpl 的实例对象。它实现了 PeerAwareInstanceRegistry 接口。

调用它的 register() 方法后会调用抽象类 AbstractInstanceRegistry 的 register() 方法，核心代码就是在这个抽象类的 register() 方法。另外要说下的就是上面的抽象类和接口分别实现和继承了接口 InstanceRegistry。

接口和类的关系图如下：

那么注册信息会放到哪个里面呢？

三、存放注册信息的地方

我们看到源码里面定义了一个 gNewMap，是 ConcurrentHashMap，然后赋值给了 gMap 变量

ConcurrentHashMap<String, Lease<InstanceInfo>> gNewMap 

所以其实是用 gMap 变量来存注册信息的。我们来分析 gMap 的结构。

首先 gMap 是 ConcurrentHashMap 结构，所以就是 key-value 这种键值对的。

• key 就是一个 id，String 类型。值类似这种：i-00000004
• value 里面存的是 Lease。
• Lease是一个类，里面持有一个 instanceInfo 的 holder。这个 instanceInfo 就是注册过来的服务实例信息，包含  ip 地址，端口号等。

gMap.put(registrant.getId(), lease);

ConcurrentHashMap<String, Lease<InstanceInfo>>()

readWriteLock = new ReentrantReadWriteLock();
Lock read = readWriteLock.readLock();
read.lock();
...
read.unlock();