Spring Cloud服务注册与发现主要交互流程如下:
【服务提供者】启动时向【注册中心】注册,【注册中心】维护注册服务列表。
【服务消费者】定期从【注册中心】获取服务的注册信息,如:有几个实例,每个实例的IP地址,访问端口等信息。获取的服务列表缓存在【服务消费者】者本地,【服务消费者】每次调用服务时直接从本地缓存读取服务信息。
【服务提供者】定期向【注册中心】续约,超过一定期限没有续约的服务将会从【注册中心】的服务列表中剔除。
【服务提供者】、【服务消费者】、【注册中心】三者之间的交互关系可以参考下图:
具体配置参数如下:
服务提供者:
服务是否注册至注册中心
eureka.cli ent.register-with-eureka = true
定义服务续约任务的调用间隔时间,默认为30秒
eureka.instance.lease-renewal-interval-in-seconds=30
定义服务失效的时间,默认为90秒
eureka.instance.lease-expiration-duration-in-seconds=90
服务下线:
Spring Boot使用内置Web 容器启动。如果使用linux kill命令去杀死【服务提供者】进程,【注册中心】是无法立即知道的,客户端的服务请求仍然会转发到已经杀死的服务上。不过Spring Boot封装了正确停止内置Web 容器的方式,其与Spring Cloud进行集成,可以立即通知到【注册中心】服务已经下线。
主要有两种方式:1.通过http协议向【服务提供者】发送shutdown命令 2.将【服务提供者】封装成系统服务,然后使用service stop命令。我们的架构使用第一种方式。
1.在pom.xml中引入actuator依赖。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-security</artifactId>
</dependency>
2.在application.properties文件开启shutdown endpoint,SpringBoot的endpoints.shutdown.enabled默认是关闭的
#启用shutdown endpoints.shutdown.enabled=true
#禁用密码验证 endpoints.shutdown.sensitive=false
3.发送停止信号,使用curl向服务器发送post请求:
curl -X POST host:port/shutdown
服务消费者:
消费者本地缓存一份注册服务清单。缓存清单更新的时间默认为30秒。
eureka.client.registry-fetch-interval-seconds = 30
虽然用Spring Boot自身提供的下线服务,可以即时通知到注册中心,但是从注册中心再同步到客户端仍然会有30秒的延迟时间。所以在我们在生产上滚动发布新服务时,如果只有两个实例,一定要确保一个新版本服务实例已经可以正常提供服务,再下线另一个服务实例。为什么这么说了,看一下我们的发布流程:
两个服务实例,S1,S2版本为v1,现在要发v2版本。
先下线S1 v1版本的服务,30秒后,【服务消费者】服务列表中清理掉S1 v1服务注册信息。然后启动S1 v2服务,此时S1 v2注册信息还没有缓存到【服务消费者】端,需要30秒后从【注册中心】才能同步到最新注册信息,所以如果此时立即下线S1 v1服务,将会导致短暂无服务可用的状况,这在生产上是不允许的。
服务注册中心:
EurekaServer在启动的时候会创建 一 个定时任务,定期扫描,每隔 一 段时间(默认为60秒) 将当前清单中超时(默认为90秒)没有续约的服务剔除出去。
eureka.server.evictionIntervalTimerInMs=60000
自我保护模式:
【注册中心】运行期间会统计【服务提供者】心跳失败的比例在15分钟之内是否低于85%, 如果出现低于85%的情况(在单机调试的时候很容易满足, 实际在生产环境上通常是由于网络不稳定导致),【注册中心】会将当前的实例注册信息保护起来, 让这些实例注册信息不会过期。
但是如果实例真的出现问题,比如重新发布新版本的服务时,会先下线旧版本的服务, 这种情况下客户端很可能会将请求转发至实际不存在或不能正常提供服务的实例, 此时会出现调用失败的清况, 所以客户端必须要有容错机制, 比如可以使用请求重试、 断路器等机制。在我们架构中,我们采用重试机制,直接重试集群中其它实例。
开发及测试环境,建议关闭自我保护模式,以确保注册中心可以将不可用的实例正确剔除。
eureka.server.enable-self-preservation=false