SpringColud Eureka的服务注册与发现

时间  2020-06-15
标签 springcolud eureka 服务 注册 发现 繁體版
原文   原文链接

1、Eureka简介

本文中全部代码都会上传到git上，请放心浏览
项目git地址：https://github.com/839022478/Spring-Cloudjava

在传统应用中，组件之间的调用，经过有规范的约束的接口来实现，从而实现不一样模块间良好的协做。可是被拆分红微服务后，每一个微服务实例的网络地址均可能动态变化，数量也会变化，使得原来硬编码的地址失去了做用。须要一个中心化的组件来进行服务的登记和管理，为了解决上面的问题，因而出现了服务治理，就是管理全部的服务信息和状态，也就是咱们所说的注册中心git

1.1 注册中心

好比咱们去作火车或者汽车，须要去买票乘车，只看咱们有没有票（有没有服务），有就去买票（获取注册列表），而后乘车（调用），不用关心到底有多少车在运行github

流程图：
在这里插入图片描述
使用注册中心，咱们不须要关心有多少提供方，只管去调用就能够了，那么注册中心有哪些呢？web

注册中心：Eureka，Nacos，Consul，Zookeeperspring

本文中讲解的是比较火热的Spring Cloud微服务下的Eureka，Eureka是Netflix开发的服务发现框架，是一个RESTful风格的服务，是一个用于服务发现和注册的基础组件，是搭建Spring Cloud微服务的前提之一，它屏蔽了Server和client的交互细节，使得开发者将精力放到业务上。数据库

服务注册与发现主要包括两个部分：服务端（Eureka Server）和客户端（Eureka Client）浏览器

  • 服务端(Eureka Server)： 一个公共服务，为Client提供服务注册和发现的功能，维护注册到自身的Client的相关信息，同时提供接口给Client获取注册表中其余服务的信息，使得动态变化的Client可以进行服务间的相互调用。缓存

  • 客户端(Eureka Client)： Client将本身的服务信息经过必定的方式登记到Server上，并在正常范围内维护本身信息一致性，方便其余服务发现本身，同时能够经过Server获取到本身依赖的其余服务信息，完成服务调用，还内置了负载均衡器，用来进行基本的负载均衡服务器

Eureka GIt官网：https://github.com/Netflix/Eureka网络

1.3 服务注册与发现

服务注册与发现关系图：
在这里插入图片描述

1.2 client功能和server功能

1.2.1 client功能

  1. 注册：每一个微服务启动时，将本身的网络地址等信息注册到注册中心，注册中心会存储（内存中）这些信息。
  2. 获取服务注册表：服务消费者从注册中心，查询服务提供者的网络地址，并使用该地址调用服务提供者，为了不每次都查注册表信息，因此client会定时去server拉取注册表信息到缓存到client本地。
  3. 心跳：各个微服务与注册中心经过某种机制（心跳）通讯，若注册中心长时间和服务间没有通讯，就会注销该实例。
  4. 调用：实际的服务调用，经过注册表，解析服务名和具体地址的对应关系，找到具体服务的地址，进行实际调用。

1.2.2 server注册中心功能

  1. 服务注册表：记录各个微服务信息，例如服务名称，ip，端口等。
    注册表提供 查询API（查询可用的微服务实例）和管理API（用于服务的注册和注销）。
  2. 服务注册与发现：注册：将微服务信息注册到注册中心。发现：查询可用微服务列表及其网络地址。
  3. 服务检查：定时检测已注册的服务，如发现某实例长时间没法访问，就从注册表中移除。

2、Eureka单节点搭建

2.1 pom.xml

在有的教程中，会引入spring-boot-starter-web，这个依赖其实不用，由于spring-cloud-starter-netflix-eureka-server的依赖已经包含了它，在pom依赖进去，就能够了

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

2.2 application.yml

server:
  port: 8500
eureka:
  client:
    #是否将本身注册到Eureka Server,默认为true，因为当前就是server，故而设置成false，代表该服务不会向eureka注册本身的信息
    register-with-eureka: false
    #是否从eureka server获取注册信息，因为单节点，不须要同步其余节点数据，用false
    fetch-registry: false
    #设置服务注册中心的URL，用于client和server端交流
    service-url:
      defaultZone: http://localhost:8080/eureka/

2.3 服务端启动类

启动类上添加此注解标识该服务为配置中心
@EnableEurekaServer

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {

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

}

2.4 启动

咱们启动EurekaDemoApplication ，而后在浏览器中输入地址 http://localhost:8500/，就能够启动咱们的 Eureka 了，咱们来看下效果，出现了这个画面，就说明咱们已经成功启动~，只是此时咱们的服务中是尚未客户端进行注册
在这里插入图片描述

3、服务注册

注意：在客户端pom里面咱们须要加上spring-boot-starter-web，不然服务是没法正常启动的

3.1 pom.xml

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

3.2 application.yml

#注册中心
eureka:
  client:
    #设置服务注册中心的URL
    service-url:
      defaultZone: http://localhost:8500/eureka/
  #服务名
  instance:
    appname: mxn

3.3 客户端启动类

在客户端启动类中咱们须要加上 @EnableDiscoveryClient注解

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@EnableDiscoveryClient
@SpringBootApplication
public class EurekaClientApplication {

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

3.4 查看效果

工程启动后，刷新http://localhost:8500/页面，咱们能够发现服务注册成功了
在这里插入图片描述

而且咱们能够在idea日志打印中看到DiscoveryClient_MXN/DESKTOP-5BQ3UK8 - registration status: 204,说明就是注册成功了
Eureka Server与Eureka Client之间的联系主要经过心跳的方式实现。心跳(Heartbeat)即Eureka Client定时向Eureka Server汇报本服务实例当前的状态，维护本服务实例在注册表中租约的有效性。

Eureka Client将定时从Eureka Server中拉取注册表中的信息，并将这些信息缓存到本地，用于服务发现

4、Eureka 端点

官网地址：https://github.com/Netflix/eureka/wiki/Eureka-REST-operations

Eureka服务器还提供了一个端点（eureka/apps/{applicaitonName}）能够查看所注册的服务详细信息 。applicaitonName就是微服务的名称，好比这里咱们访问 http://localhost:8500/eureka/apps/mxn

在这里插入图片描述

5、Eureka 原理

5.1 本质

存储了每一个客户端的注册信息。EurekaClient从EurekaServer同步获取服务注册列表。经过必定的规则选择一个服务进行调用

5.2 Eureka架构图

在这里插入图片描述

  • 服务提供者： 是一个eureka client，向Eureka Server注册和更新本身的信息，同时能从Eureka Server注册表中获取到其余服务的信息。
  • 服务注册中心： 提供服务注册和发现的功能。每一个Eureka Cient向Eureka Server注册本身的信息，也能够经过Eureka Server获取到其余服务的信息达到发现和调用其余服务的目的。
  • 服务消费者： 是一个eureka client，经过Eureka Server获取注册到其上其余服务的信息，从而根据信息找到所需的服务发起远程调用。
  • 同步复制： Eureka Server之间注册表信息的同步复制，使Eureka Server集群中不一样注册表中服务实例信息保持一致。
  • 远程调用： 服务客户端之间的远程调用。
  • 注册： Client端向Server端注册自身的元数据以供服务发现。
  • 续约： 经过发送心跳到Server以维持和更新注册表中服务实例元数据的有效性。当在必定时长内，Server没有收到Client的心跳信息，将默认服务下线，会把服务实例的信息从注册表中删除。
  • 下线： Client在关闭时主动向Server注销服务实例元数据，这时Client的服务实例数据将从Server的注册表中删除。
  • 获取注册表： Client向Server请求注册表信息，用于服务发现，从而发起服务间远程调用。

5.3 Eureka自我保护

有时候咱们会看到这样的提示信息：EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY'RE NOT. RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE.，这是由于默认状况下，Eureka Server在必定时间内，没有接收到某个微服务心跳，会将某个微服务注销（90S）。可是当网络故障时，微服务与Server之间没法正常通讯，上述行为就很是危险，由于微服务正常，不该该注销，它的指导思想就是 宁肯保留健康的和不健康的，也不盲目注销任何健康的服务
咱们也能够经过命令去关闭自我保护的功能：

eureka:
  server: 
    enable-self-preservation: false

那么自我保护是如何触发的呢？
自我保护机制的触发条件是，当每分钟心跳次数( renewsLastMin) 小于 numberOfRenewsPerMinThreshold时，而且开启自动保护模式开关( eureka.server.enable-self-preservation = true) 时，触发自我保护机制，再也不自动过时租约
上面咱们全部的小于 numberOfRenewsPerMinThreshold，究竟是怎么计算的呢，咱们在eureka源码中能够得知

numberOfRenewsPerMinThreshold = expectedNumberOfRenewsPerMin * 续租百分比（默认为0.85）
expectedNumberOfRenewsPerMin = 当前注册的应用实例数 x 2
当前注册的应用实例数 x 2 是由于，在默认状况下，注册的应用实例每半分钟续租一次，那么一分钟心跳两次，所以 x 2

例如：咱们有10个服务，指望每分钟续约数：10 * 2=20，指望阈值：20*0.85=17，当少于17时，就会触发自我保护机制
在这里插入图片描述

5.4 健康检查

因为server和client经过心跳保持 服务状态，而只有状态为UP的服务才能被访问。看eureka界面中的status。
在这里插入图片描述

好比心跳一直正常，服务一直UP，可是此服务DB(数据库)连不上了，没法正常提供服务。

此时，咱们须要将 微服务的健康状态也同步到server。只须要启动eureka的健康检查就行。这样微服务就会将本身的健康状态同步到eureka。配置以下便可。

在client端配置：将本身的健康状态传播到server。

eureka:
  client:
    healthcheck:
      enabled: true

5.5 Eureka监听事件

import com.netflix.appinfo.InstanceInfo;
import org.springframework.cloud.netflix.eureka.server.event.*;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component
public class CustomEvent {

    @EventListener
    public void listen(EurekaInstanceCanceledEvent event ) {
        System.out.println(LocalDateTime.now()+"服务下线事件:"+event.getAppName()+"---"+event.getServerId());
//发钉钉
    }

    @EventListener
    public void listen(EurekaInstanceRegisteredEvent event) {
        InstanceInfo instanceInfo = event.getInstanceInfo();
        System.out.println(LocalDateTime.now()+"服务上线事件:"+instanceInfo.getAppName()+"---"+instanceInfo.getInstanceId());
    }

    @EventListener
    public void listen(EurekaInstanceRenewedEvent event) {
        System.out.println(LocalDateTime.now()+"服务续约/心跳上报事件:"+event.getAppName()+"---"+event.getServerId());

    }

    @EventListener
    public void listen(EurekaRegistryAvailableEvent event) {
        System.out.println(LocalDateTime.now()+"注册中心可用事件");
    }

    @EventListener
    public void listen(EurekaServerStartedEvent event) {
        System.out.println(LocalDateTime.now()+"注册中心启动事件");

    }
}

5.6 Renew: 服务续约

Eureka Client 会每隔 30 秒发送一次心跳来续约。 经过续约来告知 Eureka Server 该 Eureka Client 运行正常，没有出现问题。 默认状况下，若是 Eureka Server 在 90 秒内没有收到 Eureka Client 的续约，Server 端会将实例从其注册表中删除，此时间可配置，通常状况不建议更改。

5.6 服务剔除

若是Eureka Client在注册后，既没有续约，也没有下线(服务崩溃或者网络异常等缘由)，那么服务的状态就处于不可知的状态，不能保证可以从该服务实例中获取到回馈，因此须要服务剔除此方法定时清理这些不稳定的服务，该方法会批量将注册表中全部过时租约剔除，剔除是定时任务，默认60秒执行一次。延时60秒，间隔60秒

剔除的限制：
1.自我保护期间不清除。
2.分批次清除。

6、Eureka缺陷

因为集群间的同步复制是经过HTTP的方式进行，基于网络的不可靠性，集群中的Eureka Server间的注册表信息不免存在不一样步的时间节点，不知足CAP中的C(数据一致性)

7、总结

中间咱们讲解了eureka的节点搭建，以及原理，对于如今很火热的微服务，咱们对Eureka是很是有必要进行了解的，若是以为文章对你有帮助，来个点赞支持吧，若是对文章有疑问或建议，欢迎讨论留言，谢谢你们~

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程