SpringCloud微服务核心组件Eureka

朴灿烈づ我的快乐病毒、 2022-12-30 13:36 160阅读 0赞

一 Eureka服务治理体系  
服务治理==服务注册+服务发现  
**服务治理实现：**  
**1.1 服务治理**  
服务治理是微服务架构中最核心和基础的模块，主要用来实现各个微服务实例的自动化注册和发现，  
Eureka服务治理体系如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2pveV90b20_size_16_color_FFFFFF_t_70]  
**1.2 服务注册**  
在服务治理的框架中，会创建一个注册中心，每个服务单元都向服务中心注册自己的服务，包括服务的ip和端口号、服务版本号、通讯协议等，注册中心按照服务名组织服务清单，同时还要使用心跳检测，去检测服务清单中是否有可用服务，如果出现不可用的服务就进行清除，  
**1.3 服务发现**  
在服务治理的框架中，服务间的调用不在使用指定具体的实例地址来实现，通过服务名发起请求调用实现，服务调用方通过服务名，从服务注册中心的服务清单中获取实例的列表清单，再通过负载均衡的策略取出一个服务实例的位置进行调用。

**Eureka服务端**  
Eureka服务端，即服务注册中心。它同其他服务注册中心一样，支持高可用配置。依托于强一致性提供良好的服务实例可用性，可以应对多种不同的故障场景

Eureka服务端支持集群模式部署，当集群中有分片发生故障的时候，Eureka会自动转入自我保护模式。它允许在分片发生故障的时候继续提供服务的发现和注册，当故障分配恢复时，集群中的其他分片会把他们的状态再次同步回来。集群中的的不同服务注册中心通过异步模式互相复制各自的状态

**高可用服务注册中心**  
Eureka Server在设计的时候就考虑了高可用设计，在Eureka服务治理设计中，所有节点既是服务的提供方，也是服务的消费方，服务注册中心也不例外。  
Eureka Server的高可用实际上就是将自己做为服务向其他服务注册中心注册自己，这样就可以形成一组互相注册的服务注册中心，以实现服务清单的互相同步，达到高可用的效果。

**构建服务注册中心集群**  
Eureka Server的同步遵循着一个非常简单的原则：只要有一条边将节点连接，就可以进行信息传播与同步。可以采用两两注册的方式实现集群中节点完全对等的效果，实现最高可用性集群，任何一台注册中心故障都不会影响服务的注册与发现

**服务提供者**

服务注册：  
服务提供者在启动的时候会通过REST请求的方式将自己注册到Eureka Server上，同时带上自身服务的一些元数据信息。Eureka Server接收到这个Rest请求之后，将元数据信息存储在一个双层结构的Map中，其中第一层的key是服务名。第二层的key 是具体服务的实例名。  
在服务注册时，需要确认一下eureka.client.register-with-eureka=true参数是否正确，该值默认为true。若设置为fasle将不会启动注册操作。

服务同步：  
从eureka服务治理体系架构图中可以看到，不同的服务提供者可以注册在不同的服务注册中心上，它们的信息被不同的服务注册中心维护。

此时，由于多个服务注册中心互相注册为服务，当服务提供者发送注册请求到一个服务注册中心时，它会将该请求转发给集群中相连的其他注册中心，从而实现服务注册中心之间的服务同步。通过服务同步，提供者的服务信息就可以通过集群中的任意一个服务注册中心获得。

服务续约：  
在注册服务之后，服务提供者会维护一个心跳用来持续高速Eureka Server，“我还在持续提供服务”，否则Eureka Server的剔除任务会将该服务实例从服务列表中排除出去。我们称之为服务续约。

下面是服务续约的两个重要属性：  
（1）eureka.instance.lease-expiration-duration-in-seconds

leaseExpirationDurationInSeconds，表示eureka server至上一次收到client的心跳之后，等待下一次心跳的超时时间，在这个时间内若没收到下一次心跳，则将移除该instance  
默认为90秒  
如果该值太大，则很可能将流量转发过去的时候，该instance已经不存活了。  
如果该值设置太小了，则instance则很可能因为临时的网络抖动而被摘除掉。  
该值至少应该大于leaseRenewalIntervalInSeconds  
（2）eureka.instance.lease-renewal-interval-in-seconds

leaseRenewalIntervalInSeconds，表示eureka client发送心跳给server端的频率。如果在leaseExpirationDurationInSeconds后，server端没有收到client的心跳，则将摘除该instance。除此之外，如果该instance实现了HealthCheckCallback，并决定让自己unavailable的话，则该instance也不会接收到流量。

默认30秒

获取服务：  
消费者服务启动时，会发送一个Rest请求给服务注册中心，来获取上面注册的服务清单。为了性能考虑，Eureka Server会维护一份只读的服务注册清单来返回给客户端，同时该缓存清单默认会每隔30秒更新一次。

下面是获取服务的两个重要的属性：  
（1） eureka.client.fetch-registry是否需要去检索寻找服务，默认是true  
（2）eureka.client.registry-fetch-interval-seconds  
表示eureka client间隔多久去拉取服务注册信息，默认为30秒，对于api-gateway，如果要迅速获取服务注册状态，可以缩小该值，比如5秒

服务调用：  
服务消费者在获取服务清单后，通过服务名可以获取具体提供服务的实例名和该实例的元数据信息。因为有这些服务实例的详细信息，所以客户端可以根据自己的需要决定具体调用哪个实例，在Ribbon中会默认采用轮询的方式进行调用，从而实现客户端的负载均衡。

通讯协议  
默认情况下，Eureka使用Jersey和XStream配合JSON作为Server与Client之间的通讯协议

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2pveV90b20_size_16_color_FFFFFF_t_70]: /images/20221120/aa4a25f2d1fc4545a04882183aff0891.png