SpringCloud系列之服务治理Eureka

Posted 2022-08-02 共饮一杯无

什么是Eureka

Netflix Eureka 是一款由 Netflix 开源的基于 REST 服务的注册中心，用于提供服务发现功能。Spring Cloud Eureka 是 Spring Cloud Netflix 微服务套件的一部分，基于 Netflix Eureka 进行了二次封装，主要负责完成微服务架构中的服务治理功能。

Spring Cloud Eureka 是一个基于 REST 的服务，并提供了基于 Java 的客户端组件，能够非常方便的将服务注册到 Spring Cloud Eureka 中进行统一管理。

Eureka核心概念服务注册和服务发现

服务注册

注册中心拆开来看注册和中心。注册比如用户注册，就是将自己的信息注册在某个平台上。中心可以理解成一个统一管理信息的平台。所以注册中心顾名思义是统一管理所有注册信息的平台。
服务注册指的是服务在启动时将自身的信息注册到注册中心中，方便信息进行统一管理。服务注册是客户端向注册中心提交信息的动作。

服务发现

服务发现指的是从注册中心获取对应服务的信息,是客户端向注册中心拉取pull信息的动作。

Eureka实战

Eureka 的架构主要分为 Eureka Server 和 Eureka Client 两部分，Eureka Client 又分为 Applicaton Service 和 Application Client，Applicaton Service 就是服务提供者，Application Client 就是服务消费者。Eureka Client 会向 Eureka Server 发送请求，进行注册，并将自己的一些信息发送给 Eureka Server。
注册成功后，每隔一定的时间，Eureka Client 会向 Eureka Server 发送心跳来续约服务，也就是汇报健康状态。 如果客户端长时间没有续约，那么 Eureka Server 将在 90 秒（默认）内从服务器注册表中删除客户端的信息。
Eureka Client 还会定期从 Eureka Server 拉取注册表信息，然后通过Ribbon 组件根据负载均衡算法得到一个目标，并发起远程调用。
应用正常停止时也会通知 Eureka Server 移除相关信息，信息成功移除后，其他客户端会更新服务的信息，这样就不会调用已经下线的服务了，当然这个会有延迟，有可能会调用到已经失效的服务，所以在客户端会开启失败重试功能来避免这个问题。
Eureka Server 会有多个节点组成一个集群，保证高可用。Eureka Server 没有集成其他第三方存储，而是存储在内存中，内部维护一个注册表的概念。所以 Eureka Server 之间会将注册信息复制到集群中的 Eureka Server 的所有节点。 这样数据才是共享状态，任何的 Eureka Client 都可以在任何一个 Eureka Server 节点查找注册表信息。

Eureka服务端单节点构建

打开https://start.spring.io/ 或者阿里云的快速start https://start.aliyun.com/bootstrap.html ，开始构建对应的服务端项目。推荐使用阿里云的快速start，因为访问速度更快些。

自动生成完成后，在resource目录下，新建application.yml文件替换原来的application.properties。内容如下：

#应用名称
spring:
  application:
    name: eureka-server
server:
  port: 8001
eureka:
  client:
    # 是否将自己实例注册到Eureka Server中
    register-with-eureka: false
    # 是否应从Eureka Server获取Eureka注册表信息
    fetch-registry: false

在SpringBoot的启动类上添加@EnableEurekaServer 注解，表示是Eureka 服务端。
上述配置完成后，一个单节点的Eureka服务端就配置完成了，启动效果如下：

访问http://localhost:8761/ 可以进入eureka控制台。

目前还没有任何一个服务注册到 Eureka 中，不过从上图中，我们还是可以看到关于 Eureka 服务器内存、CPU 、IP等的相关信息。
EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEYRE NOT. RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE。
图中红色警告翻译为：紧急!Eureka已经不能确认这些已经启动的实例是否可用，由于最近的续订次数小于续订阈值（续订期望值），为了安全起见（实例可用），当前这些实例不会删除。
这是因为Eureka进入自我保护模式（SELF PRESERVATION MODE）。

Eureka服务端集群构建

单个 Eureka 服务可能存在的单点失效问题，我们通常都需要构建一个 Eureka 服务器集群来确保注册中心本身的可用性。与传统的集群构建方式不同，如果我们把 Eureka 也视为一个服务，也就是说 Eureka服务自身也能注册到其他 Eureka 服务上，从而实现相互注册，并构成一个集群。
同样可以通过单节点构建步骤构建两个Eureka Server服务A和B。对应的yml配置如下：

server: 
  port: 8761 

eureka: 
  instance: 
    hostname: eurekaA 
  client: 
    serviceUrl:
       defaultZone: http:// eurekaB:8762/eureka/ 

server: 
  port: 8762 

eureka: 
  instance: 
    hostname: eurekaB 
  client: 
    serviceUrl:
       defaultZone: http://eurekaA:8761/eureka/ 

eureka.instance.hostname 是Eureka 实例管理类配置项 ，用于指定当前 Eureka 服务的主机名称。
需要在本机的hosts文件中添加以下信息：

127.0.0.1 eurekaA 
127.0.0.1 eurekaB

我们可以看到服务端A和B只调整了端口和地址的引用。构建 Eureka 集群模式的关键点在于使用客户端配置项 eureka.client.serviceUrl.defaultZone 用于指向集群中的其他 Eureka 服务器。所以 Eureka 集群的构建方式实际上就是将自己作为服务并向其他注册中心注册自己，这样就形成了一组互相注册的服务注册中心以实现服务列表的同步。这个场景下 register-with-eureka（是否将自己实例注册到Eureka Server中） 和 fetch-registry（是否应从Eureka Server获取Eureka注册表信息）配置项应该都使用其默认的 true 值，我们不需要对其进行显式的设置。
如果你尝试使用本机搭建集群环境，显然 eureka.instance.hostname 配置项中的 eureka1 和 eureka2 是无法访问的，所以需要在本机hosts 文件中添加以下信息。
现在启动这两个 Eureka 服务，然后分别打开 http://127.0.0.1:8761/ 和 http://127.0.0.1:8762/ 端点可以看到各自的服务注册效果。

Eureka客户端构建

客户端引入的pom坐标有差异，需要引入客户端坐标：

<dependency> 
     <groupId>org.springframework.cloud</groupId> 
     <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> 
</dependency> 

在启动类上需要加@EnableDiscoveryClient注解表示是Eureka客户端。

@EnableDiscoveryClient
@SpringBootApplication
public class EurekaClientProviderApplication 

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

yml配置如下：

spring: 
  application: 
    name: eureka-client  
server: 
  port: 8081 

eureka: 
  client: 
    serviceUrl: 
    #指定eureka服务端地址，如果是集群则通过逗号分隔
      defaultZone: http://localhost:8761/eureka/ 

配置完成后可以在eureka控制台查看到相关注册信息。