在 跟我学Spring Cloud(Finchley版)-05-服务注册与服务发现-Eureka入门 一节中,已经编写了一个Eureka Server,并将服务提供者与消费者都注册到了Eureka Server上。
本节,来深入探讨Eureka的高级特性。
Eureka原理
本节来探讨Eureka的原理。
Region & Availability Zone
下面分析一下Eureka原理,在分析原理前,先来了解一下Region和Availability Zone,如下图。
众所周知,Netflix公司将他们的应用都部署在了AWS上,所以Eureka的架构使用到了AWS中的一些概念—— 不用担心,这不是说Eureka和AWS环境绑定,Eureka可以部署在任意环境 。
Region和Availability Zone均是AWS的概念。
-
Region表示AWS中的地理位置,例如us-east-1、us-east-2、eu-west-1等;
-
每个Region都有多个Availability Zone, 彼此内网打通 ;
-
各个Region之间完全隔离, 彼此内网不打通 ;
-
AWS通过这种方式实现了最大的容错和稳定性。
Spring Cloud中,默认使用的Region是 us-east-1
。非AWS环境下,可将将Region理解为内网没有打通的机房,将Availability Zone理解成相同机房的不同机架(内网打通)。
拓展阅读
-
如果您不了解AWS,那你应该听说过阿里云,可以把AWS简单认为是美国版的阿里云……
-
对Region和Availability Zone感兴趣的读者可前往http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/using-regions-availability-zones.html扩展阅读;
-
2017年AWS的S3发生故障,受影响的大型网站列表中,Netflix赫然在列,有兴趣可前往https://www.jianshu.com/p/d5d1fd3151ad 拓展阅读。
Eureka架构详解
如图是Eureka集群的工作原理。图中的组件非常多,概念也比较抽象,我们先来用通俗易懂的文字翻译一下:
-
Application Service:服务提供者;
-
Application Client:服务消费者;
-
Make Remote Call调用RESTful API;
-
us-east-1c、us-east-1d等都是Availability Zone,它们都属于us-east-1这个region。
由图可知,Eureka包含两个组件:Eureka Server 和 Eureka Client,它们的作用如下:
-
Eureka Server提供服务发现的能力,各个微服务启动时,会向Eureka Server注册自己的信息(例如IP、端口、微服务名称等),Eureka Server会存储这些信息;
-
Eureka Client是一个 Java 客户端,用于简化与Eureka Server的交互;
-
微服务启动后,会周期性( 默认30秒 )地向Eureka Server发送心跳以续约自己的“租期”;
-
如果Eureka Server在一定时间内没有接收到某个微服务实例的心跳,Eureka Server将会注销该实例( 默认90秒 );
-
默认情况下, Eureka Server同时也是Eureka Client。多个Eureka Server实例,互相之间通过增量复制的方式,来实现服务注册表中数据的同步 。Eureka Server默认保证在90秒内,Eureka Server集群内的所有实例中的数据达到一致(从这个架构来看,Eureka Server所有实例所处的角色都是 对等 的,没有类似Zookeeper、Consul、Etcd等软件的选举过程,也不存在主从, 所有的节点都是主节点 。Eureka官方将Eureka Server集群中的所有实例称为“ 对等体(peer) ”)
-
Eureka Client会缓存服务注册表中的信息。这种方式有一定的优势——首先,微服务无需每次请求都查询Eureka Server,从而降低了Eureka Server的压力;其次,即使Eureka Server所有节点都宕掉,服务消费者依然可以使用缓存中的信息找到服务提供者并完成调用。
综上,Eureka通过心跳检查、客户端缓存等机制,提高了系统的灵活性、可伸缩性和可用性。
TIPS
事实上,这个官方架构图是有一点问题的: Eureka Server本身也集成了Eureka Client,彼此通过Eureka Client同步数据给其它实例又或者从其他实例同步数据 ——现在,你应该能理解上一节中所使用的 register-with-eureka
以及 fetch-registry
的作用了。
高可用
编写高可用Eureka Server
下面来编写一个双节点Eureka Server集群。编写这个集群非常简单,只需修改单实例Eureka Server的配置即可:
1 为系统配置主机名:
2 配置:
由配置不难看出我们设置了两个Profile:peer1、peer2。两个Profile下各有一个Eureka Server,通过相互注册的方式,构建了Eureka Server集群。
3 启动:
第一个实例会报错,这是正常的,因为它会尝试连接第二个实例,但第二个实例尚未启动,所以会报连接不上的异常。
注意点
拓展阅读
TIPS
编写Eureka Server集群的简写方式:
将应用注册到Eureka Server集群上
以 microservice-provider-user
项目为例,只须修改 eureka.client.serviceUrl.defaultZone
,配置多个Eureka Server地址,就可以将其注册到Eureka Server集群了。示例:
这样就可以将服务注册到Eureka Server集群上了。
当然,微服务即使只配置Eureka Server集群中的某个节点,也能正常注册到Eureka Server集群,因为多个Eureka Server之间的数据会相互同步。例如:
正常情况下,这种方式与配置多个Server节点的效果是一样的。不过为适应某些极端场景,笔者建议在客户端配置多个Eureka Server节点。
应用启动后,访问Eureka Server应能看到类似如下的界面:
RESTful API
前文说过,Eureka本身是一个基于REST的服务。本节来探讨Eureka Server的RESTful API。
下表展示了Eureka Server提供的RESTful API,来自https://github.com/Netflix/eureka/wiki/Eureka-REST-operations ,只需按表格向Eureka Server发送请求,即可操作Eureka Server中的数据。
Operation |
HTTP action |
Description |
Register new application instance |
POST /eureka/apps/ appID |
Input:JSON/XMLpayload HTTPCode: 204 on success |
De-register application instance |
DELETE /eureka/apps/ appID / instanceID |
HTTP Code: 200 on success |
Send application instance heartbeat |
PUT /eureka/apps/ appID / instanceID |
HTTP Code: 200 on success 404 if instanceID doesn’t exist |
Query for all instances |
GET /eureka/apps |
HTTP Code: 200 on success Output:JSON/XML |
Query for all appID instances |
GET /eureka/apps/ appID |
HTTP Code: 200 on success Output:JSON/XML |
Query for a specific appID / instanceID |
GET /eureka/apps/ appID / instanceID |
HTTP Code: 200 on success Output:JSON/XML |
Query for a specific instanceID |
GET /eureka/instances/ instanceID |
HTTP Code: 200 on success Output:JSON/XML |
Take instance out of service |
PUT /eureka/apps/ appID / instanceID /status?value=OUT OF SERVICE |
HTTP Code: 200 on success 500 on failure |
Put instance back into service (remove override) |
DELETE /eureka/apps/ appID / instanceID /status?value=UP (The value=UP is optional, it is used as a suggestion for the fallback status due to removal of the override) |
HTTP Code: 200 on success 500 on failure |
Update metadata |
PUT /eureka/apps/ appID / instanceID /metadata?key=value |
HTTP Code: 200 on success 500 on failure |
Query for all instances under a particular vip address |
GET /eureka/vips/ vipAddress |
HTTP Code: 200 on success Output:JSON/XML 404 if the vipAddress does not exist. |
Query for all instances under a particular secure vip address |
GET /eureka/svips/ svipAddress |
HTTP Code: 200 on success Output:JSON/XML 404 if the svipAddress does not exist. |
调用示例
示例1:注册一个服务:
1 将以下文件存储为rest-api-test.xml
2 通过cURL调用Eureka Server
示例2:查看指定服务的所注册的信息
只需访问: http://Eureka Server的地址/eureka/apps/microservice-provider-user
即可查看 microdervice-provider-user
服务的信息。
RESTful API的意义
你可能会问:我们不是已经有Eureka Client了吗?谁闲着没事再去用RESTful API啊?
要知道,微服务的优势之一就是允许使用异构的技术、异构的语言甚至异构的平台解决你想解决的问题。
举个例子,如果你有一个系统,一部分是Spring Cloud构建的, 一部分是用世界上最好的语言 PHP 写的 !但是呢, 你希望Java应用与PHP应用之间的通信也能享受服务发现所带来的好处 ,此时就可编写一个基于PHP的Eureka Client,将PHP应用也注册到Eureka Server!
事实上, 前文说的Eureka Client不过是一个用Jersey 1.x封装了RESTful API的Jar包而已 。
拓展阅读事实上,业界已经有一些不同语言的Eureka Client,例如:
自我保护模式
自我保护模式是Eureka的重要特性,笔者之前已经专题写过文章详解了,所以本系列不再赘述,直接贴链接了: 理解Eureka的自我保护模式
用户认证
Finchley版本相对之前的版本有些改动,比较重要,以番外形式出现,明天更新。
配套代码
-
GitHub:
-
microservice-discovery-eureka-ha:https://github.com/eacdy/spring-cloud-study/tree/master/2018-Finchley/microservice-discovery-eureka-ha
-
Gitee:
-
microservice-discovery-eureka-ha:https://gitee.com/itmuch/spring-cloud-study/tree/master/2018-Finchley/microservice-discovery-eureka-ha
您的关注是我最大的动力!
看完,赶紧点个“好看”鸭
点鸭点鸭
↓↓↓↓