作者：叩丁狼教育，陈刚
对于一个优秀的程序员而言，一个技术不仅要会用，还要知道他的实现原理和思想，即不仅要知其然还要知其所以然，这样我们写代码才会特别自信，出现bug才能很快定位到问题所在。接下来我们就来简单探讨一下SpringCloud的实现原理，即：源码分析
一.服务注册
服务注册与发现是SpringCloud最基础的部分，我们就从这部分开始着手分析，我们来看一下我们第一章写的服务注册案例，图：
我们知道当服务(Eureka Client)启动会主动向 EurekaServer注册自己，而消费者服务需要调用提供者服务实现消费时是需要向EurekaServer获取目标服务的服务地址等信息，那么我们就先来分析一下EurekaClient是如何实现服务注册的。
回想一下我们构造一个EurekaClient服务实例的时候需要做哪些事情呢？
1.在主程序配置类打开 @EnableDiscoveryClient(或EnableEurekaClient)标签开启EurekaClient功能
2.在applicatiton.properties中做一些服务的基础配置和注册中心地址配置
那么我们就沿着这个2个点来切入源码：
点开 @ EnableDiscoveryClient 源码如下：
EnableDiscoveryClient的文档注释：
Annotation to enable a DiscoveryClient implementation
告诉我们：这个EnableDiscoveryClient这个标签是用来开启 DiscoveryClient的，那么我们来看一下 org.springframework.cloud.client.discovery.DiscoveryClient 如下：
DiscoveryClient 的注释：
DiscoveryClient represents read operations commonly available to Discovery service such as Netflix Eureka or consul.io
告诉我们这个接口定义了服务通常的读取操作的抽象方法，分析这个接口下的三个方法，作用分别是：获取备注 ，根据服务id获取服务列表，获取所有的服务的id
这个接口貌似到顶了，我们看一下他的实现类你可以看到一个让你很亲切的名字 EurekaDiscoveryClient(Eureka的服务客户端) 如下：
可以看到 EurekaDiscoveryClient 依赖了 EurekaClient 接口 ，而对于getServices和 getInstances方法的实现代码中都是调用了EurekaClient的方法,即：“this.eurekaClient…”
继续跟踪 EurekaClient 的源码：
EurekaClient 实现了 LookupService接口，继续跟踪 LookupService
从注释 ：Lookup service for finding active instances.
可以知道，这个lookupService 的作用是用于查找活动实例的服务。并提供了一些查找方法
然而在 EurekaDiscoveryClient 中使用的到底是 EurekaClient 哪个实现类的实例呢？我们继续跟踪一下 EurekaClient的实现类 com.netflix.discovery.DiscoveryClient ,从包名可以知道这个类是netflix提供的：
翻译一下这个类的文档注释，大致意思为：
DiscoveryClient 和 Eureka Server 类进行交互
向 Eureka Server 注册服务
向 Eureka Server租约续期
服务关闭，取消租约续期
获取服务列表
Eureka client需要配置 Eureka Server的url列表
看到这里我们大概知道，其实真正实现服务发现的Netflix包中的com.netflix.discovery.DiscoveryClient类，我们整理一下这几个类/接口的关系图如下：
接下来我们详细看一下DiscoveryClient是如何实现服务注册和发现等功能的，找到DiscoveryClient中的代码：
从方法名字就可以看出方法里面初始化了很多的定时任务，
instanceInfo:是根据服务配置创建出来的服务实例相关信息对象,是在EurekaClientAutoConfiguration类中的 eurekaApplicationInfoManager方法中被创建的
而 EurekaInstanceConfig 就是application.properties配置的绑定
而instanceInfoReplicator 是一个线程对象，他的代码如下：
/**
* A task for updating and replicating the local instanceinfo to the remote server. Properties of this task are:
* - configured with a single update thread to guarantee sequential update to the remote server
* - update tasks can be scheduled on-demand via onDemandUpdate()
* - task processing is rate limited by burstSize
* - a new update task is always scheduled automatically after an earlier update task. However if an on-demand task
* is started, the scheduled automatic update task is discarded (and a new one will be scheduled after the new
* on-demand update).
*
* @author dliu
*/
class InstanceInfoReplicator implements Runnable {
翻译注释知道 InstanceInfoReplicator的作用是用于更新本地instanceinfo并将其复制到远程服务器的任务 ，其实就是把本地服务实例的相关配置信息(地址，端口,服务名等)发送到注册中心完成注册
我们来跟踪一下他的 run方法 ：
定位关键代码： discoveryClient.register(); 这里就是在实现服务注册，继续跟踪进去：
这里通过调用：eurekaTransport.registrationClient.register(instanceInfo);实现注册，而instanceInfo其实就是当前服务实例的元数据(配置信息)，继续跟踪
翻译 Low level Eureka HTTP client API. 得知这里是一个HTTP客户端的API，那么我们可以大胆猜测，register方法的实现其实就是通过 rest 请求的方式。继续往下追踪该方法
看到这里我们应该就明白了，在register方法中获取到了 serviceUrl 即配置文件中的注册服务地址，，把InstanceInfo作为参数，底层通过EurekaHttpClient(Rest方式)来发请求请求，实现服务注册。
服务获取
继续看com.netflix.discovery.DiscoveryClient的initScheduledTasks()方法，里面还有两个定时任务
我们先看第一个任务：服务获取 ，
clientConfig.getRegistryFetchIntervalSeconds()是从配置中获取服务清单获取时间间隔，他是执行线程是new HeartbeatThread(),我们跟踪进去
fetchRegistry:就是获取注册表(注册服务清单)的方法
etAndStoreFullRegistry(); 获得并存储完整的注册表,跟踪进去
我们可以看到 eurekaTransport.queryClient.这样的代码其实就是通过Rest方式去获取服务清单 最后通过 localRegionApps.set把服务存储到本地区域
服务续约
继续看 com.netflix.discovery.DiscoveryClient 中的 initScheduledTasks() 方法中的另一个定时任务
heartbeat ：使用心跳机制实现服务续约，即每间隔多少秒去请求一下注册中心证明服务还在线，防止被剔除。
renewalIntervalInSecs ：就是心跳时间间隔 对应的配置：
eureka.instance.lease-renewal-interval-in-seconds=30
eureka.instance.lease-expiration-duration-in-seconds=90
我们来看一下他的执线程：HeartbeatThread
不难看出他是通过 eurekaTransport.registrationClient.sendHeartBeat：去发送心跳 ，依然是Rest方式
