前言
Spring Cloud Eureka是Spring Cloud Netflix微服务套件中的一部分,主要负责实现微服务架构中的服务治理功能,包括服务注册和服务发现。本文从源码的角度,分析Eureka的服务治理机制。
Eureka服务治理机制
在Eureka服务治理架构中有三种角色,分别是:
角色一:服务注册中心,Eureka提供的服务端,提供服务的注册和发现功能:
角色二:服务提供者,提供服务的应用,需要将自己提供的服务注册到Eureka,以供其他应用发现
角色三:服务消费者,消费者应用,从服务注册中心获取服务列表,从而知道从何处调用需要的服务
DiscoveryClient类
一般我们将Spring boot应用注册到Eureka Server或者需要从Eureka Server中获取服务列表时,需要做如下两件事情:
1:在应用主类中配置@EnableDiscoveryClient注解:
2:在application.properties中用eureka.client.serviceUrl.defaultZone参数指定服务注册中心地址
先从@EnableDiscoveryClient注解开始,看一下源码:
从图中红框标注的注释可以得知,此注解用来开启DiscoveryClient的实例。搜索DiscoveryClient,可以发现一个类和一个接口,先来看一下类图:
从DiscoveryClient(com.netflix.discovery.DiscoveryClient)的类注释中,我们可以知道,该类负责向Eureka Server注册服务实例、向Eureka Server服务租约、当服务关闭时,向Eureka Server取消租约、查询Eureka Server中的服务实例列表。
服务注册
查看DiscoveryClient的构造方法,可以看到调用了如下方法:
可以看到,如果当前应用需要被注册到Eureka中,则创建一个InstanceInfoReplicator类的实例,它会执行一个定时任务,
该任务的具体执行内容可以查看该类的run方法,
看到这里,我们应该能猜出来,注册操作其实就是通过REST请求的方式进行的,传入的参数为InstanceInfo对象,内部保存的就是关于服务的元数据。
服务获取和服务续约
刚才的initScheduledTasks方法中还有两个定时任务,分别是“服务获取”和“服务续约”,
initScheduledTasks方法会启动HeartbeatThread线程定时完成服务续约,默认续约的时间间隔为30秒,默认的服务信息保留时间为90秒,可以通过application.properties中启动参数设置。
HeartbeatThread线程通过调用renew方法,直接以REST请求的方式实现服务续约。
再来看服务获取逻辑,initScheduledTasks方法会启动CacheRefreshThread线程定时完成服务获取,默认的时间间隔为30秒,也可以通过application.properties中启动参数设置。
可以看到服务获取逻辑相对复杂一点,会根据是否是第一次获取发起不同的REST请求和相应的处理,处理逻辑又分全量获取和差量获取。
服务注册中心处理
通过上述分析,我们得知所有的交互都通过REST请求来发起的,那服务注册中心又是如何处理这些请求的呢?Eureka Server对于各类REST请求的定义都位于com.netflix.eureka.resources包中,以处理服务注册为例,
服务注册的过程大致如下,先调用publishEvent方法,将该新服务注册的事件传播出去,再调用父类方法注册实现,将InstanceInfo中的元数据保存在一个ConcurrentHashMap对象中。注册中心存储了两层Map结构,第一层key为存储的服务名称,value为InstanceInfo中的appName属性,第二层key为实例名称,value为InstanceInfo中的instanceId属性。
总结
本文从源码的角度介绍了Spring Cloud Eureka的服务治理机制,但真正的服务治理机制绝非如此简单,本文关注了其最重要的几个方面,希望能对读者有所帮助。