服务注册发现:Eureka快速搭建以及相关组件与配置说明

EurekaNetflix开源的一个服务注册发现工具,基于REST协议提供服务。也加入到Spring Cloud子项目中。本文介绍一下基于SpringBoot的Eureka快速使用,以及Eureka各个组件和相关配置的说明。

Eureka服务角色

每一个Eureka服务都是一个实例(instance)。而一个实例在Eureka中有两种角色: Eureka ServerEureka Client

  • Eureka Server:注册中心本身,负责监听和维护Eureka Client相关的信息。如主机的加入和退出等
  • Eureka Client:又分为两种, Service ProviderService Consumer
    • Service Provider:服务提供者,在Eureka Server上进行注册,续约,上下线等操作
    • Service Consumer:服务消费者,从Eureka Server上获取服务列表(会定期更新),以此发起调用

当然,这些角色都不是绝对的,只是一个逻辑上的分类,一个实例可以具备Provider和Service的双重身份

Eureka架构

服务注册发现:Eureka快速搭建以及相关组件与配置说明

Eureka简单使用

这边我就不打算打造单节点了,直接整一个伪集群。 先开一个SpringBoot项目,pom.xml里引入以下依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
复制代码

同时启动类上加上@EnableEurekaServer注解:

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {

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

}
复制代码

再分别建立application-v1.properties,application-v2.properties,application-v3.properties 内容分别为:

spring.application.name=eureka-server
server.port=7001
eureka.instance.hostname=peer1
eureka.client.service-url.defaultZone=http://localhost:7002/eureka/,http://localhost:7003/eureka/
复制代码
spring.application.name=eureka-server
server.port=7002
eureka.instance.hostname=peer1
eureka.client.service-url.defaultZone=http://localhost:7001/eureka/,http://localhost:7003/eureka/
复制代码
spring.application.name=eureka-server
server.port=7003
eureka.instance.hostname=peer1
eureka.client.service-url.defaultZone=http://localhost:7001/eureka/,http://localhost:7002/eureka/
复制代码

可以看到,区别也仅仅是端口,不同。比如对于7001端口来说,它作为Eureka Server,同时也是7002和7003端口上Eureka Server的Client,从而搭建出一个Eureka集群

项目打成jar包后,分别执行

java -jar eureka-0.0.1-SNAPSHOT.jar --spring.profiles.active=v1 &
java -jar eureka-0.0.1-SNAPSHOT.jar --spring.profiles.active=v2 &
java -jar eureka-0.0.1-SNAPSHOT.jar --spring.profiles.active=v3 &
复制代码

启动项目,访问localhost:7001可以看到:

服务注册发现:Eureka快速搭建以及相关组件与配置说明

EUREKA-SERVER服务已经注册上去了,对应的节点有三个。那这样Eureka集群就已经搭建好了,当然这只是一个最简单的Demo

Eureka相关参数和流程

第一次注册

当Service Provider第一次向Eureka Server注册的时候,它会把自己的相关信息都发给Eureka Server,包括服务名,ip,端口等。Eureka Server接收到之后,将该信息写入到自己的缓存之中

Service Consumer会按照一定的频率从Eureka Server种拉去服务列表(如果是第一次拉取的话是全量获取,后续是增量获取),获取到服务列表后,用特定的方法(比如Ribbon用的就是轮询的方法来实现客户端的负载均衡)从服务列表种选取一个实例来发送请求

配置:

# 服务名,注册到Eureka Server上,客户端通过这个名字来获取服务列表
spring.application.name: eureka-service

eureka.client.serviceUrl.defaultZone=http://localhost:7002/eureka/,http://localhost:7003/eureka/
# 是否向Eureka Server注册自己
eureka.client.register-with-eureka: true
# 是否向Eureka Server获取注册信息
eureka.client.fetch-registry: true
复制代码

心跳检测

Provider

Eureka Server通过心跳检测来得知Provider的实时状态,心跳检测默认进行频率是30秒。当Eureka Server收到心跳包后,就进行一次续约。如果对应的服务状态发生了变化(比如机器下线了,或者新加入了一台机器),就要把这个更新写到一个“租约变更队列”之中,供后续Comsumer来获取

那Eureka Server怎么知道一个实例是否下线了呢?如果Eureka Server在90秒的时间内没有收到一个实例的心跳包,那么就会认为实例已经下线了,把这个记录更新到”租约变更队列“中

其实Client的下线可以有两种情况,一种是正常下线,在下线之前,Client会主动通知Eureka Server,使得Eureka Server能及时得知此消息;另一种是异常下线,比如进程崩溃,宕机,网络异常等情况,这种情况,Eureka Server90秒内没有收到心跳包就认为该实例下线

# 心跳频率,用来续约,单位:秒
eureka.instance.lease-renewal-interval-in-seconds: 30
#  eureka server多久没有收到心跳,则表示对应的实例过期,单位:秒。
eureka.instance.lease-expiration-duration-in-seconds: : 90s
复制代码

Consumer

Consumer和Eureka Server之间的通信主要是为了获取服务列表,以达到一致性。在Consumer第一次连接上Eureka Server的时候,会进行一次全量获取,后续会每隔30秒进行一次增量的获取,那增量获取的信息是从哪来的呢?还记得我们之前聊过的那个”租约变更队列“吗?实际上就是Eureka Server从队列中获取到的信息,然后进行同步

当然,在这个过程中,因为同步时间是30s,所以在30s中可能会出现信息不一致的情况。当然对于大多数的客户端来说,这个不一致带来的问题不会很大,因为重试功能是不可能没有的。但如果真的需要有更强的一致性的话,可以把这个时间缩短,但是同时也意味着Consumer的心态变得更加频繁了,由此可能会带来一些额外的网络开销,这是需要注意的。并且无论这个时间缩得多短,不一致性也是肯定会存在的。并且Eureka实现的是AP,而抛弃了C(强一致性),所以从这个方面来考虑,这个频率也没必要设置得太快

# 是否从Eureka-Server中获取服务实例注册信息,默认值为true
eureka.client.fetch-registry: true
# 从Eureka-Server拉取注册服务实例信息频率,默认:30 秒
eureka.client.registry-fetch-interval-seconds: 30 

# 是否禁用增量获取服务实例注册信息,设置为true后,每次都是全量获取
eureka.disableDelta: false
复制代码

自我保护机制

考虑这种情况:Eureka Server和Provider之间的网络通信出现了问题,但Provider还正常运行着,也还能对Consumer提供服务。但是由于它发送的心跳包无法到达Eureka Server,Eureka Server认为它下线了,于是从服务列表中移除了这个服务,这样Consumer获取到新的服务列表之后,就会误以为Provider服务不可用,进而导致一些问题

自我保护机制就是为了解决这个问题。当一分钟内Eureka Server收到的心跳包少于一个阈值的时候,就会开启自我保护机制,在这个状态中,Eureka Server不会从服务列表中移除实例(所以这个列表可能会有一些过期的实例,还是照样发给了Consumer)。当收到的心跳包数量达到阈值后,才会退出自我保护状态。

#是否开启自我保护模式。
eureka.server.enable-self-preservation: false
#开启自我保护模式比例阈值,当收到心跳包占期望收到心跳包数量低于这个值,进入自我保护模式。
eureka.server.renewal-percent-threshold: 0.85
复制代码

原文 

https://juejin.im/post/5ef9b18ce51d4534bc7223b3

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » 服务注册发现:Eureka快速搭建以及相关组件与配置说明

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址