3、 Eurake 服务注册与发现
3.1 基于Springboot构建Eurake服务
在第二节中《Springboot项目构建》 中的第三步 中选择如下组件: 左侧选择 cloud Discovery 在其子组件中选择 EurakeServer ,我们在这里面还可以看到 EurakeDiscovery 、ZookeeperDiscovery 等组件。 其中EurakeDiscovery 就是我们后面,将服务提供方的服务注册到EurakeServer 中时需要引入的组件。
项目构建成功后我们会在pom.xml发现如下依赖:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
说明我们已经成功引入了EurakeServer。 不过我们还需要进行下面配置 虽然我们已经引入了EurakeServer 组件,但我们还需要启用他(后面很多组件也需要类似的方式去启用):
@SpringBootApplication
@EnableEurekaServer
public class EurekaserverApplication {
public static void mainString[] args) {
SpringApplication.runEurekaserverApplication.class, args);
}
}
我们通过@EnableEurekaServer去启用Eurake
在resources/application.properties 中添加如下配置:
server.port=8761
eureka.client.register-with-eureka=false #是否将自己注册到EurrkeServer,默认为true
eureka.client.fetch-registry=false #表示是否从EurekaServer获取注册信息,默认为true,表示需要从其他server同步信息
eureka.client.service-url.defaultZone= http://localhost:8761/eureka/#设置与EurekaServer 交互的地址,查询服务和注册服务都依赖这个地址
至此,我们的Eurake已经配置完成了,是不是很简单。 启动服务,打开http://localhost:8761/ 我们看看见如下页面:
目前还没有服务注册进来。
Now that we’ve stood up a service registry, let’s stand up a client that both registers itself with the
registry and uses the Spring Cloud DiscoveryClient abstraction to interrogate the registry for it’s own host and port. The @EnableDiscoveryClient activates the Netflix Eureka DiscoveryClient implementation. There are other implementations for other service registries like Hashicorp’s Consul or Apache Zookeeper.
现在,我们已经注册了一个服务注册中心,让我们再使用注册表注册自己的客户端,并使用Spring Cloud DiscoveryClient抽象来询问注册表本身的主机和端口。@EnableDiscoveryClient 激活Netflix Eureka DiscoveryClient 实现。还有其他服务注册的实现,比如Hashicorp的领事或Apache Zookeeper。
3.2 基于Springboot 构建服务提供方
在第二节中《Springboot项目构建》 中的第三步 中选择如下组件:
左侧选择 cloud Discovery 在其子组件中选择 EurakeDiscovery
项目构建成功后我们会在pom.xml发现如下依赖:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
其实与构建EurakeServer 的依赖一样。
启用服务发现:
@SpringBootApplication
@EnableDiscoveryClient
public class AppApplication {
public static void mainString[] args) {
SpringApplication.runAppApplication.class, args);
}
}
在resources/application.properties 中添加如下配置:
server.port=8802 #应用端口号
spring.application.name=app-8801 #服务名称
eureka.client.service-url.defalutZone= http://localhost:8761/eureka/ #EurekaServer服务地址
turbine.combine-host-port=true #同一主机上的服务,以不同端口号区分,默认情况下是以host来区分,后面服务监控时是将到
eureka.instance.prefer-ip-address=true #表示将自己的IP注册到EurekaServer 上,如果不配置或者将其设置为false,则表示将微服务所在系统的hostname注册到EurekaServer上
启动服务,我们再次打开 http://localhost:8761/ 我们发现多了一条服务:
我们通过不同端口再次启动该服务 我们发现有多了一条服务:
我们发现这两个服务 属于一个共同的application:APP-8801 ,当服务调用端Client去调用该服务是,只需知道服务名称 APP-8801 ,Eurake会通过Ribbon进行负载均衡 随机请求两个服务中的一个服务,服务在均衡的策略是可以配置的。在《4、Ribbon 客户端负载均衡》我会具体介绍,如何去设计负载均衡的策略。
3.3 EurakeServer 高可用
单点的Eurake server 在生产环境下并不适用,一旦发生宕机,会造成所有服务之间的调用无法适用,在3.1中配置EurakeServer时 有如下两个属性:
eureka.client.register-with-eureka=false #是否将自己注册到EurrkeServer,默认为true
eureka.client.fetch-registry=false #表示是否从EurekaServer获取注册信息,默认为true,表示需要从其他server同步信息
我关闭了 eurakaServer 将自己注册的功能,和sever之间的同步功能, 他们是默认开启的。 我们只要将这两个设置为true,就可以实现Eurake的高可用了。
Eureka自我保护性
默认情况下Eureka 在90内没有获取的服务的心跳,将注销该服务。但是有时候是网络分区故障的问题导致Eureka无法收到心跳,服务本身是健壮的,如果删除此服务,这会导致服务不可用。当开启了Eureka自我保护后,Eureka会保护此服务在注册表中的信息,使其不会被删除,等网络恢复后,Eureka节点会自动退出自我保护模式。 Eureka 的自我保护模式默认是允许开启的,如要禁用可在application.properties 中添加如下配置:
eureka.server.enable-self-preservation=false
3.4 EurakeSever 认证
在生产环境下,我们不可能允许什么服务都能注册到Eurake 中,为此需要添加EurakeServer的身份认证。
我们需要在EurakeSever中添加如下依赖: org.springframework.boot spring-boot-starter-security
并在application.properties 中添加如下信息:
#添加basic认证
security.basic.enabled=true
security.user.name=user
security.user.password=password
此时我们已经为EurakeSever 开启了Basic 认证
为此,我们也修改服务端,我们只需要将服务提供端application.properties 中原来的
eureka.client.service-url.defalutZone= http://localhost:8761/eureka/
变为: eureka.client.service-url.defalutZone= http://user:password@localhost:8761/eureka/
3.5 Eureka Server Rest 端点
非java编写的服务可以利用这些Rest端点去操作Eureka。
操作 | HTTP | action | 描述 |
---|---|---|---|
注册新的应用实例 | POST | /eureka/v2/apps/appID | 接受JSON/XML格式请求,返回204响应码表示成功 |
发送应用实例心跳 | PUT | /eureka/v2/apps/appID/instanceID | 返回响应码200表示成功,404表示instanceID不存在 |
查询所有实例 | GET | /eureka/v2/apps | 返回响应码200表示成功,响应内容格式JSON/XML |
为所有appID实例做查询Query for all appID instances) | GET | /eureka/v2/apps/appID | 返回响应码200表示成功,响应内容格式JSON/XML |
为特定的appID/instanceID做查询 | GET | /eureka/v2/apps/appID/instanceID | 返回响应码200表示成功,响应内容格式JSON/XML |
为特定的instanceID做查询 | GET | /eureka/v2/instances/instanceID | 返回响应码200表示成功,响应内容格式JSON/XML |
停止服务实例Take instance out of service) | PUT | /eureka/v2/apps/appID/instanceID/status?value=OUT_OF_SERVICE | 返回响应码200表示成功,500失败。 |
将实例恢复到服务移除覆盖) | DELETE | /eureka/v2/apps/appID/instanceID/status?value=UP | value=UP是可选的,它被建议用于fallback状态,由于取消了覆盖) 返回响应码200表示成功,500失败。 |
更新元数据 | PUT | /eureka/v2/apps/appID/instanceID/metadata?key=value | 返回响应码200表示成功,500失败。 |
查询特定vip address 下的所有实例 | GET | /eureka/v2/vips/vipAddress | 返回响应码200表示成功,响应内容格式:JSON/XML,返回404表示vipAddress不存在 |
查询特定secure vip address下所有实例 | GET | /eureka/v2/svips/svipAddress | 返回响应码200表示成功,响应内容格式:JSON/XML,返回404表示svipAddress不存在 |
如我请求查询所有实例:http://localhost:8761/eureka/apps 获取到如下结果:
对于我们使用java编写的应用,基于Springcloud EurekaDiscovery 中已经分装这些功能。下面对源码进行分析一下。
我们可以发现Springcloud 定义了 DiscoveryClient 接口,来抽象Rest端,其下面有三实现类,我们关注的是基于Eureka实现的EurekaDiscoveryClient。查看此类的实现: 此类中引入了com.netflix.discovery包下的EurakeClient 接口。 实现此接口的类是com.netflix.discovery包下的DiscovClient 类。