引言

Eureka是Netflix公司开源的一款基于REST的服务自动注册和发现的产品,如下图所示Eureka可以分为三个部分:

  • Eureka-Server:提供服务注册和发现。
  • Eureka-Client-Service-Provider:服务提供者,通过Rest告知服务端注册,更新,取消服务。
  • Eureka-Client-Service-Consumer:服务消费者,通过Rest从服务端获取需要服务的地址列表,然后配合一些负载均衡策略来调用相关的服务。

Eueka Structure

Eureka Server

服务注册(Register)

Eureka Server中会保存一份所有Service注册信息的map,将InstanceInfo中的元数据信息存储在一个ConcurrentHashMap<String, Map<String, Lease<InstanceInfo>>>对象中,它是一个双层Map结构,第一层的存储服务名-appName,第二层的存储实例名-instanceId属性。

如果没有设置eureka.instance.appName默认使用spring.application.name,如果没有设置eureka.instance.instanceId则默认是CLIENT IP:PORT

服务续约(Renew)

Eureka Client每隔一段时间都会向Eureka Server发送一个心跳声明自己目前处于正常的状态。

服务剔除(Canel)

Eureka会定期检查是否有服务已经失效,检测的标准就是超过指定的时间没有进行续约的服务,这个指定的时间可以通过eureka.instance.lease-expiration-duration-in-seconds=90来指定,Eureka Server定期检查的时间可以通过eureka.instance.lease-renewal-interval-in-seconds=30来设置。

Peer复制

当一个Eureka Client向一个Eureka Server实例注册/续约/剔除之后,这台Eureka Server需要将相关的信息同步更新到其他的Eureka Server。

Service Provider

Service Provider(Eureka Client)主要负责下面几个任务:

  • 向Eureka Server注册服务。
  • 向Eureka Server服务续约。
  • 当服务关闭期间,向Eureka Server注销。
  • Eureka Client还需要配置一个Eureka Server的URL列表。

注册

Service Provider要对外提供服务,一个很重要的步骤就是向Eureka Server去注册。

服务续约

Service Provider每个一定时间就会通知Eureka Server来表明自己依然还活着,这个参数默认是30s,可以通过eureka.instance.lease-renewal-interval-in-secends来设置。

服务剔除

在Service Provider要Shutdown的时候,需要及时通知Eureka Server将自己剔除,避免Consumer调用不存在的服务,这可以通过下面的方法来调用:

1
DiscoveryManager.getInstance().shutdownComponent()

Eureka Server选择规则

在获取了Region和Zone信息之后,才开始真正加载Eureka Server的具体地址。它根据传入的参数按一定算法确定加载位于哪一个Zone配置的serviceUrls。

当客户端在服务列表中选择实例进行访问时,对于Zone和Region遵循这样的规则:优先访问同自己一个Zone中的实例,其次才访问其他Zone中的实例。通过Region和Zone的两层级别定义,配合实际部署的物理结构,我们就可以有效的设计出区域性故障的容错集群。

aws-region-zone

Consumer

Fetch Service Registry

通过eureka.client.fetch-registry=true来允许从Eureka Server获取服务列表。

Update Service Registry

Consumer会在本地保存一份所有服务的缓存列表,每隔一定的时间都会重新向Eureka Server查询来更新这份列表,这个参数可以通过eureka.client.registry-fetch-interval-seconds=30来指定这个时间。p.s: Consumer也是属于Eureka Client。

为什么服务注册会慢

当Erueka Client向Eureka Server注册一个服务,有时候我们会发现不能从Consumer立即读取到注册服务,主要有下面四个原因:

  • Eureka Client每隔一定时间(默认是30s)才会向Eureka Server发送心跳信息。
  • Eureka Client自身在本地也有一份服务列表缓存。
  • Eureka Server也保持了一份缓存。
  • 通过Ribbon做负载均衡的时候,Ribbon也保存了一份服务列表的缓存。

Reference

Asarkar-Blog-Netflix-Eureka

GitHub-Netflix-Eureka-Wiki

GitHub-Spring-Cloud-Netflix-Issues-373

Understanding Eureka Peer to Peer Communication

CSDN-AWS-Region-Zone

Contact

GitHub: https://github.com/ziwenxie
Blog: https://www.ziwenxie.site