在跟我学Spring Cloud(Finchley版)-05-服务注册与服务发现-Eureka入门 一节中,已经编写了一个Eureka Server,并将服务提供者与消费者都注册到了Eureka Server上。html
本节,来深刻探讨Eureka的高级特性。java
本节来探讨Eureka的原理。python
下面分析一下Eureka原理,在分析原理前,先来了解一下Region和Availability Zone,以下图。git
众所周知,Netflix公司将他们的应用都部署在了AWS上,因此Eureka的架构使用到了AWS中的一些概念——不用担忧,这不是说Eureka和AWS环境绑定,Eureka能够部署在任意环境。github
Region和Availability Zone均是AWS的概念。spring
Spring Cloud中,默认使用的Region是us-east-1
。非AWS环境下,可将将Region理解为内网没有打通的机房,将Availability Zone理解成相同机房的不一样机架(内网打通)。npm
拓展阅读vim
如图是Eureka集群的工做原理。图中的组件很是多,概念也比较抽象,咱们先来用通俗易懂的文字翻译一下:windows
由图可知,Eureka包含两个组件:Eureka Server 和 Eureka Client,它们的做用以下:api
综上,Eureka经过心跳检查、客户端缓存等机制,提升了系统的灵活性、可伸缩性和可用性。
TIPS
事实上,这个官方架构图是有一点问题的:Eureka Server自己也集成了Eureka Client,彼此经过Eureka Client同步数据给其它实例又或者从其余实例同步数据——如今,你应该能理解上一节中所使用的 register-with-eureka
以及fetch-registry
的做用了。
下面来编写一个双节点Eureka Server集群。编写这个集群很是简单,只需修改单实例Eureka Server的配置便可:
为系统配置主机名:
vim /etc/hosts # 添加以下内容 127.0.0.1 peer1 peer2 对于Windows系统,请修改C:\windows\system32\drivers\etc\hosts文件
配置:
spring: application: name: microservice-discovery-eureka-ha --- spring: profiles: peer1 # 指定profile=peer1 server: port: 8761 eureka: instance: hostname: peer1 # 指定当profile=peer1时,主机名是peer1 client: serviceUrl: defaultZone: http://peer2:8762/eureka/ # 将本身注册到peer2这个Eureka上面去 --- spring: profiles: peer2 server: port: 8762 eureka: instance: hostname: peer2 client: serviceUrl: defaultZone: http://peer1:8761/eureka/
由配置不难看出咱们设置了两个Profile:peer一、peer2。两个Profile下各有一个Eureka Server,经过相互注册的方式,构建了Eureka Server集群。
启动:
java -jar microservice-discovery-eureka-ha-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer1 java -jar microservice-discovery-eureka-ha-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer2
第一个实例会报错,这是正常的,由于它会尝试链接第二个实例,但第二个实例还没有启动,因此会报链接不上的异常。
注意点
http://127.0.0.1:8761/eureka/
)相互注册,Eureka Server误认为两个Eureka Server实例是一个实例——这会形成Eureka Server首页显示不正常等一系列问题!!拓展阅读
TIPS
编写Eureka Server集群的简写方式:
spring: application: name: microservice-discovery-eureka-ha eureka: client: serviceUrl: defaultZone: http://peer2:8762/eureka/,http://peer1:8761/eureka/ --- spring: profiles: peer1 server: port: 8761 eureka: instance: hostname: peer1 --- spring: profiles: peer2 server: port: 8762 eureka: instance: hostname: peer2
以microservice-provider-user
项目为例,只须修改eureka.client.serviceUrl.defaultZone
,配置多个Eureka Server地址,就能够将其注册到Eureka Server集群了。示例:
eureka: client: serviceUrl: defaultZone: http://peer1:8761/eureka/,http://peer2:8762/eureka/
这样就能够将服务注册到Eureka Server集群上了。
固然,微服务即便只配置Eureka Server集群中的某个节点,也能正常注册到Eureka Server集群,由于多个Eureka Server之间的数据会相互同步。例如:
eureka: client: serviceUrl: defaultZone: http://peer1:8761/eureka/
正常状况下,这种方式与配置多个Server节点的效果是同样的。不过为适应某些极端场景,笔者建议在客户端配置多个Eureka Server节点。
应用启动后,访问Eureka Server应能看到相似以下的界面:
前文说过,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 appIDinstances | GET /eureka/apps/appID | HTTP Code: 200 on success Output:JSON/XML |
Query for a specificappID/instanceID | GET /eureka/apps/appID/instanceID | HTTP Code: 200 on success Output:JSON/XML |
Query for a specificinstanceID | 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 thevipAddressdoes 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 thesvipAddressdoes not exist. |
示例1:注册一个服务:
将如下文件存储为rest-api-test.xml
<instance> <instanceId>itmuch:rest-api-test:9000</instanceId> <hostName>itmuch</hostName> <app>REST-API-TEST</app> <ipAddr>127.0.0.1</ipAddr> <vipAddress>rest-api-test</vipAddress> <secureVipAddress>rest-api-test</secureVipAddress> <status>UP</status> <port enabled="true">9000</port> <securePort enabled="false">443</securePort> <homePageUrl>http://127.0.0.1:9000/</homePageUrl> <statusPageUrl>http://127.0.0.1:9000/info</statusPageUrl> <healthCheckUrl>http://127.0.0.1:9000/health</healthCheckUrl> <dataCenterInfo class="com.netflix.appinfo.InstanceInfo$DefaultDataCenterInfo"> <name>MyOwn</name> </dataCenterInfo> </instance>
经过cURL调用Eureka Server
cat ./rest-api-test.xml | curl -v -X POST -H "Content-type: application/xml" -d @- http://localhost:8761/eureka/apps/rest-api-test
示例2:查看指定服务的所注册的信息
只需访问:http://Eureka Server的地址/eureka/apps/microservice-provider-user
便可查看microdervice-provider-user
服务的信息。
你可能会问:咱们不是已经有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版本相对以前的版本有些改动,比较重要。详见: 跟我学Spring Cloud(Finchley版)番外-01-Eureka安全详解 。
http://www.itmuch.com/spring-cloud/finchley-6/