eurake注册中心_eureka注册中心

eurake注册中心_eureka注册中心3、Eurake服务注册与发现3.1基于Springboot构建Eurake服务在第二节中《Springboot项目构建》 中的第三步中选择如下组件: 左侧选择 cloudDiscovery 在其子组件中选择 EurakeServer ,我们在这里面还可以看到 EurakeDiscovery 、ZookeeperDiscovery 等组件。其中EurakeDisco

3、 Eurake 服务注册与发现

3.1 基于Springboot构建Eurake服务

在第二节中《Springboot项目构建》 中的第三步 中选择如下组件: eurake注册中心_eureka注册中心左侧选择 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 组件,但我们还需要启用他(后面很多组件也需要类似的方式去启用):

此代码由Java架构师必看网-架构君整理
@SpringBootApplication @EnableEurekaServer public class EurekaserverApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaserverApplication.class, args);
    }
}

我们通过@EnableEurekaServer去启用Eurake

resources/application.properties 中添加如下配置:

此代码由Java架构师必看网-架构君整理
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/ 我们看看见如下页面: eurake注册中心_eureka注册中心

目前还没有服务注册进来。

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项目构建》 中的第三步 中选择如下组件:

eurake注册中心_eureka注册中心左侧选择 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 main(String[] args) {
        SpringApplication.run(AppApplication.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/ 我们发现多了一条服务: eurake注册中心_eureka注册中心

我们通过不同端口再次启动该服务 我们发现有多了一条服务:

eurake注册中心_eureka注册中心

我们发现这两个服务 属于一个共同的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 获取到如下结果:

eurake注册中心_eureka注册中心

对于我们使用java编写的应用,基于Springcloud EurekaDiscovery 中已经分装这些功能。下面对源码进行分析一下。 eurake注册中心_eureka注册中心

我们可以发现Springcloud 定义了 DiscoveryClient 接口,来抽象Rest端,其下面有三实现类,我们关注的是基于Eureka实现的EurekaDiscoveryClient。查看此类的实现: eurake注册中心_eureka注册中心此类中引入了com.netflix.discovery包下的EurakeClient 接口。 eurake注册中心_eureka注册中心实现此接口的类是com.netflix.discovery包下的DiscovClient 类。

架构君码字不易,如需转载,请注明出处:https://javajgs.com/archives/209550
0

发表评论